Tag: docker rabbitmq

Rabbitmq生产者（symfony 3）和消费者错误（NodeJs）

我用symfony 3创build了一个Producer ProducerController class ProducerController extends Controller { /** * @Route("/producer", name="producer") */ public function uploadAction(Request $request) { $userId = mt_rand(1, 1000000); $message = \Swift_Message::newInstance() ->setSubject('Sujet de l\'email') ->setFrom('test@xxx.com') ->setTo('destinaire@xxx.com') ->setBody($this->renderView('index.html.twig', ['userId' =>$userId]), 'text/html'); $this->get('old_sound_rabbit_mq.message_producer')->publish(serialize($message)); return $this->render('welcome.html.twig', ['userId' => $userId]); } } config.yml old_sound_rabbit_mq: connections: default: host: '192.168.99.10' # hostname and port of the rabbitmq […]

使用symfony rabbitMq与nodeJs进行通信

Node Js：我创build了一个使用nodejs和socket的消费者，以便与rabbitMq和symfony进行通信 文件：consumer.js var http = require('http'), url = require('url'), amqp = require('amqplib/callback_api'); amqp.connect('amqp://user:pass@192.168.99.10:55672', function(err, conn) { conn.createChannel(function(err, ch) { var q = 'hello'; ch.assertQueue(q, {durable: false}); console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q); ch.consume(q, function(msg) { console.log(" [x] Received %s", msg.content.toString()); }, {noAck: true}); }); }); 文件：App.js var server […]