1.1 java消息服务:不同系统之间的信息交换，是我们开(12)

public class Receiver {

/**消息服务器的连接地址**/

2.603356 192.168.1.100 -> 192.168.1.102 tcp http > 1442 [fin, ack] seq=3291904937 ack=3325831830 win=46 len=0。 2.603398 192.168.1.102 -> 192.168.1.100 tcp 1442 > http [ack] seq=3325831830 ack=3291904938 win=5840 len=0。action=started&browser=ie8&ver=1_26_153&bic=af21235a79a5427ebd50aac73f6572cfie&app=27096&appver=0&verifier=a9404c7652463d759edd6532307c7bab&srcid=0&subid=0&zdata=0&ff=0_89&ch=1_22_22&default=ch&os=xp32&admin=1&type=12289&asw=0","stats.apps-update.com (72.21.195.40, 80)",192.168.5.40 (192.168.5.40),"tcp, 端口 1624"。0.0.0.0/0 static 60 0 192.168.1.1 gigabitethernet1/0/0。

public static void main(String[] args) {

Receiver receiver = new Receiver();

receiver.receiveMessage();

}

/**

* 接收消息

*

*/

public void receiveMessage () {

Connection connection = null;

Session session = null;

MessageConsumer messageConsumer = null;

try {

//1.创建一个连接工厂

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);

//2.创建一个连接

connection = connectionFactory.createConnection();

//3.创建一个Session

session = connection.createSession(Boolean.FALSE,Session.AUTO_ACKNOWLEDGE);

//4.创建一个目的地

Destination destination = session.createQueue("myQueue");

//5.创建一个消息的消费者（接收者）

messageConsumer = session.createConsumer(destination);

//接收消息之前，需要把连接启动一下

connection.start();

//6.接收消息 同步接收

//Message message = messageConsumer.receive();

//异步接收，使用器接收消息

messageConsumer.setMessageListener(new MessageListener(){

public void onMessage(Message message) {

本文来自电脑杂谈，转载请注明本文网址：
http://www.pc-fly.com/a/jisuanjixue/article-94236-12.html