java ibm mq 教程



本文将会带你了解如何使用 Java JMS（Java Message Service）从 IBM MQ 队列读写消息。

我们可以在 Docker 容器中运行 IBM MQ，以避免手动安装和配置的复杂性。

使用以下命令以基本配置运行容器：

接下来，需要在 pom.xml 文件中添加 IBM MQ 客户端：

首先，我们需要用 建立 JMS （连接），用于创建与队列管理器（Queue Manager）的连接：

首先创建一个 实例，用于配置和创建与 IBM MQ 服务器的连接。我们将主机名设置为 ，因为 MQ 服务器是在本地 Docker 容器内运行的。暴露的映射端口为 1414。

然后，使用默认的 SYSTEM.DEF.SVRCONN channel。这是客户端连接 IBM MQ 的常用 channel。

本节将带你了解向 IBM MQ 队列发送消息的过程。

首先，创建 类。该类负责设置与 IBM MQ 服务器的连接、管理会话和处理消息发送操作。我们声明 、、 和 实例的变量，这些变量将用于与 IBM MQ 服务器交互。

下面是 IBM MQ 连接设置、会话创建和消息发送的示例：

接下来，在 的构造函数中，我们使用 类初始化 。然后使用该工厂创建 。该连接允许我们与 IBM MQ 服务器交互。

连接建立后，我们使用 创建一个 。该会话允许我们与队列通信。这里，我们通过 参数表示会话是非事务性的，通过 表示在收到消息时自动确认。

然后，定义特定队列 ，并创建一个 来处理消息发送。最后，启动连接，以确保会话处于活动状态并准备好发送消息。

现在，我们已经建立了连接、创建了会话、定义了队列并创建了消息生产者，可以向队列发送文本消息了：

首先，创建一个接收 参数的 方法。 方法负责向队列发送文本消息。它会创建一个 对象，并使用 方法设置消息内容。

接下来，使用 对象的 方法将消息发送到定义的队列。由于只要 对象存在，连接和会话就会一直处于打开状态，因此这种设计可以实现高效的消息传输。

除了 之外，IBM MQ 还支持其他多种消息类型，以满足不同的使用情况。例如，我们可以发送以下消息：

• BytesMessage：以字节形式保存的原始二进制消息。
• ObjectMessage：序列化的 Java 对象消息。
• MapMessage：包含键值对的消息。
• StreamMessage：包含原始数据类型流的消息。

接下来看看如何从队列中读取消息。

首先，需要建立连接并创建会话，这与发送消息时的操作类似。

首先创建一个 类。该类处理与 IBM MQ 服务器的连接，并设置消息消费所需的组件：

在该类中，我们首先创建一个 来建立与 IBM MQ 服务器的连接。然后，使用此连接创建一个 ，它允许我们与队列交互。

最后，定义了特定队列 ，并创建了一个 来处理从队列传入的消息。

连接、会话和 receiver 设置完成后，就可以开始从队列中接收消息了。

使用 的 方法从指定队列中读取消息：

在 方法中，我们使用 函数等待队列中的消息，超时时间为 1000 毫秒。收到消息后，会检查它是否是 类型。

如果是，则可以使用 方法获取实际的消息内容，该方法会以字符串形式返回文本内容。

本节将介绍一些常用的 消息属性和 Header，我们可以在发送或接收消息时使用它们。

消息属性（Message properties）可用于存储和检索消息正文以外的其他信息。这对于过滤消息或向消息中添加上下文数据特别有用。

以下是在发送消息时设置自定义属性的示例：

接下来，可以在接收消息时检索属性：

消息 Header 供预定义字段，其中包括有关消息的元数据。一些常用的 消息 Header 包括：

• JMSMessageID：由 JMS Provider 分配给每条消息的唯一标识符。可以使用此 ID 跟踪和记录消息。
• JMSExpiration：定义消息过期时间（毫秒）。如果消息在此时间内未送达，则会被丢弃。
• JMSTimestamp：消息发送时间。
• JMSPriority：消息的优先级。

在接收消息时检索消息 Header：

在本节中，我们使用 来模拟依赖，并验证 和 类的交互。

首先，使用 注解创建依赖的 Mock 实例。

接下来，验证 方法是否正确与 Mock（模拟）的 交互。我们模拟了 的 方法，并验证 是否被正确创建：

最后，验证 方法能否与 Mock（模拟）的 正确交互。我们模拟 方法来返回预定义的 ，结果如我们所料，消息文本被检索到了：

本文介绍了如何使用 Java JMS 读写 IBM MQ 队列，详细介绍了如何设置 JMS 连接、会话以及消息生产者/接收者，还介绍了 IBM MQ 支持的几种消息类型以及如何使用自定义消息属性和消息 Header。

Ref：

版权声明：

本文来源网络，所有图片文章版权属于原作者，如有侵权，联系删除。

本文网址：https://www.bianchenghao6.com/java-jiao-cheng/12200.html