RabbitMq部署流程

1:下载安装RabbitMq
https://www.rabbitmq.com/install-windows.html (或linux版本)、

2:启动RabbitMq
{RabbitMq location}/sbin/RabbitMq-server.bat

3:生产者程序

const amqp = require("amqplib/callback_api");
amqp.connect("amqp://localhost", function(err, conn){
    conn.createChannel((err, ch)=>{
        var q = "hello";
        ch.assertQueue(q, {
            durable : false
        })
        ch.sendToQueue(q, new Buffer("Hello world"));
        console.log("sended");
    })
})

4:消费者

const amqp = require("amqplib/callback_api");
amqp.connect("amqp://localhost", function(err, conn){
    conn.createChannel((err, ch)=>{
        var q = "hello";
        ch.assertQueue(q, {
            durable : false
        })

        console.log("waitting");

        ch.consume(q, (msg)=>{
            console.log(msg.content.toString());
        }, {
            noAck : true
        })
    })
})
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容