2. 程式人生 > >activemq訂閱模式以及訊息時長和確認機制

activemq訂閱模式以及訊息時長和確認機制

阿新 • • 發佈：2019-02-13
程式碼如下：
  1. package com.activemq;  
  2. import org.apache.activemq.ActiveMQConnectionFactory;  
  3. import javax.jms.*;   
  4. publicclass TopicPub {  
  5.      publicstaticvoid main(String[] args) throws JMSException {    
  6.             ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");    
  7.             Connection connection = factory.createConnection();    
  8.             connection.start();    
  9.             Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);    
  10.             /** 
  11.             Session javax.jms.Connection.createSession(boolean transacted, int acknowledgeMode) throws JMSException
     
  12.             1.transacted事務，事務成功commit,才會將訊息傳送到mom中 
  13.             2.acknowledgeMode訊息確認機制 
  14.                  1）、帶事務的session 
  15.                     如果session帶有事務，並且事務成功提交，則訊息被自動簽收。如果事務回滾，則訊息會被再次傳送。 
  16.                  2）、不帶事務的session 
  17.                     不帶事務的session的簽收方式，取決於session的配置。 
  18.                     Activemq支援一下三種模式：
     
  19.                     Session.AUTO_ACKNOWLEDGE  訊息自動簽收 
  20.                     Session.CLIENT_ACKNOWLEDGE  客戶端呼叫acknowledge方法手動簽收 
  21.                     Session.DUPS_OK_ACKNOWLEDGE 不是必須簽收，訊息可能會重複傳送。在第二次重新傳送訊息的時候，訊息 
  22.                     頭的JmsDelivered會被置為true標示當前訊息已經傳送過一次，客戶端需要進行訊息的重複處理控制。 
  23.                  程式碼示例如下： 
  24.                  session = connection.createSession(true, Session.CLIENT_ACKNOWLEDGE); 
  25.                  textMsg.acknowledge(); 
  26.             */
  27.             Topic topic = session.createTopic("wm5920.topic");    
  28.             MessageProducer producer = session.createProducer(topic);    
  29.             producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);//設定非持久化  
  30. //          producer.setTimeToLive(5000);//5秒後過期，這個對點對點模式有效
  31.             TextMessage message = session.createTextMessage();    
  32.             message.setText("message_" + System.currentTimeMillis());    
  33.             producer.send(message);    
  34.             System.out.println("Sent message: " + message.getText());    
  35.             session.close();    
  36.             connection.stop();    
  37.             connection.close();    
  38.         }    
  39. }  

訂閱主題，注：如果在釋出主題前，沒有訂閱，是收不到訊息的，這跟點對點的佇列模式不同
  1. package com.activemq;  
  2. import org.apache.activemq.ActiveMQConnectionFactory;    
  3. import javax.jms.*;    
  4. publicclass TopicSubs{  
  5. publicstaticvoid main(String[] args) throws JMSException {    
  6.         ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");    
  7.         Connection connection = factory.createConnection();    
  8.         connection.setClientID("wm5920");  
  9.         connection.start();    
  10.         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);    
  11.         Topic topic = session.createTopic("wm5920.topic");    
  12.         //持久訂閱方式，不會漏掉資訊
  13.         TopicSubscriber subs=session.createDurableSubscriber(topic, "wm5920");  
  14.         subs.setMessageListener(new MessageListener() {    
  15.             publicvoid onMessage(Message message) {    
  16.                 TextMessage tm = (TextMessage) message;    
  17.                 try {    
  18.                     System.out.println("Received message: " + tm.getText());    
  19.                 } catch (JMSException e) {    
  20.                     e.printStackTrace();    
  21.                 }    
  22.             }    
  23.         });  
  24.         //非持久訂閱方式
  25. //        MessageConsumer consumer = session.createConsumer(topic);  
  26. //        consumer.setMessageListener(new MessageListener() {  
  27. //            public void onMessage(Message message) {  
  28. //                TextMessage tm = (TextMessage) message;  
  29. //                try {  
  30. //                    System.out.println("Received message: " + tm.getText());  
  31. //                } catch (JMSException e) {  
  32. //                    e.printStackTrace();  
  33. //                }  
  34. //            }  
  35. //        }); 
  36. //        session.commit();
  37. //      session.close();  
  38. //      connection.stop();  
  39. //      connection.close();  
  40.     }    
  41. }  

相關推薦

activemq訂閱模式以及訊息時長和確認機制

程式碼如下： package com.activemq;   import org.apache.activemq.ActiveMQConnectionFactory;   import ja

activemq中的訂閱模式以及訊息時長和確認機制

直接上程式碼 釋出主題 package com.activemq; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; public class TopicPub {

java獲取mp3的時長和播放mp3文件

length trace ger snapshot import oid 時長 cnblogs return 所需包為jaudiotagger-2.2.6-SNAPSHOT.jar和jl1.0.1.jar。 import java.io.BufferedInputStre

jave 獲取音視頻文件的大小、以及播放時長

try message 文件夾 -1 sig system als alt for 首先引入jave-1.0.2.jar， 寫了個demo 僅供參考 package com.readVideo.test; public class VideoName { priv

買雲服務器送免費時長和帶寬，有這麽好的事？

直接 頁面 http 好的 團購 com 小鳥雲 查看 一點 一般大家在購買雲服務器的時候，看到的優惠不外乎是八折九折這樣，不痛不癢的優惠力度感覺無法觸動人心！所以這次小鳥雲就玩得更大一點，直接給大家送免費的時長和帶寬了？！小鳥雲十月雲服務器拼團活動正式啟動啦！活動期間，開

audio自定義樣式，控制操作面板的暫停，播放，獲取音訊的時長，以及根據時長進行進度條展示

<!DOCTYPE html> <html> <head> <meta charset="utf-8"> <title>audio例項</title> <script src="./js

scala實戰之spark使用者線上時長和登入次數統計例項

接觸spark後就開始學習scala語言了，因為有一點python和java的基礎學習起來還行，今天在這裡把我工作中應用scala程式設計統計分析使用者行為日誌的例項和大家分析一下，我這裡主要講一下使用者的線上時長統計和登入次數統計演算法實現過程。 第一步 程式設計環境：首

ActiveMQ訊息傳送和確認機制

ActiveMQ訊息傳送機制：Producer客戶端使用來發送訊息的， Consumer客戶端用來消費訊息； 它們的協同中心就是ActiveMQ broker,broker也是讓producer和consumer呼叫過程解耦的工具，最終實現了非同步RPC/資料交換的功能。 隨

ActiveMQ訂閱模式持久化實現

我的訴求是，建一個訂閱通道，然後多個客戶端監聽，當某個客戶端掉線後，再上線的時候可以收到它沒有接收到的訊息。 本文主要參考了《使用Spring配置ActiveMQ的釋出訂閱模式》(http://nettm.iteye.com/blog/1828268)，將他們複製貼上過來

27.session訪問時長和步長佔比本地測試

本文為《Spark大型電商專案實戰》 系列文章之一，主要介紹之前實現的訪問時長和訪問步長所佔比例在本地進行測試。 說明 對於Accumulator這種分散式累加計算的變數的使用，有一個重要說明：

ActiveMQ中的訊息的持久化和非持久化 以及 持久訂閱者 和 非持久訂閱者之間的區別與聯絡

①DeliveryMode 這是傳輸模式。ActiveMQ支援兩種傳輸模式：持久傳輸和非持久傳輸(persistent and non-persistent delivery)，預設情況下使用的是持久傳輸。 可以通過MessageProducer類的 setDeliv

SpringBoot+ActiveMq實現訂閱模式（Topic）訊息佇列

上文已經詳細介紹了點對點模式（Queue）下的訊息佇列，今天就來再介紹一下訊息佇列的另一種模式：訂閱模式。 一、訂閱模式的流程 生產者產生一條訊息message放入一個topic中，該topic已經三個消費者訂閱了，那麼被放入topic中的這條訊息，就會同時被這三個消費者取走（當然他們必

事件的釋出和訂閱 以及訊息佇列

摘自：http://m.blog.csdn.net/article/details?id=43529311 1 訊息驅動架構 訊息驅動架構（Event Driven Architecture） ： 通過在底耦合的模組之間傳輸事件訊息，以保持模組的鬆散耦合，並藉助事件訊息的通

ActiveMQ兩種訊息模式以及為什麼使用MQ

1.為什麼使用MQ  a.高併發 在高併發分散式環境下，由於來不及同步處理，請求往往發生堵塞;通過訊息佇列，可以非同步處理請求，緩解系統的壓力; b.鬆耦合性 一個應用傳送訊息到MQ之後並不關係訊息如何或者什麼時候被傳遞，同樣的訊息的接收者也不關係訊息從哪裡來的。在不同的環

Redis的批量操作是什麼？怎麼實現的延時佇列？以及訂閱模式、LRU。

## 前言 這次的內容是我自己為了總結Redis知識而擴充的，上一篇其實已經總結了幾點知識了，但是Redis的強大，以及適用範圍之廣可不是單單一篇博文就能總結清的。所以這次準備繼續總結，因為第一個問題，Redis的批量操作，是我在面試過程中被真實問到的，當時沒答上來，也是因為確實沒了解過Redis的批量操作。

AIX查看系統安裝時間和運行時長

usr let pos sha blog clas light log etc $ lslpp -h bos.mp* --AIX系統的安裝時間，可以通過bos.mp和bos.mp64文件集的安裝時間得知 Fileset Level Action

activeMQ公布訂閱模式中中經常使用工具類

模式 .text boolean ava cer ttext tex conn contain package com.jms; import java.util.Map; import java.util.concurrent.ConcurrentHashMap

觀察者模式和發布/訂閱模式的區別

observe nbsp 初步 有時 觀察 觀察者 發生 狀態 發現 在事件總線(EventBus)的架構設計中，用到了發布/訂閱模式，但發現和觀察者模式挺接近，有時容易發生混淆，現試圖分清一下他們的關系。 觀察者模式的角色為觀察者(observer)

JMS消息隊列ActiveMQ(發布／訂閱模式)

jms activemq 消息隊列 (發布／訂閱模式) 消費者1（Consumer）--訂閱（subcribe）-->主題（Topic）package com.java1234.activemq2; import javax.jms.Connection; import javax.j

詳解懶漢模式和餓漢模式以及他們的改進

下一步 例子 理解 創建對象 進行 有一個 這就是 cnblogs 多人 提到單例模式的話相信很多人都不會陌生，一般初級程序員也知道懶漢模式和餓漢模式。 那麽什麽是單例模式呢？我個人低的理解就是當用這個類的對象的時候就只能創建同一個對象。是你，是你，還是你！ 而在單例模式中