JMS教程(二)

r囧r小猫 2022-08-19 11:12 144阅读 0赞

下面我们来写一个Hello World程序，让大家对activeMQ及JMS有一个初步的了解.

1. 首先请下载activeMQ.  官网: http://activemq.apache.org/

我下载的是最新的 apache-activemq-5.13.0, 解压后放在了C:\\下.

2. 开启activemq.    找到安装目录/bin/win32/activemq.bat, 运行这个文件即可.

请注意你的操作系统版本. 我的是 windows XP 32位，所以运行的是 win32目录下的activemq.bat文件.

3. 下面开始编写程序.

a. ) 程序中引入包:

activemq-all-5.13.jar

commons-collection-3.2.2.jar

commons-pool2-2.4.2.jar

b) 书写程序

//建立与消息服务器的连接
    	ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");  
            Connection connection = factory.createConnection();  
            connection.start();  
              
            //Queue是 jms接口  ->           ActiveMQQueue
            //创建一个队列
            Queue queue = new ActiveMQQueue("testQueue"); 
            //创建一个会话.
            final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);  
            //通过会话来创建一个消息
            Message message = session.createTextMessage("Hello JMS!");  
             //创建一个生产者
            MessageProducer producer = session.createProducer(queue); 
            //生产者将消息发给服务器
            producer.send(message);  
         
            System.out.println("消息已经发送到服务器");  
             
            //创建一个消费者
            MessageConsumer comsumer = session.createConsumer(queue); 
            //消费者接收消息
            Message recvMessage = comsumer.receive();  
            System.out.println(((TextMessage)recvMessage).getText());

分析:

1.     ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");

activemq的默认端口是  61616,  通过这一句代码，创建一个联接工厂.

2.     Queue queue = new ActiveMQQueue("testQueue");

创建了一个队列，也就是一个Destination目标，也表明activemq提供的是一个  P2P的服务模型.

叁数值  "testQueue"表明在activemq中存了一个名字叫  "testQueue"的队列,后面消费者也要从这个队列中取消息.

3.  Session session = connection.createSession(false, Session.AUTO\_ACKNOWLEDGE);  
                      创建了一个会话，第一个参数值false表示不支持事务模式.  第二个参数表明消费者联接后自动确认.

运行结果:

![Center][]

[Center]: /images/20220731/b200102fb6a84695ba7b1c679a85b096.png