Weblogic 中 JMS 客户端工作原理:

  1. 客户端程序通过 JNDI 查找 ConnectionFactory 对象,获取连接对象 Connection。
  2. 通过 Connection 对象创建 Session 对象,Session 对象用于发送和接收消息。
  3. 通过 Session 对象创建 Destination 对象,Destination 对象用于指定消息发送的目的地。
  4. 通过 Session 对象创建 MessageProducer 对象,MessageProducer 对象用于发送消息到指定的目的地。
  5. 通过 Session 对象创建 MessageConsumer 对象,MessageConsumer 对象用于接收消息。
  6. 客户端程序发送消息到指定的目的地,或从指定的目的地接收消息。

Weblogic 中 JMS 的实例代码:

发送消息:

Context ctx = new InitialContext();
ConnectionFactory factory = (ConnectionFactory) ctx.lookup('jms/ConnectionFactory');
Connection connection = factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = (Destination) ctx.lookup('jms/Queue');
MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage('Hello, World!');
producer.send(message);

接收消息:

Context ctx = new InitialContext();
ConnectionFactory factory = (ConnectionFactory) ctx.lookup('jms/ConnectionFactory');
Connection connection = factory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = (Destination) ctx.lookup('jms/Queue');
MessageConsumer consumer = session.createConsumer(destination);
connection.start();
Message message = consumer.receive();
if (message instanceof TextMessage) {
    TextMessage textMessage = (TextMessage) message;
    System.out.println('Received message: ' + textMessage.getText());
}
Weblogic JMS 客户端工作原理及实例代码详解

原文地址: http://www.cveoy.top/t/topic/kztX 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录