nodejs中操作rabbitmq生产和消费消息示例代码

代码语言:nodejs

所属分类:通讯

代码描述:nodejs中操作rabbitmq生产和消费消息示例代码

代码标签: nodejs 操作 rabbitmq 生产 消费 消息 示例 代码

下面为部分代码预览,完整代码请点击下载或在bfwstudio webide中打开

const topic = 'hello';
var amqp = require('amqplib/callback_api');
function publisher(conn) {
    conn.createChannel(on_open);
    function on_open(err, ch) {
        if (err != null) bail(err);
        ch.assertQueue(topic);
        ch.sendToQueue(topic, new  Buffer.from('something to do'));
    }
}
function consumer(conn) {
    var ok = conn.createChannel(on_open);
    function on_ope.........完整代码请登录后点击上方下载按钮下载查看

网友评论0