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