參考部落格文章:http://www.cnblogs.com/SzeCheng/p/4792084.html
參考部落格文章:http://activemq.apache.org/producer-flow-control.html
名詞解釋:
P:生產者
C:消費者
服務端:P 或 ActiveMQ服務
客戶端:ActiveMQ服務 或 C
客戶端成功接收訊息的標誌是這則訊息被簽。成功接收一則訊息一般包含以下三個階段:
1.客戶端接收訊息;
2.客戶端處理訊息;
3.訊息被簽收。
session = connection.createSession(Boolean.false, Session.CLIENT_ACKNOWLEDGE);##第一个参数控制事务,第二个参数控制消息
在不帶事務的 Session 中,一則訊息何時和如何被簽收取決於Session的設定。
1. Session.AUTO_ACKNOWLEDGE
當客戶端從 receive 或 onMessage成功返回時,Session 自動簽收客戶端的這條訊息的收條。
2. Session.CLIENT_ACKNOWLEDGE
客戶端透過呼叫訊息的 acknowledge 方法簽收訊息。
message.acknowledge();
在帶事務的 Session 中,簽收自動發生在事務提交時。如果交易回滾,所有已經接收的訊息將會再次傳送。其實這裡的Session.CLIENT_ACKNOWLEDGE 用處不大。
session = connection.createSession(Boolean.TRUE, Session.CLIENT_ACKNOWLEDGE);
session.commit();
總結:
1、對於生產者:服務端端為P,客戶端為ActiveMQ服務。 Session設定為AUTO_ACKNOWLEDGE 和CLIENT_ACKNOWLEDGE ,相對來說差異不是很大,視情況考慮。
2、對於消費者:服務端為ActiveMQ為服務,客戶端為C。 Session設定為AUTO_ACKNOWLEDGE ,接收到訊息(receive 或 onMessage成功返回時),即為消費成功,然後從佇列移除該資料。不關心該資料有沒有正確被處理成我們想要的結果;Session設定為CLIENT_ACKNOWLEDGE 時,必須手動呼叫acknowledge 方法才為消費成功,然後從佇列移除該資料。
3、P和C的Session設定成哪一種模式,互不影響。

熱AI工具

Undresser.AI Undress
人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool
免費脫衣圖片

Clothoff.io
AI脫衣器

Video Face Swap
使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱門文章

熱工具

mPDF
mPDF是一個PHP庫,可以從UTF-8編碼的HTML產生PDF檔案。原作者Ian Back編寫mPDF以從他的網站上「即時」輸出PDF文件,並處理不同的語言。與原始腳本如HTML2FPDF相比,它的速度較慢,並且在使用Unicode字體時產生的檔案較大,但支援CSS樣式等,並進行了大量增強。支援幾乎所有語言,包括RTL(阿拉伯語和希伯來語)和CJK(中日韓)。支援嵌套的區塊級元素(如P、DIV),

Safe Exam Browser
Safe Exam Browser是一個安全的瀏覽器環境,安全地進行線上考試。該軟體將任何電腦變成一個安全的工作站。它控制對任何實用工具的訪問,並防止學生使用未經授權的資源。

SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)

SecLists
SecLists是最終安全測試人員的伙伴。它是一個包含各種類型清單的集合,這些清單在安全評估過程中經常使用,而且都在一個地方。 SecLists透過方便地提供安全測試人員可能需要的所有列表,幫助提高安全測試的效率和生產力。清單類型包括使用者名稱、密碼、URL、模糊測試有效載荷、敏感資料模式、Web shell等等。測試人員只需將此儲存庫拉到新的測試機上,他就可以存取所需的每種類型的清單。

SAP NetWeaver Server Adapter for Eclipse
將Eclipse與SAP NetWeaver應用伺服器整合。