zoukankan      html  css  js  c++  java
  • RabbitMQ学习之:(十二)在Node.js环境下使用RabbitMQ

    学,以致用。找了半天Node.js下RabbitMQ的库,看上去都不太趁手,直到最后找到了amqp库,看上去倒还不错,照着例子,写了第一个RabbitMQ的客户端。


    首先,使用 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的管理页面,发送消息。



  • 相关阅读:
    UITableView
    xib的读取方式
    远程登录树莓派
    来体验下Linux吧
    树莓派了解Linux基本命令
    来感受Linux命令行的“真香定律”
    初尝树莓派
    从入手树莓派开始
    08-java学习笔记-集合框架中的工具类
    07-java学习笔记-map集合
  • 原文地址:https://www.cnblogs.com/puncha/p/3876952.html
Copyright © 2011-2022 走看看