Weblogic JMS 客户端工作原理及实例代码详解
Weblogic 中 JMS 客户端工作原理:
- 客户端程序通过 JNDI 查找 ConnectionFactory 对象,获取连接对象 Connection。
- 通过 Connection 对象创建 Session 对象,Session 对象用于发送和接收消息。
- 通过 Session 对象创建 Destination 对象,Destination 对象用于指定消息发送的目的地。
- 通过 Session 对象创建 MessageProducer 对象,MessageProducer 对象用于发送消息到指定的目的地。
- 通过 Session 对象创建 MessageConsumer 对象,MessageConsumer 对象用于接收消息。
- 客户端程序发送消息到指定的目的地,或从指定的目的地接收消息。
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());
}
原文地址: http://www.cveoy.top/t/topic/kztX 著作权归作者所有。请勿转载和采集!