我可以从我的 NodeJS 应用程序动态创建 RabbitMQ 铲子吗？答案

【问题标题】：Can I dynamically create RabbitMQ shovel from my NodeJS app?我可以从我的 NodeJS 应用程序动态创建 RabbitMQ 铲子吗？
【发布时间】：2019-03-01 02:01:49
【问题描述】：

RabbitMQ 铲子插件提供了一个 HTTP API 来创建和配置铲子。假设我为我的 RabbitMQ 服务器实例启用了铲子和铲子管理插件，我可以从我的 NodeJS 应用程序动态创建铲子吗？

我目前使用 amqplib 连接到交易所。 https://www.squaremobius.net/amqp.node/channel_api.html

但是我没有看到任何用于动态创建铲子的 API。这是可以实现的还是有任何其他库支持这个？

【问题讨论】：

github.com/rabbitmq/rabbitmq-shovel-management

标签： node.js rabbitmq node-amqp rabbitmq-shovel node-amqplib

【解决方案1】：

amqplib 没有提供任何特定的方法来创建动态铲子，但您可以使用文档中指定的基于 HTTP 的管理 API 来做到这一点：https://www.rabbitmq.com/shovel-dynamic.html#tutorial

因此，在纯 Node.js 中，这是 HTTP 请求（PUT 方法）以编程方式创建铲子的示例：

var http = require('http');

var rabbit_host = "myrabbitmq.com";
var token = Buffer.from("admin:admin_pwd").toString('base64');
var shovel_name = "my_shovel";

var payload = {
    "component": "shovel",
    "vhost": "/",
    "name": "my_shovel",
    "value": {
        "src-uri": "amqp://user1:pwd1@myrabbitmq.com",
        "src-exchange": "test",
        "dest-uri": "amqp://user2:pwd2@anotherbroker.com",
        "dest-exchange-key": "test2",
        "add-forward-headers": false,
        "ack-mode": "on-confirm",
        "delete-after": "never"
    }
};

var options = {
  "host": rabbit_host,
  "port": 15672,
  "path": "/api/parameters/shovel/%2F/" + shovel_name,
  "method": "PUT",
  "headers": { 
    "Authorization" : "Basic " + token,
    "Content-Type" : "application/json",
  }
}

var callback = function(response) {
    var str = ''
    response.on('data', function(chunk){
        str += chunk;
    });

    response.on('end', function(){
        console.log("end: response="+str);
    });
}

var body = JSON.stringify(payload);
http.request(options, callback).end(body).on('error', function(e) {
    console.log("error: " + e.message);
});

显然主机“myrabbitmq.com”必须可以从端口 15672 上的 Node.js 脚本访问。

上面的示例创建了一个从“myrabbitmq.com”到“anotherbroker.com”的铲子，指定了路由消息的交换。

【讨论】：

谢谢！如果 amqp 库没有提供用于创建动态铲子的 API，我假设我必须这样做。不确定是否有任何其他库为此提供 API。当我实现动态铲子时，这个例子肯定会对我有很大帮助。