最近在工作中用到了ActiveMQ的點對點模式，在此用一個范例簡單描述下使用過程。

1.首先在工程導入ActiveMQ的jar包，此jar包在下載的ActiveMQ資源里，這里用的是ActiveMQ版本是5.9。

?

2.編寫消息發(fā)送者

package com.cool.jms;import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;/*** 消息生產者* Created by hejin on 2017/4/12 0012.*/ public class JMSProducer {//默認連接用戶名private static final String USER= ActiveMQConnection.DEFAULT_USER;//默認連接密碼private static final String PASSWORD=ActiveMQConnection.DEFAULT_PASSWORD;//默認連接地址private static final String URL=ActiveMQConnection.DEFAULT_BROKER_URL;//發(fā)送的消息數量private static final int SENDNUM=10;public static void main(String[] args) throws JMSException {//連接工廠ConnectionFactory connectionFactory;//連接Connection connection;//會話(接收或發(fā)送消息的線程)Session session;//消息目的地Destination destination;//消息生產者MessageProducer messageProducer;//實例化連接工廠connectionFactory=new ActiveMQConnectionFactory(JMSProducer.USER,JMSProducer.PASSWORD,JMSProducer.URL);try {//通過連接工廠獲取連接connection = connectionFactory.createConnection();//啟動連接connection.start();//創(chuàng)建sessionsession=connection.createSession(true,Session.AUTO_ACKNOWLEDGE);//創(chuàng)建一個名稱為HelloWorld的消息隊列destination= session.createQueue("HelloWorld");//創(chuàng)建消息生產者messageProducer = session.createProducer(destination);//發(fā)送消息sendMessage(session,messageProducer);//提交session.commit();} catch (Exception e) {e.printStackTrace();}}public static void sendMessage(Session session,MessageProducer messageProducer) throws Exception{for (int i=0;i<JMSProducer.SENDNUM;i++){//創(chuàng)建需要發(fā)送的消息TextMessage message = session.createTextMessage("ActiveMQ發(fā)送消息:" + i);System.out.println("ActiveMQ發(fā)送消息:"+i);messageProducer.send(message);}} }

　　

執(zhí)行上面的代碼控制臺輸出

在瀏覽器訪問MQ的頁面:http://127.0.0.1:8161/admin/queues.jsp,可以查看發(fā)送的隊列的消息信息。

消息詳情：

?

3.編寫消費package com.cool.jms;

import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;/*** Created by hejin on 2017/4/12 0012.*/ public class JMSConsumer {//默認連接名稱private static String USER= ActiveMQConnection.DEFAULT_USER;//默認密碼private static String PASSWORD=ActiveMQConnection.DEFAULT_PASSWORD;//默認連接地址private static String URL=ActiveMQConnection.DEFAULT_BROKER_URL;public static void main(String[] args) {//連接工廠ConnectionFactory connectionFactory;//連接Connection connection;//會話 接收或發(fā)送消息的進程Session session;//消息的目的地Destination destination;//消息的消費者MessageConsumer messageConsumer;//實例化連接工廠connectionFactory=new ActiveMQConnectionFactory(JMSConsumer.USER,JMSConsumer.PASSWORD,JMSConsumer.URL);//IDEA快速捕獲異常快捷鍵:Ctrl+Alt+Ttry {//通過連接工廠獲取連接connection=connectionFactory.createConnection();//啟動連接connection.start();//創(chuàng)建sessionsession=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);//創(chuàng)建一個HelloWorld的消息隊列destination=session.createQueue("HelloWorld");//創(chuàng)建消息消費者messageConsumer = session.createConsumer(destination);while(true){TextMessage message = (TextMessage) messageConsumer.receive(100000);if(message!=null){System.out.println("收到的消息:"+message.getText());}else{break;}}} catch (JMSException e) {e.printStackTrace();}} }

控制臺輸出:

轉載于:https://www.cnblogs.com/againn/p/6743510.html

總結

以上是生活随笔為你收集整理的ActiveMQ点对点的发送和接收的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。