首頁  >  文章  >  php教程  >  ActiveMQ中Session設定的相關理解

ActiveMQ中Session設定的相關理解

高洛峰
高洛峰原創
2016-11-22 13:14:292507瀏覽

參考部落格文章: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設定成哪一種模式,互不影響。


陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn