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