成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

干貨｜SpringBoot JMS（ActiveMQ）API實踐應用詳解

作者：淺羽Eric
開發 前端
Active是一種開源的，實現了JMS1.1規范的，面向消息(MOM)的中間件，為應用程序提供高效的、可擴展的、穩定的和安全的企業級消息通信。AC-tiveMQ使用Apache提供的授權，任何人都可以對其實現代碼進行修改。

[[350573]]

 前言

Active是一種開源的，實現了JMS1.1規范的，面向消息(MOM)的中間件，為應用程序提供高效的、可擴展的、穩定的和安全的企業級消息通信。AC-tiveMQ使用Apache提供的授權，任何人都可以對其實現代碼進行修改。

ActiveMQ的設計目標是提供標準的，面向消息的，能夠跨越多語言和多系統的應用集成消息通信中間件。ActiveMQ實現了JMS標準并提供了很多附加的特性。本文將帶大家詳細介紹ActiveMQ的API的使用。

1. JMS的概念?

「什么是JMS呢：」

  • JMS---------JAVA Message Service
  • JAVA的消息服務，是sun公司提供的接口，只是一個規范，這個規范就類似于JDBC是一樣的，使用的時候是需要當前規范的實現產品的。

「JMS能干什么呢：」

  • 能夠將信息發布到目的地
  • 可以從目的地來消費這個消息

2、兩種通信模型

「隊列的通信概念：」

  • 特點：當我們同一個隊列有多個消費者的時候，多個消費者的數據之和才是原來隊列中的所有數據
  • 隊列的通信模型最大的適用場景：流量的消峰，高并發的處理

「主題的通信模型：」

  • 特點：當我們隊列有多個消費者的時候，那么這多個消費者消費到的數據是一樣的
  • 主題消費者通信模型的適用場景：微服務下服務之間的異步通信

3. MQ的實現產品

「實現產品：」

  • ActiveMQ
  • RabbitMQ
  • RockerMQ
  • Kafka(這個設計的初衷是做分布式的日志的，后來因為日志有嚴格的順序問題，這個時候人們就用Kafka來做消息隊列了)

4、JMS中常見的名詞

「常見的名詞：」

  • ActiveMQConnectionFactory：這個是創建連接的工廠
  • ConnectionFactory：連接的工廠
  • Connection：連接JAVA對MQ的一個連接
  • Destination：目的地
  • 生產者(Producer)
  • 消費者(Consumer)
  • Session：會話(每一次對MQ的操作都稱為一次會話)
  • Queue：隊列
  • Topic：主題

5、什么是消息隊列

「消息隊列簡單的說就是用來存放臨時數據的地方：」

  • 生產者----------->存儲介質上
  • 消費者----------->存儲介質上

「消息隊列類似于快遞公司：」

  • 你可以將東西交給快遞公司
  • 目標人也可以從快遞公司去取東西

6. ActiveMQ是什么

「含義：」

  • ActiveMQ就是一個JMS的實現產品，它能夠實現JMS下的所有功能

7、ActiveMQ能干什么

「主要作用：」

  • 流量消峰處理
  • 微服務下模塊的異步通信
  • 處理高并發下的訂單
  • 處理第三方平臺的高并發
  • 協助消息表可以完成分布式事務的最終一致性

8、ActiveMQ的安裝

「ActiveMQ的安裝和配置：」

  1.  1、官網下載Linux版的ActiveMQ（最新版本為5.13.4） 
  2.        https://activemq.apache.org/download.html 
  3.  
  4.        2、解壓安裝 
  5.       tar -zxvf apache-activemq-5.13.4-bin.tar.gz 
  6.  
  7.        3、配置（這里采用默認配置，無需修改） 
  8.       vim /usr/lical/activemq-1/conf/activemq.xml 
  9.  
  10.        4、啟動 
  11.       cd /usr/local/activemq-1/bin 
  12. ./activemq start 
  13.  
  14.       5、打開管理界面（管理界面可以查看并管理所有隊列及消息） 
  15.          http://192.168.1.100:8161 
  16.  
  17.        啟動成功后，可以瀏覽 http://localhost:8161/admin/ 
  18.        默認用戶名、密碼：admin/admin 
  19.        管理界面是用jetty做容器的，如果想修改管理界面的端口，可以編輯../conf/jetty.xml，找到下面這一段： 
  20.       <bean id="jettyPort" class="org.apache.activemq.web.WebConsolePort" init-method="start"> 
  21.     <!-- the default port       number for the web console --> 
  22.     <property name="host" value="0.0.0.0"/> 
  23.     <property name="port" value="8161"/> 
  24.      </bean> 
  25.        用戶名/密碼是在 ../conf/jetty-realm.properties 里，比如要增加一個管理員jimmy/123456，可參考下面修改： 
  26.        1 
  27. 2 
  28. 3admin: admin, admin 
  29. jimmy: 123456, admin 
  30. user: user, user 
  31.        注：管理界面有一個小坑，ActiveMQ 5.13.2與jdk1.8兼容性有點問題，如果使用jdk1.8，管理界面進入Queues標簽頁時，偶爾會報錯，但是并不影響消息正常收發，只是無法從界面上查看隊列情況，如果出現該問題，可將jdk版本降至1.7，同時最好清空data目錄下的所有數據，再重啟activemq即可。 

9. ActiveMQ的API的使用

「AcatveMQ的API使用：」

 

  • 隊列的使用(生產者)
  1. package com.qy.mq.queue; 
  2.  
  3. import org.apache.activemq.ActiveMQConnectionFactory; 
  4. import org.apache.activemq.Message; 
  5.  
  6. import javax.jms.*; 
  7.  
  8. /** 
  9.  * @Auther: qianyu 
  10.  * @Date: 2020/11/04 14:12 
  11.  * @Description:生產者 
  12.  */ 
  13. public class Producer { 
  14.  
  15.     //準備發布的這個地址 
  16.     private  static final String PATH="tcp://10.7.182.87:61616"; 
  17.     //ActiveMQ下的用戶名 
  18.     private static final String userName="admin"; 
  19.     //ActiveMQ下的密碼 
  20.     private static final String password="admin"; 
  21.  
  22.     public static void main(String[] args) throws JMSException { 
  23.         //第一步：創建連接的工廠 
  24.         ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(userName, password, PATH); 
  25.         //通過這個工廠獲取連接 
  26.         Connection connection = activeMQConnectionFactory.createConnection(); 
  27.         //第三步：打開這個連接 
  28.         connection.start(); 
  29.         //第四步：創建操作MQ的這個會話 
  30.         /** 
  31.          * 第一個參數：是否使用事務 
  32.          * 第二個參數：客戶端的應答模式 
  33.          *     第一種：自動應答 
  34.          *     第二種：客戶端手動應答 
  35.          */ 
  36.         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
  37.         //需要發送消息的目的地(queue操作的是隊列) 
  38.         Destination destination=session.createQueue("wqqq"); 
  39.         //生產者來生產這個消息 
  40.         //要有生產者 
  41.         MessageProducer messageProducer = session.createProducer(destination); 
  42.  
  43.         //發送很多的消息到消息隊列中去 
  44. //        for (int i=0;i<100;i++){ 
  45.             //需要準備發送的消息 
  46. //            TextMessage textMessage = session.createTextMessage("我是淺羽:"+i); 
  47.             //研究消息的類型 
  48.  
  49.           /*  BytesMessage bytesMessage = session.createBytesMessage(); 
  50.             bytesMessage.setByteProperty("www",new Byte("123")); 
  51.  
  52.             //接下來就可以發送消息了 
  53.             messageProducer.send(bytesMessage);*/ 
  54.  
  55.         //創建map類型的message 
  56.         /*MapMessage mapMessage = session.createMapMessage(); 
  57.         mapMessage.setInt("www1",123); 
  58.  
  59.         messageProducer.send(mapMessage);*/ 
  60.  
  61.         ObjectMessage objectMessage = session.createObjectMessage(new User(1, "qianyu", "123")); 
  62.         messageProducer.send(objectMessage); 
  63.  
  64. //        } 
  65.     } 
  66.  
  67. } 
  • 隊列的使用（消費者）
  1. package com.qy.mq.queue; 
  2.  
  3. import org.apache.activemq.ActiveMQConnectionFactory; 
  4.  
  5. import javax.jms.*; 
  6. import java.io.Serializable; 
  7.  
  8. /** 
  9.  * @Auther: qianyu 
  10.  * @Date: 2020/11/04 14:13 
  11.  * @Description:消費者 
  12.  */ 
  13. public class Consumer { 
  14.  
  15.     //準備發布的這個地址 
  16.     private  static final String PATH="tcp://10.7.182.87:61616"; 
  17.     //ActiveMQ下的用戶名 
  18.     private static final String userName="admin"; 
  19.     //ActiveMQ下的密碼 
  20.     private static final String password="admin"; 
  21.  
  22.     public static void main(String[] args) throws JMSException { 
  23.         //第一步：創建連接的工廠 
  24.         ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(userName, password, PATH); 
  25.         //通過這個工廠獲取連接 
  26.         Connection connection = activeMQConnectionFactory.createConnection(); 
  27.         //第三步：打開這個連接 
  28.         connection.start(); 
  29.         //第四步：創建操作MQ的這個會話 
  30.         /** 
  31.          * 第一個參數：是否使用事務 
  32.          * 第二個參數：客戶端的應答模式 
  33.          *     第一種：自動應答 
  34.          *     第二種：客戶端手動應答 
  35.          */ 
  36.         Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); 
  37.         //需要發送消息的目的地(queue操作的是隊列) 
  38.         Destination destination=session.createQueue("wqqq"); 
  39.         //創建我們的消費者了 
  40.         MessageConsumer messageConsumer = session.createConsumer(destination); 
  41.         //接下來就可以接收我們的消息了 
  42.         //Message message = messageConsumer.receive(); 
  43.  
  44.         //接收消息并指定這個超時的時間 
  45. //      Message message = messageConsumer.receive(5000); 
  46.  
  47.         //接收消息沒有就不等待了 直接over了  不接收了 
  48. //      Message message = messageConsumer.receiveNoWait(); 
  49.  
  50.         //給定當前的路徑設置監聽器 
  51.         messageConsumer.setMessageListener(new MessageListener() { 
  52.             @Override 
  53.             public void onMessage(Message message) { 
  54.  
  55.                /* BytesMessage bytesMessage= (BytesMessage) message; 
  56.  
  57.                 try { 
  58.                     System.out.println("獲取到的數據是:"+bytesMessage.getByteProperty("www")); 
  59.                 } catch (JMSException e) { 
  60.                     e.printStackTrace(); 
  61.                 }*/ 
  62.  
  63.  
  64.                /*MapMessage mapMessage= (MapMessage) message; 
  65.  
  66.                 try { 
  67.                     System.out.println("獲取到的數據是:"+mapMessage.getInt("www1")); 
  68.                 } catch (JMSException e) { 
  69.                     e.printStackTrace(); 
  70.                 }*/ 
  71.  
  72.                //測試對象類型的消息的發送和接收 
  73.                ObjectMessage objectMessage= (ObjectMessage) message; 
  74.                 try { 
  75.                     User user = (User) objectMessage.getObject(); 
  76.  
  77.                     System.out.println("接收到的數據是:"+user); 
  78.                 } catch (JMSException e) { 
  79.                     e.printStackTrace(); 
  80.                 } 
  81.  
  82.  
  83.               /*  //我們知道是一個字符串類型的消息 
  84.                 TextMessage textMessage= (TextMessage) message; 
  85.                 //接下來就可以打印這個消息了 
  86.                 try { 
  87.                     System.out.println("消費者1---接收到的消息是："+textMessage.getText()); 
  88.                 } catch (JMSException e) { 
  89.                     e.printStackTrace(); 
  90.                 }*/ 
  91.  
  92.                 try { 
  93.                     //這句話就表示的是客戶端來手動的進行應答 
  94.                     message.acknowledge(); 
  95.                 } catch (JMSException e) { 
  96.                     e.printStackTrace(); 
  97.                 } 
  98.  
  99.             } 
  100.         }); 
  101.     } 
  102. } 
  • 主題模型的生產者
  1. package com.qy.mq.topic; 
  2.  
  3. import org.apache.activemq.ActiveMQConnectionFactory; 
  4.  
  5. import javax.jms.*; 
  6.  
  7. /** 
  8.  * @Auther: qianyu 
  9.  * @Date: 2020/11/04 15:17 
  10.  * @Description: 
  11.  */ 
  12. public class Producer { 
  13.     //準備發布的這個地址 
  14.     private  static final String PATH="tcp://10.7.182.87:61616"; 
  15.     //ActiveMQ下的用戶名 
  16.     private static final String userName="admin"; 
  17.     //ActiveMQ下的密碼 
  18.     private static final String password="admin"; 
  19.  
  20.     public static void main(String[] args) throws JMSException { 
  21.         //第一步：創建連接的工廠 
  22.         ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(userName, password, PATH); 
  23.         //通過這個工廠獲取連接 
  24.         Connection connection = activeMQConnectionFactory.createConnection(); 
  25.         //第三步：打開這個連接 
  26.         connection.start(); 
  27.         //第四步：創建操作MQ的這個會話 
  28.         /** 
  29.          * 第一個參數：是否使用事務 
  30.          * 第二個參數：客戶端的應答模式 
  31.          *     第一種：自動應答 
  32.          *     第二種：客戶端手動應答 
  33.          */ 
  34.         Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); 
  35.         //需要發送消息的目的地(下面創建的就應該是主題模型的地址) 
  36.         Destination destination=session.createTopic("topic222"); 
  37.         //生產者來生產這個消息 
  38.         //要有生產者 
  39.         MessageProducer messageProducer = session.createProducer(destination); 
  40.  
  41.         //發送很多的消息到消息隊列中去 
  42.         for (int i=0;i<100;i++){ 
  43.             //需要準備發送的消息 
  44.             TextMessage textMessage = session.createTextMessage("我是淺羽:"+i); 
  45.             //接下來就可以發送消息了 
  46.             messageProducer.send(textMessage); 
  47.         } 
  48.     } 
  49. } 
  • 主題模型的消費者
  1. package com.qy.mq.topic; 
  2.  
  3. import org.apache.activemq.ActiveMQConnectionFactory; 
  4.  
  5. import javax.jms.*; 
  6.  
  7. /** 
  8.  * @Auther: qianyu 
  9.  * @Date: 2020/11/04 15:19 
  10.  * @Description: 
  11.  */ 
  12. public class Consumer { 
  13.  
  14.     //準備發布的這個地址 
  15.     private  static final String PATH="tcp://10.7.182.87:61616"; 
  16.     //ActiveMQ下的用戶名 
  17.     private static final String userName="admin"; 
  18.     //ActiveMQ下的密碼 
  19.     private static final String password="admin"; 
  20.  
  21.     public static void main(String[] args) throws JMSException { 
  22.         //第一步：創建連接的工廠 
  23.         ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(userName, password, PATH); 
  24.         //通過這個工廠獲取連接 
  25.         Connection connection = activeMQConnectionFactory.createConnection(); 
  26.         //第三步：打開這個連接 
  27.         connection.start(); 
  28.         //第四步：創建操作MQ的這個會話 
  29.         /** 
  30.          * 第一個參數：是否使用事務 
  31.          * 第二個參數：客戶端的應答模式 
  32.          *     第一種：自動應答 
  33.          *     第二種：客戶端手動應答 
  34.          */ 
  35.         Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); 
  36.         //需要發送消息的目的地(queue操作的是隊列) 
  37.         Destination destination=session.createTopic("topic222"); 
  38.         //創建我們的消費者了 
  39.         MessageConsumer messageConsumer = session.createConsumer(destination); 
  40.         //接下來就可以接收我們的消息了 
  41.  
  42.         //給定當前的路徑設置監聽器 
  43.         messageConsumer.setMessageListener(new MessageListener() { 
  44.             @Override 
  45.             public void onMessage(Message message) { 
  46.  
  47.                 //我們知道是一個字符串類型的消息 
  48.                 TextMessage textMessage= (TextMessage) message; 
  49.                 //接下來就可以打印這個消息了 
  50.                 try { 
  51.                     System.out.println("消費者1---接收到的消息是："+textMessage.getText()); 
  52.                 } catch (JMSException e) { 
  53.                     e.printStackTrace(); 
  54.                 } 
  55.  
  56.                 try { 
  57.                     message.acknowledge(); 
  58.                 } catch (JMSException e) { 
  59.                     e.printStackTrace(); 
  60.                 } 
  61.  
  62.             } 
  63.         }); 
  64.     } 
  65. } 

本篇關于ActiveMQ的介紹就先到這里結束了，后續會出更多關于ActiveMQ系列更多文章，謝謝大家支持！

責任編輯：姜華 來源： 淺羽的IT小屋
ActiveMQ
相關推薦

2024-04-07 07:53:12

SpringWeb技術WebSocket

2012-05-25 15:35:43

JMSJava

2009-06-25 15:33:13

Java消息服務JMS

2024-03-19 08:45:45

WebSocketSpring應用開發

2023-03-23 09:33:22

Android移動開發

2024-08-26 15:35:40

2022-03-22 22:05:39

區塊鏈支付模式

2025-02-28 09:20:00

Future開發代碼

2022-05-12 11:41:16

開發框架程序

2019-11-11 17:34:16

前端開發技術

2019-01-21 14:20:26

Java開發代碼

2013-06-13 09:21:31

RESTful APIRESTfulAPI

2024-04-08 07:28:27

PiniaVue3狀態管理庫

2019-01-15 09:10:17

邊緣計算數據中心IT

2023-09-08 23:30:19

2016-12-27 08:49:55

API設計策略

2022-03-29 10:04:44

APIHarmony文件管理

2021-03-05 11:52:50

LinuxSPI驅動詳解

2011-12-07 14:57:44

JavaNIO

2009-06-16 10:10:40

JavaMail AP
點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板： 日韩电影中文字幕在线观看 | 日韩电影一区二区三区 | 国产精品不卡一区 | 亚洲国产欧美精品 | 草草草网站 | 成人欧美一区二区三区在线播放 | 91n成人 | 亚洲视频一区在线 | 国产精品久久久久久久久久久久冷 | 成人国产午夜在线观看 | 91在线视频国产 | 97视频人人澡人人爽 | 欧美一区二区免费 | 日本在线视频中文字幕 | 黄色大片免费观看 | 日韩一区二区不卡 | 日本人做爰大片免费观看一老师 | 国产精品久久久久久久久大全 | 一级欧美一级日韩片 | 午夜免费电影院 | 亚洲免费在线视频 | 欧美福利 | 精品国产一区二区三区四区在线 | 国产亚洲精品久久久久动 | 精品美女视频在免费观看 | 国产精品久久久久久一区二区三区 | 午夜精品一区二区三区在线视 | 精品九九久久 | 国产精品高清一区二区三区 | 欧美在线观看免费观看视频 | 男女深夜网站 | 国产黄视频在线播放 | 精品国产91久久久久久 | 亚洲一区二区视频 | 国产成人精品网站 | 久久激情视频 | 久久国产精品亚洲 | 久久久久亚洲av毛片大全 | 欧美小视频在线观看 | 最新国产精品视频 | 男女视频91 |