AMQ OpenWire JMS 支持以下业界认可的标准和网络协议：

有关 AMQ OpenWire JMS 支持的配置，请参阅红帽客户门户网站中的 Red Hat AMQ 7 支持的配置。

本节介绍核心 API 实体，并描述它们如何协同运作。

AMQ OpenWire JMS 发送并接收 消息。消息使用消息生产者和消费者 在连接的对等点之间传输 。生产者和消费者通过 会话 建立。通过 连接 建立会话。连接由连接工厂 创建。

发送对等点会创建一个制作者来发送消息。制作者具有在远程同级上标识目标队列或主题 的目的地。接收方创建接收消息的消费者。与制作者一样，消费者也有在远程同级上标识源队列或主题的目的地。

目标是 队列 或 主题。在 JMS 中，队列和主题是包含消息的指定代理实体的客户端显示。

队列实施点对点语义。每条消息仅能被一个使用者看到，消息会在读取后从队列中删除。主题实施发布与订阅语义。每条消息都由多个使用者看到，该消息在读取后可供其他消费者使用。

如需更多信息，请参阅 JMS 指南。

sudo 命令

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

文件路径

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

变量文本

本文档包含代码块，它们需要使用特定于环境的值替换。变量文本括在箭头大括号内，样式为圆形单空间。例如，在以下命令中，将 <project-dir> 替换为您的环境的值：

$ cd <project-dir>

配置您的 Maven 环境，以从红帽 Maven 存储库下载客户端库。

该客户端现在在 Maven 项目中可用。

作为在线存储库的替代选择，可以将 AMQ OpenWire JMS 作为基于文件的 Maven 存储库安装到本地文件系统中。

这个示例为名为 exampleQueue 的队列创建使用者和制作者。它发送文本消息，然后接收回消息，将收到的消息打印到控制台。

在 Linux 上运行它会产生以下输出：

$ java -cp "target/classes:target/dependency/*" org.apache.activemq.artemis.jms.example.QueueExample
Sent message: This is a text message
Received message: This is a text message

这个示例的源代码位于 <install-dir>/examples/protocols/openwire/queue/src 目录中。<install-dir>/examples/protocols/openwire 目录中提供了其他示例。

JMS 应用使用从 InitialContextFactory 获取的 JNDI InitialContext 对象来查找 JMS 对象，如连接工厂。AMQ OpenWire JMS 在 org.apache.activemq.jndi.ActiveMQInitialContextFactory 类中提供 InitialContextFactory 实施。

当 InitialContext 对象被实例化时，InitialContextFactory 实现会被发现：

javax.naming.Context context = new javax.naming.InitialContext();

要查找实施，必须在您的环境中配置 JNDI。实现这一目标的方法有三种：使用 jndi.properties 文件、使用系统属性或使用初始上下文 API。

使用 jndi.properties 文件

创建名为 jndi.properties 的文件，并将其放置在 Java 类路径中。使用键 java.naming.factory.initial 添加属性。

java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory

在基于 Maven 的项目中，jndi.properties 文件放置在 <project-dir>/src/main/resources 目录中。

使用系统属性

设置 java.naming.factory.initial 系统属性。

$ java -Djava.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory ...

使用初始上下文 API

使用 JNDI 初始上下文 API 以编程方式设置属性。

Hashtable<Object, Object> env = new Hashtable<>();

env.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");

InitialContext context = new InitialContext(env);

请注意，您可以使用同一 API 为连接工厂、队列和主题设置 JNDI 属性。

JMS 连接工厂是创建连接的入口点。它使用对应用特定配置设置进行编码的连接 URI。

要设置工厂名称和连接 URI，请按照以下格式创建一个属性：您可以将该配置存储在 jndi.properties 文件中，或者设置对应的系统属性。

connectionFactory.<lookup-name> = <connection-uri>

例如，这是您可以如何配置一个名为 app1 的工厂：

connectionFactory.app1 = tcp://example.net:61616?jms.clientID=backend

然后，您可以使用 JNDI 上下文使用名称 app1 来查找配置的连接工厂：

ConnectionFactory factory = (ConnectionFactory) context.lookup("app1");

连接配置使用连接 URI。连接 URI 指定远程主机、端口和一组配置选项，这些选项设置为查询参数。有关可用选项的详情请参考 第 5 章 配置选项。

<scheme>://<host>:<port>[?<option>=<value>[&<option>=<value>...]]

这个方案是 tcp 用于未加密的连接，ssl 用于 SSL/TLS 连接。

例如，以下连接 URI 通过端口 61616 连接到主机 example.net，并将客户端 ID 设置为 backend ：

tcp://example.net:61616?jms.clientID=backend

故障切换 URI

用于重新连接和故障转移的 URI 可以包含多个连接 URI。它们采用以下形式：

failover:(<connection-uri>[,<connection-uri>])[?<option>=<value>[&<option>=<value>...]]

前缀为 nested. 的传输选项应用到列表中的每个连接 URI。

JMS 提供使用 JNDI 来查找特定于部署的队列和主题资源的选项。

要在 JNDI 中设置队列和主题名称，请使用以下格式创建属性：将此配置放在 jndi.properties 文件中，或者设置对应的系统属性。

queue.<lookup-name> = <queue-name>
topic.<lookup-name> = <topic-name>

例如，以下属性为两个特定于部署的资源定义名称 jobs 和 notifications ：

queue.jobs = app1/work-items
topic.notifications = app1/updates

然后，您可以根据 JNDI 名称查找资源：

Queue queue = (Queue) context.lookup("jobs");
Topic topic = (Topic) context.lookup("notifications");

预定义策略选项

prefetch 策略决定每个 MessageConsumer 从远程 peer 获取的信息数，并保存在本地"prefetch"缓冲区中。

prefetch 的值可能会影响消息到队列上的多个消费者的分发。更高的值可能会导致向每位消费者同时发送的批处理。当消费者以不同速度运作时，要达到更加均匀的循环分布，请使用较低的值。

重新传送策略选项

重新传送策略控制如何在客户端上处理重新传送消息。

要写入到大信息，使用 BytesMessage.writeBytes() 方法。以下示例从文件中读取字节并将其写入信息：

BytesMessage message = session.createBytesMessage();
File inputFile = new File(inputFilePath);
InputStream inputStream = new FileInputStream(inputFile);

int numRead;
byte[] buffer = new byte[1024];

while ((numRead = inputStream.read(buffer, 0, buffer.length)) != -1) {
    message.writeBytes(buffer, 0, numRead);
}

要从大消息中读取，请使用 BytesMessage.readBytes() 方法。以下示例从信息中读取字节并将其写入文件：

BytesMessage message = (BytesMessage) consumer.receive();
File outputFile = new File(outputFilePath);
OutputStream outputStream = new FileOutputStream(outputFile);

int numRead;
byte buffer[] = new byte[1024];

for (int pos = 0; pos < message.getBodyLength(); pos += buffer.length) {
    numRead = message.readBytes(buffer);
    outputStream.write(buffer, 0, numRead);
}