第 4 章 例子
本章演示了通过示例程序使用红帽构建的 Rhea。
有关更多示例，请参阅 Rhea 示例套件和 Rhea 示例。
4.1. 发送消息
此客户端程序使用 < connection-url > 连接到服务器，为目标 <address& gt; 创建发件人，发送一条消息，包含 <message-body >、关闭连接并退出。
示例：发送消息
"use strict";
var rhea = require("rhea");
var url = require("url");
if (process.argv.length !== 5) {
console.error("Usage: send.js <connection-url> <address> <message-body>");
process.exit(1);
}
var conn_url = url.parse(process.argv[2]);
var address = process.argv[3];
var message_body = process.argv[4];
var container = rhea.create_container();
container.on("sender_open", function (event) {
console.log("SEND: Opened sender for target address '" +
event.sender.target.address + "'");
});
container.on("sendable", function (event) {
var message = {
body: message_body
};
event.sender.send(message);
console.log("SEND: Sent message '" + message.body + "'");
event.sender.close();
event.connection.close();
});
var opts = {
host: conn_url.hostname,
port: conn_url.port || 5672,
// To connect with a user and password:
// username: "<username>",
// password: "<password>",
};
var conn = container.connect(opts);
conn.open_sender(address);
运行示例
要运行示例程序，请将其复制到本地文件，并使用 node 命令调用它。如需更多信息，请参阅 第 3 章 开始使用。
$ node send.js amqp://localhost queue1 hello
