第 4 章 示例
本章介绍如何通过示例程序使用 AMQ JavaScript。
有关更多示例，请参阅 AMQ JavaScript 示例套件 和 Rhea 示例。
4.1. 发送消息
这个客户端程序使用 <connection-url> 连接到服务器，为目标 <address> 创建一个发送程序，发送一条包含 <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
