举例说明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());
}
``
原文地址: https://www.cveoy.top/t/topic/dcd3 著作权归作者所有。请勿转载和采集!