java - 使用 JMS 连接到大型机

Question

我们目前正在使用 WebSphere MQ 从大型机获取数据，并且有时会在 MQ 端遇到问题。

我想知道是否有办法绕过 MQ 并使用 JMS 从大型机中获取数据。我们使用 WebSphere Application Server 6.0.2。

Answer 1

抱歉，JMS 只是一个驱动程序接口而不是队列管理器实现。

JMS 和队列管理器之间的区别与 JDBC 和数据库之间的区别相同。

律师事务所，安德里亚

Answer 2

当然，您可以在 java 端使用 JMS，这将最终包装对 MQ 的调用。您只需要注意邮件标题。用另一个消息传递基础架构替换 MQ 取决于大型机可以与之通信的内容，因为我想您对此没有太多控制权，对吧？经常选择 MQ 是因为它受到 IBM 大型机系统的支持。

格雷格

Answer 3

请找出逻辑，

1. 我们必须使用 ConnectionFactory、Connection 和 Session 建立到服务器的连接

2. 我们需要使用 Queue 创建 Queue 引用

3. 需要为我们计划使用 TextMessage 发送到队列的 Message 创建一个对象

4. 我们必须创建对象来与队列交互。在这里，MessageProducer 用于发送我们在步骤 3 中创建的消息，MessageConsumer 用于接收响应

请找到下面的代码来实现，

//Instantiate a Sun Java(tm) System Message Queue ConnectionFactory 
ConnectionFactory myConnFactory = new com.sun.messaging.ConnectionFactory();

String h = "HOSTNAME";
String p = "PORTNO";

// Set imqAddressList property
((com.sun.messaging.ConnectionFactory)myConnFactory).setProperty(
com.sun.messaging.ConnectionConfiguration.imqAddressList,
new StringBuffer().append("mq://").append(h).append(":").append(p).append("/jms").toString());

//Create a connection to the Sun Java(tm) System Message Queue Message Service.
Connection myConn = myConnFactory.createConnection();

//Start the Connection created in step 3.
myConn.start();

//Create a session within the connection.
Session mySess = myConn.createSession(false, Session.AUTO_ACKNOWLEDGE);

//Instantiate a Sun Java(tm) System Message Queue Destination administered object.
Queue myQueue = new com.sun.messaging.Queue("<MODULENAME>");

//Create a message producer.
MessageProducer myMsgProducer = mySess.createProducer(myQueue);

//Create and send a message to the queue.
TextMessage myTextMsg = mySess.createTextMessage();
myTextMsg.setText("<message>");

System.out.println("Sending Message: " + myTextMsg.getText());
myMsgProducer.send(myTextMsg);

//Create a message consumer.
MessageConsumer myMsgConsumer = mySess.createConsumer(myQueue);

//Start the Connection created in step 3.
myConn.start();

//Receive a message from the queue.
Message msg = myMsgConsumer.receive();

//Retreive the contents of the message.
if (msg instanceof TextMessage) {
TextMessage txtMsg = (TextMessage) msg;
System.out.println("Read Message: " + txtMsg.getText());
}

//Close the session and connection resources.
mySess.close();
myConn.close();