使用 Rhea

Red Hat build of Rhea 3.0

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

摘要

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

使开源包含更多
复制链接

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

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

第 2 章安装
复制链接

本章介绍了在您的环境中安装红帽构建 Rhea 的步骤。

2.1. 先决条件
复制链接

您必须具有访问 AMQ 发行文件和软件仓库的订阅。

您必须在您的环境中安装 npm 命令行工具。如需更多信息，请参阅 npm 网站。
要使用红帽构建的 Rhea，您必须在环境中安装 Node.js。如需更多信息，请参阅 Node.js 网站。
红帽构建的 Rhea 依赖于 Node.js 调试 模块。有关安装说明，请参阅 debug npm 页面。

2.4. 安装示例
复制链接

使用 git clone 命令将源存储库克隆到名为 rhea 的本地目录：

git clone https://github.com/amqp/rhea.git

$ git clone https://github.com/amqp/rhea.git

Copy to Clipboard

Toggle word wrap

进入 rhea 目录，并使用 git checkout 命令签出与此发行版本关联的提交：

cd rhea
git checkout 3.0.2

$ cd rhea
$ git checkout 3.0.2

Copy to Clipboard

Toggle word wrap

在本指南中，生成的本地目录被称为 &lt ;source-dir >。

第 5 章使用 API
复制链接

如需更多信息，请参阅 Rhea API 参考、Rhea 示例套件和 Rhea 示例。

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

红帽构建的 Rhea 是一个事件驱动的 API。要定义应用程序如何处理事件，用户会在容器对象上注册 event-handling 功能。然后，这些功能称为网络活动或计时器触发新事件。

示例：处理消息传递事件

var rhea = require("rhea");
var container = rhea.create_container();

container.on("sendable", function (event) {
    console.log("A message can be sent");
});

container.on("message", function (event) {
    console.log("A message is received");
});

var rhea = require("rhea");
var container = rhea.create_container();

container.on("sendable", function (event) {
    console.log("A message can be sent");
});

container.on("message", function (event) {
    console.log("A message is received");
});

Copy to Clipboard

Toggle word wrap

这些只是几个常见情况事件。完整集记录在 Rhea API 参考中。

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

每个容器实例具有唯一的身份，称为容器 ID。当红帽构建的 Rhea 进行网络连接时，它会将容器 ID 发送到远程对等点。要设置容器 ID，请将 id 选项传递给 create_container 方法。

示例：设置容器身份

var container = rhea.create_container({id: "job-processor-3"});

var container = rhea.create_container({id: "job-processor-3"});

Copy to Clipboard

Toggle word wrap

如果用户未设置 ID，则库将在构建容器时生成 UUID。

第 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);

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

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

container.connect(opts);

Copy to Clipboard

Toggle word wrap

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

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

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

红帽构建的 Rhea 允许您以编程方式配置备用连接端点程序。

要指定多个连接端点，请定义一个函数来返回新的连接选项，并在 connection_details 选项中传递函数。每次连接尝试调用该函数一次。

示例：配置故障切换

var hosts = [{hostname: "alpha.example.com", port: 5672}, {hostname:"beta.example.com", port: 5672}];
var index = -1;

function failover_fn() {
    index += 1;

    if (index == hosts.length) index = 0;

    return {host: hosts[index].hostname, port: hosts[index].port};
};

var opts = {
    host: "example.com",
    connection_details: failover_fn
}

container.connect(opts);

var hosts = [{hostname: "alpha.example.com", port: 5672}, {hostname:"beta.example.com", port: 5672}];
var index = -1;

function failover_fn() {
    index += 1;

    if (index == hosts.length) index = 0;

    return {host: hosts[index].hostname, port: hosts[index].port};
};

var opts = {
    host: "example.com",
    connection_details: failover_fn
}

container.connect(opts);

Copy to Clipboard

Toggle word wrap

这个示例为主机列表实施重复循环故障转移。您可以使用此接口来实现自己的故障切换行为。

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);

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);

Copy to Clipboard

Toggle word wrap

特殊的 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);

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

container.connect(opts);

Copy to Clipboard

Toggle word wrap

注意

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

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

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

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

第 8 章发件人和接收器
复制链接

客户端使用发送方和接收器链接来代表传递消息的频道。发件人和接收器是单向的，消息来源的源结尾和消息目的地的目标结尾。

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

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

有些消息服务器支持按需创建队列和主题。附加发送方或接收器时，服务器使用发送者目标地址或接收器源地址来创建名称与地址匹配的队列或主题。

邮件服务器通常默认为创建队列（用于一对一消息发送）或主题（用于一对多消息发送）。客户端可以通过在源或目标上设置 队列或主题 功能来指示首选情况。

要选择队列或主题语义，请按照以下步骤执行：

配置您的消息服务器，以自动创建队列和主题。这通常是默认配置。
在发送者目标或接收器源上设置 队列或主题 功能，如下例所示。

示例：发送到按需创建的队列

var conn = container.connect({host: "example.com"});

var sender_opts = {
    target: {
        address: "jobs",
        capabilities: ["queue"]
    }
}

conn.open_sender(sender_opts);

var conn = container.connect({host: "example.com"});

var sender_opts = {
    target: {
        address: "jobs",
        capabilities: ["queue"]
    }
}

conn.open_sender(sender_opts);

Copy to Clipboard

Toggle word wrap

示例：从按需创建的主题接收

var conn = container.connect({host: "example.com"});

var receiver_opts = {
    source: {
        address: "notifications",
        capabilities: ["topic"]
    }
}

conn.open_receiver(receiver_opts);

var conn = container.connect({host: "example.com"});

var receiver_opts = {
    source: {
        address: "notifications",
        capabilities: ["topic"]
    }
}

conn.open_receiver(receiver_opts);

Copy to Clipboard

Toggle word wrap

如需了解更多详细信息，请参阅以下示例：

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

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

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

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

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

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

Copy to Clipboard

Toggle word wrap

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

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

conn.open_receiver(receiver_opts);

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

conn.open_receiver(receiver_opts);

Copy to Clipboard

Toggle word wrap

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

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

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

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

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

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

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

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

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

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

Copy to Clipboard

Toggle word wrap

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

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

conn.open_receiver(receiver_opts);

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

conn.open_receiver(receiver_opts);

Copy to Clipboard

Toggle word wrap

要从订阅分离，请使用 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 对象的 error 属性。

示例：处理错误

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

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

Copy to Clipboard

Toggle word wrap

注意

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

注意

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

第 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.3. 配置选项
复制链接

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

Expand

表 11.1. connect.json中的配置选项
键	值类型	默认值	描述
`scheme`	string	`"amqps"`	`"AMQP"` 用于明文或 SSL/TLS `"amqps"`
`主机`	string	`"localhost"`	远程主机的主机名或 IP 地址
`port`	字符串或数字	`"amqps"`	端口号或端口字面
`user`	string	None	进行身份验证的用户名
`password`	string	None	进行身份验证的密码
`sasl.mechanisms`	list 或 string	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`	一个空值
`boolean`	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_ 功能。

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 个)
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 Interoperability 章节。

JMS 消息类型

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

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

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 acceptor。请参阅默认接受者设置。
在代理上配置必要的地址。请参阅地址、队列和主题。
代理配置为允许来自您的客户端的访问，客户端被配置为发送所需的凭证。请参阅 Broker 安全。

附录 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。
选择您的操作系统版本，再继续到下一页。
使用您的系统终端中列出的命令完成注册。

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

附录 B. 使用带有示例的 AMQ Broker
复制链接

红帽构建的 Rhea 示例需要一个正在运行的消息代理，其中包含名为 example 的队列。使用以下步骤安装和启动代理并定义队列。

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

按照 AMQ Broker 入门 中的说明来安装代理并创建代理实例。启用匿名访问。

以下流程将代理实例的位置称为 < broker-instance-dir>。

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

在新终端中，使用 artemis queue 命令创建名为 example 的队列。

<broker-instance-dir>/bin/artemis queue create --name examples --address examples --auto-create-address --anycast

$ <broker-instance-dir>/bin/artemis queue create --name examples --address examples --auto-create-address --anycast

Copy to Clipboard

Toggle word wrap

系统将提示您回答一系列 yes 或没有问题。全部答案为 N。

创建队列后，代理就可以与示例程序一起使用。

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

运行完示例后，请使用 artemis stop 命令来停止代理。

<broker-instance-dir>/bin/artemis stop

$ <broker-instance-dir>/bin/artemis stop

Copy to Clipboard

Toggle word wrap

更新于 2024-02-10

法律通告
复制链接

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. 使用红帽 NPM registry复制链接链接已复制到粘贴板!

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

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

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

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

3.2. 在 Red Hat Enterprise Linux 上运行 Hello World复制链接链接已复制到粘贴板!

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 章 发件人和接收器复制链接链接已复制到粘贴板!

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. 使用红帽 NPM registry
复制链接

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

2.4. 安装示例
复制链接

第 3 章开始使用
复制链接

3.1. 先决条件
复制链接

3.2. 在 Red Hat Enterprise Linux 上运行 Hello World
复制链接

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 章发件人和接收器
复制链接

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. 停止代理
复制链接

法律通告
复制链接