RabbitMQ学习之:(十二)在Node.js环境下使用RabbitMQ
2012-12-30 00:50
573 查看
学,以致用。找了半天Node.js下RabbitMQ的库,看上去都不太趁手,直到最后找到了amqp库,看上去倒还不错,照着例子,写了第一个RabbitMQ的客户端。
首先,使用 npm install amqp --save 来安装node-amqp库,虽然他推荐使用全局安装,但是不去管它!
以下是客户端代码:
这个就是一个echo客户端,有消息过来,就打印出来,然后默默等待下一条消息。假如消息是quit,则优雅的退出~
其中,通过代码创建了一个可持久化的Queue: MoneyQueue,这个Queue自动会绑定到默认的Exchange,这个Exchange是RMQ提供的,所以也是持久的,这样就没问题了。
因为这个只是一个Consumer,没法单独工作,要验证的话,可以通过RMQ的管理页面,发送消息。
首先,使用 npm install amqp --save 来安装node-amqp库,虽然他推荐使用全局安装,但是不去管它!
以下是客户端代码:
var ampq = require('amqp'); var util = require('util'); var connection = ampq.createConnection(); var bStop = false; connection.on('ready', function () { connection.queue('moneyQueue', { durable: true, autoDelete: false }, function (queue) { console.log('Queue ' + queue.name + ' is open!'); queue.subscribe(function (message, header, deliveryInfo) { if (message.data) { var messageText = message.data.toString() console.log(messageText); if (messageText === "quit") bStop = true; } }); }); }); (function keepItRunning() { if (!bStop) setTimeout(keepItRunning, 1000); else connection.end(); })();
这个就是一个echo客户端,有消息过来,就打印出来,然后默默等待下一条消息。假如消息是quit,则优雅的退出~
其中,通过代码创建了一个可持久化的Queue: MoneyQueue,这个Queue自动会绑定到默认的Exchange,这个Exchange是RMQ提供的,所以也是持久的,这样就没问题了。
因为这个只是一个Consumer,没法单独工作,要验证的话,可以通过RMQ的管理页面,发送消息。
相关文章推荐
- RabbitMQ学习之:(十二)在Node.js环境下使用RabbitMQ
- RabbitMQ学习之:(十二)在Node.js环境下使用RabbitMQ
- Windows使用Node.js自动生成Vue.js模版环境部署步骤-----记录
- node.js学习笔记之使用文件流
- 配置移动前端开发调试环境(nodejs+npm+weiner的安装和配置使用)
- nodeJS学习(6)--- Sublime Text3 配置Node.js 开发环境
- Vue学习之开发环境配置及使用Node,npm,vue等
- Windows环境下使用Node.js
- Cocos2d-js 学习(四): DrawNode简单使用
- Linux环境下node.js环境的搭建以及配置,使用node.js编写工具与简化less编译
- Node.js学习笔记1:windows环境搭建
- Node.js学习2-NPM介绍、使用
- 使用Nodejs+Protractor搭建测试环境
- node.js学习笔记(5)_极客学院_Redis的使用
- 使用React、Node.js、MongoDB、Socket.IO开发一个角色投票应用的学习过程(三)
- node.js学习笔记(4)_极客学院_MongoDB的使用
- node环境下,jsdoc使用方法简介
- Node.js 学习笔记--- (1)安装环境
- 建立一个node.js服务器(使用express搭建第一个Web环境)
- ES6 学习笔记 (2)-- Liunx环境安装Node.js 与 搭建 Node.js 开发环境