使用 Rhea

Red Hat build of Rhea 3.0.4

使用 JavaScript 开发 AMQ 消息传递客户端

摘要

本指南论述了如何在其他 AMQ 组件中安装和使用您的客户端。

使开源包含更多
复制链接

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。我们从这四个术语开始：master、slave、黑名单和白名单。由于此项工作十分艰巨，这些更改将在即将推出的几个发行版本中逐步实施。有关更多详情，请参阅我们的首席技术官 Chris Wright 提供的消息。

第 1 章概述
复制链接

RHEA 是一个用于开发消息传递应用的库。它允许您编写发送和接收 AMQP 消息的 JavaScript 应用程序。

红帽构建的 Rhea 是 AMQ 客户端的一部分，这是支持多个语言和平台的消息传递库套件。有关可用客户端的详情，请参考 AMQ 客户端。

红帽构建的 Rhea 基于 Rhea 消息传递库。有关详细的 API 文档，请参阅 Rhea API 参考。

1.1. 主要特性
复制链接

一个事件驱动的 API，它简化了与现有应用程序的集成
用于安全通信的 SSL/TLS
灵活的 SASL 身份验证
自动重新连接和故障转移
AMQP 和语言原生数据类型之间的无缝转换
访问 AMQP 1.0 的所有特性和功能

1.2. 支持的标准和协议
复制链接

红帽构建的 Rhea 支持以下行业认可的标准和网络协议：

高级消息队列协议 (AMQP)的版本 1.0
传输层安全 (TLS)协议版本 1.0、1.1、1.2 和 1.3，这是 SSL 的后续者
简单身份验证和安全层 (SASL)机制 ANONYMOUS、PLAIN 和 EXTERNAL
使用 IPv6现代 TCP

1.3. 支持的配置
复制链接

有关红帽构建的 Rhea 支持的配置，请参阅红帽客户门户网站上的 Red Hat AMQ 支持的配置。

1.4. 术语和概念
复制链接

本节介绍核心 API 实体，并描述了它们如何一起运行。

Expand

表 1.1. API 术语
实体	描述
Container	连接的顶级容器。
连接	用于网络上两个对等点之间通信的频道。它包含会话。
会话	用于发送和接收消息的上下文。它包含发送者和接收器。
sender	将信息发送到目标的频道。它有一个目标。
接收器	从源接收消息的频道。它有一个源。
Source	名为 origin 用于消息的来源点。
目标	消息的命名目的地。
消息	特定于应用程序的信息。
delivery	消息传输。

红帽构建的 Rhea 可 发送和接收信息。消息通过 发送方 和 接收器 在连接的对等点之间传输。发送者和接收器 在会话上建立。会话建立在连接时。连接在两个唯一标识 的容器 之间建立。虽然连接可以有多个会话，但通常不需要这样做。API 允许您忽略会话，除非您需要它们。

发送对等点创建发送消息的发送者。发送者具有在远程对等点上标识队列或主题 的目标。接收对等点会创建一个接收消息的接收器。接收器有一个源，用于标识远程对等点的队列或主题。

消息的发送称为交付。消息是发送的内容，包括标头和注解等所有元数据。交付是与该内容传输关联的协议交换。

要表示发送已完成，发送者或接收器集都包括它。当另一端学习已集后，它将不再传达该交付。接收器也可以指定它是否接受或拒绝消息。

1.5. 文档惯例
复制链接

sudo 命令

在本文档中，sudo 用于任何需要 root 特权的命令。使用 sudo 时请小心谨慎，因为任何更改都可能会影响整个系统。有关 sudo 的详情，请参考使用 sudo 命令。

文件路径

在本文档中，所有文件路径都对 Linux、UNIX 和类似操作系统有效（例如 /home/andrea）。在 Microsoft Windows 上，您必须使用等效的 Windows 路径（例如 C:\Users\andrea）。

变量文本

本文档包含代码块，其变量必须替换为特定于您的环境的值。变量文本用箭头括起，样式化为字典 monospace。例如，使用以下命令将 < project-dir&gt; 替换为您的环境的值：

$ cd <project-dir>

第 3 章开始使用
复制链接

本章指导您执行设置环境并运行一个简单的消息传递程序的步骤。

3.1. 先决条件
复制链接

您必须为您的环境完成安装过程。
您必须有一个 AMQP 1.0 消息代理，侦听接口 localhost 和端口 5672 上的连接。它必须启用匿名访问。如需更多信息，请参阅启动代理。
您必须有一个名为 example 的队列。如需更多信息，请参阅创建队列。

3.2. Running Hello World on Red Hat Enterprise Linux
复制链接

Hello World 示例创建一个与代理的连接，发送一条包含问候 示例 队列的消息，并将它接收。成功时，它会将收到的消息输出到控制台。

更改到 examples 目录，再运行 helloworld.js 示例。

$ cd <source-dir>/examples
$ node helloworld.js
Hello World!

3.3. 在 Microsoft Windows 上运行 Hello World
复制链接

Hello World 示例创建一个与代理的连接，发送一条包含问候 示例 队列的消息，并将它接收。成功时，它会将收到的消息输出到控制台。

更改到 examples 目录，再运行 helloworld.js 示例。

> cd <source-dir>/examples
> node helloworld.js
Hello World!

第 4 章例子
复制链接

本章演示了通过示例程序使用红帽构建的 Rhea。

有关更多示例，请参阅 Rhea 示例套件和 Rhea 示例。

4.1. 发送消息
复制链接

此客户端程序使用 < connection-url> 连接到服务器，为目标 <address > 创建一个发送者，发送一条包含 & lt;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

4.2. 接收消息
复制链接

此客户端程序使用 < connection-url& gt; 连接到服务器，为源 <address&gt ; 创建接收器，并接收信息，直到终止或达到 < count> 信息。

示例：接收信息

"use strict";

var rhea = require("rhea");
var url = require("url");

if (process.argv.length !== 4 && process.argv.length !== 5) {
    console.error("Usage: receive.js <connection-url> <address> [<message-count>]");
    process.exit(1);
}

var conn_url = url.parse(process.argv[2]);
var address = process.argv[3];
var desired = 0;
var received = 0;

if (process.argv.length === 5) {
    desired = parseInt(process.argv[4]);
}

var container = rhea.create_container();

container.on("receiver_open", function (event) {
    console.log("RECEIVE: Opened receiver for source address '" +
                event.receiver.source.address + "'");
});

container.on("message", function (event) {
    var message = event.message;

    console.log("RECEIVE: Received message '" + message.body + "'");

    received++;

    if (received == desired) {
        event.receiver.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_receiver(address);

运行示例

要运行示例程序，将其复制到本地文件中，并使用 python 命令调用该文件。如需更多信息，请参阅第 3 章 开始使用。

$ node receive.js amqp://localhost queue1

第 6 章网络连接
复制链接

6.1. 创建传出连接
复制链接

要连接到远程服务器，请将包含主机和端口的连接选项传递给 container.connect （） 方法。

示例：创建传出连接

container.on("connection_open", function (event) {
    console.log("Connection " + event.connection + " is open");
});

var opts = {
    host: "example.com",
    port: 5672
};

container.connect(opts);

默认主机为 localhost。默认端口为 5672。

有关创建安全连接的详情，第 7 章 安全性。

6.2. 配置重新连接
复制链接

通过重新连接，客户端可以从丢失的连接中恢复。它用于确保在临时网络或组件失败后重新建立通信。

红帽构建的 Rhea 可默认启用重新连接。如果连接尝试失败，客户端将在短暂的延迟后重试。每次新尝试时，延迟会指数增加，最多为 60 秒。

要禁用重新连接，请将 reconnect connection 选项设置为 false。

示例：禁用重新连接

var opts = {
    host: "example.com",
    reconnect: false
};

container.connect(opts);

要控制连接尝试之间的延迟，请设置 initial_reconnect_delay 和 max_reconnect_delay 连接选项。以毫秒为单位指定延迟选项。

要限制重新连接尝试的数量，请设置 reconnect_limit 选项。

示例：配置重新连接

var opts = {
    host: "example.com",
    initial_reconnect_delay: 100,
    max_reconnect_delay: 60 * 1000,
    reconnect_limit: 10
};

container.connect(opts);

6.4. 接受进入的连接
复制链接

红帽构建的 Rhea 可以接受入站网络连接，使您能够构建自定义消息传递服务器。

要开始侦听连接，请使用 container.listen （） 方法以及包含要侦听的本地主机地址和端口的选项。

示例：接受进入的连接

container.on("connection_open", function (event) {
    console.log("New incoming connection " + event.connection);
});

var opts = {
    host: "0.0.0.0",
    port: 5672
};

container.listen(opts);

特殊 IP 地址 0.0.0.0 侦听所有可用的 IPv4 接口。要侦听所有 IPv6 接口，请使用 [::0]。

如需更多信息，请参阅服务器 receive.js 示例。

第 7 章安全性
复制链接

7.1. 使用 SSL/TLS 保护连接
复制链接

红帽构建的 Rhea 使用 SSL/TLS 加密客户端和服务器之间的通信。

要使用 SSL/TLS 连接到远程服务器，请将 传输连接 选项设置为 tls。

示例：启用 SSL/TLS

var opts = {
    host: "example.com",
    port: 5671,
    transport: "tls"
};

container.connect(opts);

注意

默认情况下，客户端将拒绝与带有不受信任的证书的服务器的连接。有时在测试环境中会出现这种情况。要绕过证书授权，请将 rejectUnauthorized connection 选项设置为 false。请注意，这会破坏您的连接的安全性。

7.2. 使用用户和密码连接
复制链接

红帽构建的 Rhea 可以使用用户和密码验证连接。

要指定用于身份验证的凭证，请设置 用户名和密码 连接选项。

示例：使用用户和密码连接

var opts = {
    host: "example.com",
    username: "alice",
    password: "secret"
};

container.connect(opts);

7.3. 配置 SASL 身份验证
复制链接

红帽构建的 Rhea 使用 SASL 协议执行身份验证。SASL 可以使用多种不同的 身份验证机制。当两个网络对等点连接时，它们交换了允许的机制，并且同时选择两者的最强机制。

红帽构建的 Rhea 根据存在用户和密码信息启用 SASL 机制。如果同时指定了用户和密码，则使用 PLAIN。如果只指定用户，则使用 ANONYMOUS。如果没有指定，则禁用 SASL。

第 8 章 senders 和 receivers
复制链接

客户端使用发送者和接收器链接来代表发送消息的频道。发送者和接收器是单向的，以及消息来源的源端，以及消息目的地的目标端。

源和目标通常指向消息代理上的队列或主题。源也用来表示订阅。

8.2. 创建持久化订阅
复制链接

持久化订阅是远程服务器上的一个代表消息接收器的状态。通常，当客户端关闭时，消息接收器会丢弃。但是，由于持久订阅是持久的，客户端可以从它们分离，然后稍后重新连接。客户端重新附加时，在分离时收到的任何消息都可用。

持久化订阅可以通过组合客户端容器 ID 和接收器名称来形成订阅 ID 来唯一标识。它们必须具有 stable 值，以便可以恢复订阅。

将连接容器 ID 设置为 stable 值，如 client-1 ：

var container = rhea.create_container({id: "client-1"});

使用稳定名称（如 sub-1 ）创建一个接收器，并通过设置 durable 和 expiry_policy 属性为持久性配置接收器源：

var receiver_opts = {
    source: {
        address: "notifications",
        name: "sub-1",
        durable: 2,
        expiry_policy: "never"
    }
}

conn.open_receiver(receiver_opts);

要从订阅分离，请使用 receiver.detach （） 方法。要终止订阅，请使用 receiver.close （） 方法。

如需更多信息，请参阅 durable-subscribe.js 示例。

8.3. 创建共享订阅
复制链接

共享订阅是远程服务器中的一个状态，代表一个或多个消息接收器。由于它已被共享，所以多个客户端可以从相同的消息流中使用。

客户端通过在接收器源上设置 共享功能来配置共享 订阅。

共享订阅可以通过组合客户端容器 ID 和接收器名称来形成订阅 ID 来唯一标识。它们必须具有稳定的值，以便多个客户端进程可以找到相同的订阅。如果除了 共享 外还设置了 全局 功能，则只用接收器名称来标识订阅。

要创建持久化订阅，请按照以下步骤执行：

将连接容器 ID 设置为 stable 值，如 client-1 ：

var container = rhea.create_container({id: "client-1"});

使用稳定名称（如 sub-1 ）创建一个接收器，并通过设置共享功能来配置接收器源以进行 共享 ：

var receiver_opts = {
    source: {
        address: "notifications",
        name: "sub-1",
        capabilities: ["shared"]
    }
}

conn.open_receiver(receiver_opts);

要从订阅分离，请使用 receiver.detach （） 方法。要终止订阅，请使用 receiver.close （） 方法。

如需更多信息，请参阅 shared-subscribe.js 示例。

第 9 章错误处理
复制链接

红帽构建的 Rhea 中的错误可以通过截获与 AMQP 协议或连接错误对应的命名事件来处理。

9.1. 处理连接和协议错误
复制链接

您可以通过截获以下事件来处理协议级别的错误：

connection_error
session_error
sender_error
receiver_error
protocol_error
错误

每当事件中有带有特定对象的错误条件时，都会触发这些事件。调用错误处理程序后，也会调用对应的 & lt;object> _close 处理程序。

event 参数具有用于访问错误对象的 error 属性。

示例：处理错误

container.on("error", function (event) {
    console.log("An error!", event.error);
});

注意

由于在出现任何错误时调用关闭的处理程序，因此仅在错误处理程序中处理错误本身。资源清理可以通过关闭处理程序进行管理。如果没有特定于特定对象的错误处理，则通常处理常规 错误事件 且没有更具体的处理程序。

注意

启用重新连接后，远程服务器关闭与 amqp:connection:forced 条件的连接，客户端不会将其视为错误，因此不会触发 connection_error 事件。相反，客户端会开始重新连接进程。

第 10 章日志记录
复制链接

10.1. 配置日志记录
复制链接

红帽构建的 Rhea 使用 JavaScript debug 模块来实施日志记录。

例如，要启用详细的客户端日志记录，请将 DEBUG 环境变量设置为 rhea* ：

示例：启用详细的日志记录

$ export DEBUG=rhea*
$ <your-client-program>

10.2. 启用协议日志记录
复制链接

客户端可以将 AMQP 协议帧记录到控制台。在诊断问题时，这些数据通常至关重要。

要启用协议日志记录，将 DEBUG 环境变量设置为 rhea:frames ：

示例：启用协议日志记录

$ export DEBUG=rhea:frames
$ <your-client-program>

第 11 章基于文件的配置
复制链接

红帽构建的 Rhea 可读取用于从名为 connect.json 的本地文件建立连接的配置选项。这可让您在部署时在应用程序中配置连接。

当应用程序调用容器连接方法时，库会尝试读取该文件，而无需提供任何连接选项。

11.1. 文件位置
复制链接

如果设置，红帽构建的 Rhea 将使用 MESSAGING_CONNECT_FILE 环境变量的值来定位配置文件。

如果没有设置 MESSAGING_CONNECT_FILE，红帽构建的 Rhea 会在以下位置搜索名为 connect.json 的文件，并按所示的顺序搜索名为 connect.json 的文件。它会在遇到的第一个匹配项停止。

对于 Linux：

$PWD/connect.json，其中 $PWD 是客户端进程的当前工作目录
$HOME/.config/messaging/connect.json，其中 $HOME 是当前用户主目录
/etc/messaging/connect.json

在 Windows 上：

%CD%/connect.json，其中 %cd% 是客户端进程的当前工作目录

如果没有找到 connect.json 文件，程序库会为所有选项使用默认值。

11.2. 文件格式
复制链接

connect.json 文件包含 JSON 数据，以及对 JavaScript 注释的额外支持。

所有配置属性都是可选的，或者具有默认值，因此一个简单的示例只需要提供一些详情：

示例：一个简单的 connect.json 文件

{
    "host": "example.com",
    "user": "alice",
    "password": "secret"
}

SASL 和 SSL/TLS 选项嵌套在 "sasl" 和 "tls" 命名空间下：

示例：带有 SASL 和 SSL/TLS 选项的 connect.json 文件

{
    "host": "example.com",
    "user": "ortega",
    "password": "secret",
    "sasl": {
        "mechanisms": ["SCRAM-SHA-1", "SCRAM-SHA-256"]
    },
    "tls": {
        "cert": "/home/ortega/cert.pem",
        "key": "/home/ortega/key.pem"
    }
}

11.3. 配置选项
复制链接

包含点(.)的选项键代表嵌套在命名空间内的属性。

Expand

表 11.1. connect.json中的配置选项
键	值类型	默认值	描述
`方案`	string	`"amqps"`	用于明文或 `"amqp s"` 用于 SSL/TLS 的"AMQP"
`主机`	string	`"localhost"`	远程主机的主机名或 IP 地址
`port`	字符串或数字	`"amqps"`	端口号或端口文字
`user`	string	None	用于身份验证的用户名
`password`	string	None	用于身份验证的密码
`sasl.mechanisms`	列出或字符串	none （系统默认设置）	启用 SASL 机制的 JSON 列表。裸机字符串表示一种机制。如果没有指定，客户端将使用系统提供的默认机制。
`sasl.allow_insecure`	布尔值	`false`	启用发送明文密码的机制
`tls.cert`	string	None	客户端证书的文件名或数据库 ID
`tls.key`	string	None	客户端证书的私钥的文件名或数据库 ID
`tls.ca`	string	None	CA 证书的文件名、目录或数据库 ID
`tls.verify`	布尔值	`true`	需要具有匹配主机名的有效服务器证书

第 12 章互操作性
复制链接

本章讨论如何使用红帽构建的 Rhea 与其他 AMQ 组件结合使用。有关 AMQ 组件兼容性的概述，请参阅产品简介。

12.1. 与其他 AMQP 客户端交互
复制链接

AMQP 消息使用 AMQP 类型系统组成。这种通用格式是不同语言的 AMQP 客户端可以相互交互的原因之一。

在发送消息时，红帽构建的 Rhea 会自动将语言原生类型转换为 AMQP 编码的数据。收到消息时，会发生反向转换。

注意

有关 AMQP 类型的更多信息，请访问 Apache Qpid 项目维护的交互式类型参考。

Expand

表 12.1. AMQP 类型
AMQP 类型	描述
`null`	一个空值
`布尔值`	true 或 false 值
`char`	单个 Unicode 字符
`string`	Unicode 字符序列
`binary`	一系列字节
`byte`	签名的 8 位整数
`short`	签名的 16 位整数
`int`	签名的 32 位整数
`long`	签名的 64 位整数
`ubyte`	未签名的 8 位整数
`ushort`	未签名的 16 位整数
`uint`	未签名的 32 位整数
`ulong`	未签名的 64 位整数
`浮点值`	32 位浮点数
`double`	64 位浮点号
`数组`	单个类型的值序列
`list`	变量类型值序列
`map`	从不同键到值的映射
`uuid`	通用唯一标识符
`symbol`	来自受限域的 7 位 ASCII 字符串
`timestamp`	时间的绝对点

JavaScript 的原生类型比 AMQP 可以编码。要发送包含特定 AMQP 类型的消息，请使用 rhea/types.js 模块中的 wrap_ functions。

Expand

表 12.2. RHEA 类型在编码前和解码后
AMQP 类型	RHEA 类型在编码前	RHEA 解码后的类型
`null`	`null`	`null`
`布尔值`	`布尔值`	`布尔值`
`char`	`wrap_char(number)`	`number`
`string`	`string`	`string`
`二进制`	`wrap_binary(string)`	`string`
`byte`	`wrap_byte(number)`	`number`
`short`	`wrap_short(number)`	`number`
`int`	`wrap_int(number)`	`number`
`long`	`wrap_long(number)`	`number`
`ubyte`	`wrap_ubyte(number)`	`number`
`ushort`	`wrap_ushort(number)`	`number`
`uint`	`wrap_uint(number)`	`number`
`ulong`	`wrap_ulong(number)`	`number`
`浮点值`	`wrap_float(number)`	`number`
`double`	`wrap_double(number)`	`number`
`数组`	`wrap_array (Array, code)`	`Array`
`list`	`wrap_list(Array)`	`Array`
`map`	`wrap_map(object)`	`object`
`uuid`	`wrap_uuid(number)`	`number`
`symbol`	`wrap_symbol(string)`	`string`
`timestamp`	`wrap_timestamp(number)`	`number`

Expand

表 12.3. RHEA 和其他 AMQ 客户端类型(2 的 1 个)
RHEA 类型在编码前	AMQ C++ 类型	红帽构建的 Apache Qpid Proton DotNet 类型
`null`	`nullptr`	`null`
`布尔值`	`bool`	`system.Boolean`
`wrap_char(number)`	`wchar_t`	`system.Char`
`string`	`std::string`	`system.String`
`wrap_binary(string)`	`proton::binary`	`System.Byte[]`
`wrap_byte(number)`	`int8_t`	`system.SByte`
`wrap_short(number)`	`int16_t`	`system.Int16`
`wrap_int(number)`	`int32_t`	`system.Int32`
`wrap_long(number)`	`int64_t`	`System.Int64`
`wrap_ubyte(number)`	`uint8_t`	`system.Byte`
`wrap_ushort(number)`	`uint16_t`	`system.UInt16`
`wrap_uint(number)`	`uint32_t`	`system.UInt32`
`wrap_ulong(number)`	`uint64_t`	`system.UInt64`
`wrap_float(number)`	`浮点值`	`system.Single`
`wrap_double(number)`	`double`	`system.Double`
`wrap_array (Array, code)`	-	-
`wrap_list(Array)`	`std::vector`	`amqp.List`
`wrap_map(object)`	`std::map`	`amqp.Map`
`wrap_uuid(number)`	`proton::uuid`	`system.Guid`
`wrap_symbol(string)`	`proton::symbol`	`Amqp.Symbol`
`wrap_timestamp(number)`	`proton::timestamp`	`system.DateTime`

Expand

表 12.4. RHEA 和其他 AMQ 客户端类型(2 为 2)
RHEA 类型在编码前	红帽构建的 Apache Qpid Proton Python 类型
`null`	`None`
`布尔值`	`bool`
`string`	`Unicode`
`wrap_char(number)`	`Unicode`
`wrap_binary(string)`	`bytes`
`wrap_byte(number)`	`int`
`wrap_short(number)`	`int`
`wrap_int(number)`	`long`
`wrap_long(number)`	`long`
`wrap_ubyte(number)`	`long`
`wrap_ushort(number)`	`long`
`wrap_uint(number)`	`long`
`wrap_ulong(number)`	`long`
`wrap_float(number)`	`浮点值`
`wrap_double(number)`	`浮点值`
`wrap_array (Array, code)`	`proton.Array`
`wrap_list(Array)`	`list`
`wrap_map(object)`	`dict`
`wrap_uuid(number)`	-
`wrap_symbol(string)`	`str`
`wrap_timestamp(number)`	`long`

12.2. 与红帽构建的 Apache Qpid JMS 进行互动
复制链接

AMQP 定义到 JMS 消息传递模型的标准映射。本节讨论该映射的各个方面。如需更多信息，请参阅红帽构建的 Apache Qpid JMS 互操作性章节。

JMS 消息类型

红帽构建的 Rhea 提供单一消息类型，其正文类型可能会有所不同。相反，JMS API 使用不同的消息类型来代表不同类型的数据。下表指明了特定的正文类型如何映射到 JMS 消息类型。

若要更加明确地控制生成的 JMS 消息类型，您可以设置 x-opt-jms-msg-type 消息注释。如需更多信息，请参阅红帽 Apache Qpid JMS 互操作性章节。

Expand

表 12.5. RHEA 和 JMS 消息类型
RHEA 正文类型	JMS 消息类型
`string`	`TextMessage`
`null`	`TextMessage`
`wrap_binary(string)`	`BytesMessage`
任何其他类型的	`ObjectMessage`

12.3. 连接到 AMQ Broker
复制链接

AMQ Broker 旨在与 AMQP 1.0 客户端交互。检查以下内容以确保为 AMQP 消息传递配置了代理：

打开网络防火墙中的端口 5672。
AMQ Broker AMQP 接受器已启用。请参阅默认接收器设置。
在代理上配置所需的地址。请参阅地址、队列和主题。
代理配置为允许来自您的客户端访问，客户端被配置为发送所需凭证。请参阅 Broker Security。

附录 A. 使用您的订阅
复制链接

AMQ 通过软件订阅提供。要管理您的订阅，请访问红帽客户门户中的帐户。

A.1. 访问您的帐户
复制链接

流程

转至 access.redhat.com。
如果您还没有帐户，请创建一个帐户。
登录到您的帐户。

A.2. 激活订阅
复制链接

流程

转至 access.redhat.com。
导航到 My Subscriptions。
导航到 激活订阅 并输入您的 16 位激活号。

A.3. 下载发行文件
复制链接

要访问 .zip、.tar.gz 和其他发布文件，请使用客户门户查找要下载的相关文件。如果您使用 RPM 软件包或 Red Hat Maven 存储库，则不需要这一步。

流程

打开浏览器并登录红帽客户门户网站 产品下载页面，网址为 access.redhat.com/downloads。
查找 INTEGRATION 目录中的红帽 AMQ 条目。
选择所需的 AMQ 产品。此时会打开 Software Downloads 页面。
单击组件的 Download 链接。

A.4. 为系统注册软件包
复制链接

要在 Red Hat Enterprise Linux 上安装此产品的 RPM 软件包，必须注册您的系统。如果您使用下载的发行文件，则不需要这一步。

流程

转至 access.redhat.com。
进入 Registration Assistant。
选择您的操作系统版本，再继续到下一页。
使用您的系统终端中列出的命令完成注册。

有关注册您的系统的更多信息，请参阅以下资源之一：

法律通告
复制链接

The text of and illustrations in this document are licensed by Red Hat under a Creative Commons Attribution–Share Alike 3.0 Unported license ("CC-BY-SA"). An explanation of CC-BY-SA is available at http://creativecommons.org/licenses/by-sa/3.0/. In accordance with CC-BY-SA, if you distribute this document or an adaptation of it, you must provide the URL for the original version.

Red Hat, as the licensor of this document, waives the right to enforce, and agrees not to assert, Section 4d of CC-BY-SA to the fullest extent permitted by applicable law.

Red Hat, Red Hat Enterprise Linux, the Shadowman logo, the Red Hat logo, JBoss, OpenShift, Fedora, the Infinity logo, and RHCE are trademarks of Red Hat, Inc., registered in the United States and other countries.

Linux® is the registered trademark of Linus Torvalds in the United States and other countries.

Java® is a registered trademark of Oracle and/or its affiliates.

XFS® is a trademark of Silicon Graphics International Corp. or its subsidiaries in the United States and/or other countries.

MySQL® is a registered trademark of MySQL AB in the United States, the European Union and other countries.

Node.js® is an official trademark of Joyent. Red Hat is not formally related to or endorsed by the official Joyent Node.js open source or commercial project.

The OpenStack® Word Mark and OpenStack logo are either registered trademarks/service marks or trademarks/service marks of the OpenStack Foundation, in the United States and other countries and are used with the OpenStack Foundation's permission. We are not affiliated with, endorsed or sponsored by the OpenStack Foundation, or the OpenStack community.

All other trademarks are the property of their respective owners.

使用 Rhea

使用 JavaScript 开发 AMQ 消息传递客户端

使开源包含更多复制链接链接已复制到粘贴板!

第 1 章 概述复制链接链接已复制到粘贴板!

1.1. 主要特性复制链接链接已复制到粘贴板!

1.2. 支持的标准和协议复制链接链接已复制到粘贴板!

1.3. 支持的配置复制链接链接已复制到粘贴板!

1.4. 术语和概念复制链接链接已复制到粘贴板!

1.5. 文档惯例复制链接链接已复制到粘贴板!

sudo 命令

文件路径

变量文本

第 2 章 安装复制链接链接已复制到粘贴板!

2.1. 先决条件复制链接链接已复制到粘贴板!

2.2. 使用 Red Hat NPM registry复制链接链接已复制到粘贴板!

2.3. 在浏览器中部署客户端复制链接链接已复制到粘贴板!

2.4. 安装示例复制链接链接已复制到粘贴板!

第 3 章 开始使用复制链接链接已复制到粘贴板!

3.1. 先决条件复制链接链接已复制到粘贴板!

3.2. Running Hello World on Red Hat Enterprise Linux复制链接链接已复制到粘贴板!

3.3. 在 Microsoft Windows 上运行 Hello World复制链接链接已复制到粘贴板!

第 4 章 例子复制链接链接已复制到粘贴板!

4.1. 发送消息复制链接链接已复制到粘贴板!

运行示例

4.2. 接收消息复制链接链接已复制到粘贴板!

运行示例

第 5 章 使用 API复制链接链接已复制到粘贴板!

5.1. 处理消息传递事件复制链接链接已复制到粘贴板!

5.2. 访问与事件相关的对象复制链接链接已复制到粘贴板!

5.3. 创建容器复制链接链接已复制到粘贴板!

5.4. 设置容器身份复制链接链接已复制到粘贴板!

第 6 章 网络连接复制链接链接已复制到粘贴板!

6.1. 创建传出连接复制链接链接已复制到粘贴板!

6.2. 配置重新连接复制链接链接已复制到粘贴板!

6.3. 配置故障转移复制链接链接已复制到粘贴板!

6.4. 接受进入的连接复制链接链接已复制到粘贴板!

第 7 章 安全性复制链接链接已复制到粘贴板!

7.1. 使用 SSL/TLS 保护连接复制链接链接已复制到粘贴板!

7.2. 使用用户和密码连接复制链接链接已复制到粘贴板!

7.3. 配置 SASL 身份验证复制链接链接已复制到粘贴板!

第 8 章 senders 和 receivers复制链接链接已复制到粘贴板!

8.1. 根据需要创建队列和主题复制链接链接已复制到粘贴板!

8.2. 创建持久化订阅复制链接链接已复制到粘贴板!

8.3. 创建共享订阅复制链接链接已复制到粘贴板!

第 9 章 错误处理复制链接链接已复制到粘贴板!

9.1. 处理连接和协议错误复制链接链接已复制到粘贴板!

第 10 章 日志记录复制链接链接已复制到粘贴板!

10.1. 配置日志记录复制链接链接已复制到粘贴板!

10.2. 启用协议日志记录复制链接链接已复制到粘贴板!

第 11 章 基于文件的配置复制链接链接已复制到粘贴板!

11.1. 文件位置复制链接链接已复制到粘贴板!

11.2. 文件格式复制链接链接已复制到粘贴板!

11.3. 配置选项复制链接链接已复制到粘贴板!

第 12 章 互操作性复制链接链接已复制到粘贴板!

12.1. 与其他 AMQP 客户端交互复制链接链接已复制到粘贴板!

12.2. 与红帽构建的 Apache Qpid JMS 进行互动复制链接链接已复制到粘贴板!

JMS 消息类型

12.3. 连接到 AMQ Broker复制链接链接已复制到粘贴板!

附录 A. 使用您的订阅复制链接链接已复制到粘贴板!

A.1. 访问您的帐户复制链接链接已复制到粘贴板!

A.2. 激活订阅复制链接链接已复制到粘贴板!

A.3. 下载发行文件复制链接链接已复制到粘贴板!

A.4. 为系统注册软件包复制链接链接已复制到粘贴板!

附录 B. 在示例中使用 AMQ Broker复制链接链接已复制到粘贴板!

B.1. 安装代理复制链接链接已复制到粘贴板!

B.2. 启动代理复制链接链接已复制到粘贴板!

B.3. 创建队列复制链接链接已复制到粘贴板!

B.4. 停止代理复制链接链接已复制到粘贴板!

法律通告复制链接链接已复制到粘贴板!

学习

尝试、购买和销售

社区

關於紅帽

让开源更具包容性

关于红帽文档

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

使开源包含更多
复制链接

第 1 章概述
复制链接

1.1. 主要特性
复制链接

1.2. 支持的标准和协议
复制链接

1.3. 支持的配置
复制链接

1.4. 术语和概念
复制链接

1.5. 文档惯例
复制链接

第 2 章安装
复制链接

2.1. 先决条件
复制链接

2.2. 使用 Red Hat NPM registry
复制链接

2.3. 在浏览器中部署客户端
复制链接

2.4. 安装示例
复制链接

第 3 章开始使用
复制链接

3.1. 先决条件
复制链接

3.2. Running Hello World on Red Hat Enterprise Linux
复制链接

3.3. 在 Microsoft Windows 上运行 Hello World
复制链接

第 4 章例子
复制链接

4.1. 发送消息
复制链接

4.2. 接收消息
复制链接

第 5 章使用 API
复制链接

5.1. 处理消息传递事件
复制链接

5.2. 访问与事件相关的对象
复制链接

5.3. 创建容器
复制链接

5.4. 设置容器身份
复制链接

第 6 章网络连接
复制链接

6.1. 创建传出连接
复制链接

6.2. 配置重新连接
复制链接

6.3. 配置故障转移
复制链接

6.4. 接受进入的连接
复制链接

第 7 章安全性
复制链接

7.1. 使用 SSL/TLS 保护连接
复制链接

7.2. 使用用户和密码连接
复制链接

7.3. 配置 SASL 身份验证
复制链接

第 8 章 senders 和 receivers
复制链接

8.1. 根据需要创建队列和主题
复制链接

8.2. 创建持久化订阅
复制链接

8.3. 创建共享订阅
复制链接

第 9 章错误处理
复制链接

9.1. 处理连接和协议错误
复制链接

第 10 章日志记录
复制链接

10.1. 配置日志记录
复制链接

10.2. 启用协议日志记录
复制链接

第 11 章基于文件的配置
复制链接

11.1. 文件位置
复制链接

11.2. 文件格式
复制链接

11.3. 配置选项
复制链接

第 12 章互操作性
复制链接

12.1. 与其他 AMQP 客户端交互
复制链接

12.2. 与红帽构建的 Apache Qpid JMS 进行互动
复制链接

12.3. 连接到 AMQ Broker
复制链接

附录 A. 使用您的订阅
复制链接

A.1. 访问您的帐户
复制链接

A.2. 激活订阅
复制链接

A.3. 下载发行文件
复制链接

A.4. 为系统注册软件包
复制链接

附录 B. 在示例中使用 AMQ Broker
复制链接

B.1. 安装代理
复制链接

B.2. 启动代理
复制链接

B.3. 创建队列
复制链接

B.4. 停止代理
复制链接

法律通告
复制链接