阿里云AMQP NodeJS SDK使用Demo-阿里云开发者社区

阿里云AMQP NodeJS SDK使用Demo

2020-12-22 904

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 消息队列RabbitMQ版是阿里云消息队列（MQ）团队基于AMQP 0-9-1（AMQP 0.91）标准协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维，帮助您快速上云。阿里云提供全托管服务，更专业、更可靠、更安全。本文主要演示如何使用开源NodeJS SDK连接阿里云AMQP 消息服务，实现消息收发。

Step By Step

1、AMQP控制台创建实例
图片.png

2、创建用户名和密码
图片.png

3、Node JS SDK 安装

npm install amqplib

4、连接URL配置说明

amqp://{用户名}:{密码}@{endpoint}/{vhost}

4、发送端代码

#!/usr/bin/env node

var amqp = require('amqplib/callback_api');

amqp.connect('amqp://Mj******:Nk******@am******.mq-amqp.cn-beijing-******.aliyuncs.com/demo_vhost', function(error0, connection) {
    if (error0) {
        throw error0;
    }
    connection.createChannel(function(error1, channel) {
        if (error1) {
            throw error1;
        }

        var queue = 'hello';
        var msg = 'Hello World!';

        channel.assertQueue(queue, {
            durable: false
        });
        channel.sendToQueue(queue, Buffer.from(msg));

        console.log(" [x] Sent %s", msg);
    });
    setTimeout(function() {
        connection.close();
        process.exit(0);
    }, 500);
});

5、消费端代码

#!/usr/bin/env node

var amqp = require('amqplib/callback_api');

amqp.connect('amqp://Mj******:Nk******@am******.mq-amqp.cn-beijing-******.aliyuncs.com/demo_vhost', function(error0, connection) {
    if (error0) {
        throw error0;
    }
    connection.createChannel(function(error1, channel) {
        if (error1) {
            throw error1;
        }

        var queue = 'hello';

        channel.assertQueue(queue, {
            durable: false
        });

        console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", queue);

        channel.consume(queue, function(msg) {
            console.log(" [x] Received %s", msg.content.toString());
        }, {
            noAck: true
        });
    });
});

6、测试效果
图片.png