【发布时间】：2021-09-21 14:46:11
【问题描述】：
下面是我们尝试构建的 AMQP 客户端的摘要，以使用 IBM MQ 评估请求/响应消息模式。
当前 IBM 队列管理器版本 = 9.1.0.6
具有以下属性的 AMQP 通道设置，可在 >:5672 获得。通道属性如下。
Attributes for COMET.AMQP_SECCLNT
name COMET.AMQP_SECCLNT
type AMQP
alteration_date 2021-09-06
alteration_time 08.48.37
no_external_participants
description COMET Secure SSL Client for AMQP
disc_interval
hb_interval
keep_alive_interval
max_instances 999999999
max_instances_per_client
max_message_length 4194304
mca_user
sharing_conversations
ssl_client_auth REQUIRED
ssl_cipher_spec ECDHE_RSA_AES_256_CBC_SHA384
ssl_peer_name
cert-label
status INACTIVE
canStart false
canStop false
为了通过通道访问现有队列，设置了订阅 - /comet/interim/claim。订阅被映射到队列端点——COMET.INTERIM_CLAIMQ。 以下客户端配置为
- 使用 jms 相关 ID 从同一队列端点发送消息并提取消息。
- 将 JMS 消息类型设置为 MQSTR 而不是 MQHRF2
- 将对端点的回复设置为 /comet/interim/claim – 创建订阅以访问 COMET.INTERIM_CLAIMQ。
客户端代码如下
package com.ibm.mq.samples.jms.qpid;
import javax.jms.JMSContext;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.TextMessage;
import org.apache.qpid.jms.JmsConnectionFactory;
public class TestMessageSender {
public static void main(String[] args) {
System.setProperty("javax.net.ssl.keyStore", "cometdesktopmq.jks");
System.setProperty("javax.net.ssl.trustStore", "cometdesktopmq.jks");
System.setProperty("javax.net.ssl.keyStorePassword", "<<password>>");
System.setProperty("com.ibm.mq.cfg.useIBMCipherMappings", "false");
try {
String requsetUri = "amqps://host_name:5672";
String userName = "tgusr";
String password = "<<password>>";
JmsConnectionFactory factory = new JmsConnectionFactory(userName, password, requsetUri);
QueueConnection conn = factory.createQueueConnection();
conn.start();
System.out.println("conn started");
QueueSession sess = conn.createQueueSession(false, 1);
System.out.println("queue session created");
JMSContext context = factory.createContext(userName, password);
System.out.println("context created");
Queue q = context.createQueue("/comet/interim/claim");
QueueSender qs = sess.createSender(q);
System.out.println("queue sender created");
TextMessage message = context.createTextMessage("Text content");
message.setJMSType("MQSTR");
String msgId = message.getJMSMessageID();
message.setJMSCorrelationID(msgId);
Queue rq = context.createQueue("/comet/interim/claim");
message.setJMSReplyTo(rq);
qs.send(message); // Send the message
System.out.println("message sent");
QueueReceiver reciever = sess.createReceiver(rq, "JMSCorrelationID ='" + msgId + "'");
Message reply = reciever.receive(10*1000); // Pickup the message using the id set in correlation id field, timeout = 10 secs
Inspector ins = new Inspector(reply);
ins.showMessageType();
ins.showProperties();
ins.showMessageHeaders();
ins.showMessageBody();
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
COMET.INTERIM_CLAIMQ 队列收到的消息如下
RFH [1]\[1] ¸
________________________________________
MQSTR
MQMD
StrucId: MD Version: 1
MsgType: 8 Expiry: -1
Encoding: 546 CodedCharSetId: 1208
Format: MQHRF2 Priority: 0
Report: 0 Feedback: 0
MsgId: 414d5120574d51543532352020202020e4c44561003c722a
CorrelId: 414d5120574d51543532352020202020b6273861033d162d
BackoutCount: 0
AccountingToken: 0531353938370000000000000000000000000000000000000000000000000006
ApplIdentityData: ApplOriginData:
ReplyToQ: ReplyToQMgr: WMQT525
Persistence: 1 UserIdentifier: mqm
PutApplType: 26 PutApplName: WMQT525
PutDate: 09/19/2021 22:14:20
GroupId: 000000000000000000000000000000000000000000000000
MsgSeqNumber: 1 Offset: 0
MsgFlags: 0 OriginalLength: -1
Message
RFH [1]\[1] ¸
________________________________________
MQSTR ¸
________________________________________
ü<mq_amqp><Lis>p910-006-200703</Lis><Ver>1.0</Ver><Hdr><Dur dt='boolean'>1</Dur><Pri dt='i2'>4</Pri><Ttl dt='i8'>0</Ttl><Fac xsi:nil='true'></Fac></Hdr><Prp><Mid>ID:ce297c87-f1f4-46af-8ecb-6f6eb4d97d70:1:1:1-1</Mid><To>/comet/interim/claim</To><Sub>MQSTR</Sub><Rto>/comet/interim/claim</Rto><Aet dt='i8'>0</Aet><Crt dt='i8'>1632107660940</Crt><Gsq dt='i8'>0</Gsq></Prp><Man><x-opt-jms-reply-to>0</x-opt-jms-reply-to><x-opt-jms-dest>0</x-opt-jms-dest><x-opt-jms-msg-type>5</x-opt-jms-msg-type></Man></mq_amqp> 4<jms><Rto>topic:///comet/interim/claim</Rto></jms> Text content
担忧——
- 格式仍显示 MQHRF2 而不是 MQSTR。
- ReplyToQ 属性显示为空白。 [首先关注的是高度优先]
- 邮件正文包含标签 To as - /comet/interim/claim ，这说明什么？
- 它还包含标签 topic:///comet/interim/claim。我们在代码中设置的relyTo目的地是一个Queue，为什么要翻译成topic:///？
【问题讨论】：