參考博文：http://www.cnblogs.com/SzeCheng/p/4792084.html
參考博文：http://activemq.apache.org/producer-flow-control.html
名詞解釋：
P：生產(chǎn)者
C：消費(fèi)者
服務(wù)端：P?或者?ActiveMQ服務(wù)
客戶端：ActiveMQ服務(wù)?或者?C
客戶端成功接收一條消息的標(biāo)志是這條消息被簽收。成功接收一條消息一般包括如下三個(gè)階段：?
1．客戶端接收消息；?
2．客戶端處理消息；?
3．消息被簽收。
session = connection.createSession(Boolean.false, Session.CLIENT_ACKNOWLEDGE);##第一個(gè)參數(shù)控制事務(wù),第二個(gè)參數(shù)控制消息
在不帶事務(wù)的 Session 中，一條消息何時(shí)和如何被簽收取決于Session的設(shè)置。
1．Session.AUTO_ACKNOWLEDGE
當(dāng)客戶端從 receive 或 onMessage成功返回時(shí)，Session 自動(dòng)簽收客戶端的這條消息的收條。
2．Session.CLIENT_ACKNOWLEDGE
客戶端通過(guò)調(diào)用消息的 acknowledge 方法簽收消息。
message.acknowledge();
在帶事務(wù)的 Session 中，簽收自動(dòng)發(fā)生在事務(wù)提交時(shí)。如果事務(wù)回滾，所有已經(jīng)接收的消息將會(huì)被再次傳送。其實(shí)這里的Session.CLIENT_ACKNOWLEDGE 用處不大。
session = connection.createSession(Boolean.TRUE, Session.CLIENT_ACKNOWLEDGE);
session.commit();
總結(jié)：
1、對(duì)于生產(chǎn)者：服務(wù)端端為P，客戶端為ActiveMQ服務(wù)。 ?Session設(shè)置為AUTO_ACKNOWLEDGE 和CLIENT_ACKNOWLEDGE ，相對(duì)來(lái)說(shuō)區(qū)別不是很大，根據(jù)情況考慮。
2、對(duì)于消費(fèi)者：服務(wù)端為ActiveMQ為服務(wù)，客戶端為C。?Session設(shè)置為AUTO_ACKNOWLEDGE ，接收到消息（receive 或 onMessage成功返回時(shí)），即為消費(fèi)成功，然后從隊(duì)列里移除該數(shù)據(jù)。不關(guān)心該數(shù)據(jù)有沒有正確被處理成我們想要的結(jié)果；Session設(shè)置為CLIENT_ACKNOWLEDGE 時(shí)，必須手動(dòng)調(diào)用acknowledge 方法才為消費(fèi)成功，然后從隊(duì)列里移除該條數(shù)據(jù)。
3、P和C的Session設(shè)置成哪種模式，互不影響。
熱AI工具
Undress AI Tool
免費(fèi)脫衣服圖片
Undresser.AI Undress
人工智能驅(qū)動(dòng)的應(yīng)用程序，用于創(chuàng)建逼真的裸體照片
AI Clothes Remover
用于從照片中去除衣服的在線人工智能工具。
Clothoff.io
AI脫衣機(jī)
Video Face Swap
使用我們完全免費(fèi)的人工智能換臉工具輕松在任何視頻中換臉！
熱門文章
熱工具
記事本++7.3.1
好用且免費(fèi)的代碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
功能強(qiáng)大的PHP集成開發(fā)環(huán)境
Dreamweaver CS6
視覺化網(wǎng)頁(yè)開發(fā)工具
SublimeText3 Mac版
神級(jí)代碼編輯軟件(SublimeText3)
Java ActiveMQ 的 20 個(gè)最佳實(shí)踐
Feb 20, 2024 pm 09:48 PM
1.選擇合適的客戶端傳輸協(xié)議ActiveMQ支持多種客戶端傳輸協(xié)議，包括STOMP、AMQP和OpenWire。根據(jù)您的應(yīng)用程序需求選擇合適的協(xié)議，以優(yōu)化性能和可靠性。2.配置消息持久性持久性消息即使在服務(wù)器重新啟動(dòng)后也能持久化，而非持久性消息則不會(huì)。對(duì)于關(guān)鍵消息，選擇持久性以確保可靠傳遞。演示代碼：//設(shè)置消息持久性MessageProducerproducer=session.createProducer(destination);producer.setDeliveryMode(Deliv
Java ActiveMQ 的 20 個(gè)高級(jí)技巧
Feb 20, 2024 pm 09:51 PM
1.消息路由使用JMSSelectors過(guò)濾消息：使用JMSSelectors根據(jù)消息屬性對(duì)傳入消息進(jìn)行篩選，僅處理相關(guān)消息。創(chuàng)建自定義消息路由器：擴(kuò)展ActiveMQ的路由功能，通過(guò)編寫自定義路由器將消息發(fā)送到特定目的地。配置輪詢負(fù)載均衡：將傳入消息均勻分布到多個(gè)消息消費(fèi)者，提高處理能力。2.持久性啟用持久性會(huì)話：確保即使應(yīng)用程序或服務(wù)器發(fā)生故障，消息也能持久存儲(chǔ)，避免丟失。配置死信隊(duì)列(DLQ)：將處理失敗的消息移至DLQ，以便重新處理或分析。使用Journal存儲(chǔ)：提高持久性消息的性能，減
Java ActiveMQ：輕松實(shí)現(xiàn)分布式系統(tǒng)的異步通信
Feb 19, 2024 pm 10:18 PM
ActiveMQ是Apache出品的一款開源消息中間件，它使用Java語(yǔ)言開發(fā)，具有可靠的消息傳遞、異步通信和集群支持等特點(diǎn)。ActiveMQ能夠在不同的應(yīng)用之間進(jìn)行數(shù)據(jù)交換，并且支持多種消息協(xié)議，如JMS、AMQP和MQtT等。1.ActiveMQ的優(yōu)勢(shì)ActiveMQ是一款非常成熟的消息中間件，它具有以下優(yōu)勢(shì)：可靠的消息傳遞：ActiveMQ能夠保證消息的可靠傳遞，即使在網(wǎng)絡(luò)故障或服務(wù)器宕機(jī)的情況下，消息也不會(huì)丟失。異步通信：ActiveMQ支持異步通信，允許不同的應(yīng)用之間進(jìn)行非實(shí)時(shí)的通信。
Java ActiveMQ 的 20 個(gè)必知概念
Feb 21, 2024 am 08:40 AM
1.消息代理(Broker)ActiveMQ核心組件，負(fù)責(zé)處理所有消息流。它提供一個(gè)平臺(tái)，應(yīng)用程序可以連接、發(fā)送和接收消息。BrokerServicebroker=newBrokerService();broker.addConnector("tcp://0.0.0.0:61616");broker.start();2.消息隊(duì)列在ActiveMQ中存儲(chǔ)消息的邏輯概念容器。消息隊(duì)列可以從多個(gè)生產(chǎn)者接收消息，并將其傳遞給多個(gè)消費(fèi)者。Queuequeue=session.createQueue("my
怎么在SpringBoot中整合ActiveMQ
May 11, 2023 pm 06:16 PM
設(shè)計(jì)手機(jī)手機(jī)maven 名前org.springframework.bootspring-boot-starter-parent1.5.4.RELEASEUTF-8UTF-81.8org.springframework.bootspring-boot-starterorg.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-啟動(dòng)器 starter-testtestorg.springframework
Java JMS入門：輕松掌握消息傳遞技術(shù)的基礎(chǔ)知識(shí)
Feb 26, 2024 am 10:34 AM
1.JavaJMS簡(jiǎn)介JavaJMS是一個(gè)用于建立、發(fā)送和接收消息的Javaapi。它提供了可靠的消息傳遞功能，非常適合分布式系統(tǒng)和企業(yè)級(jí)應(yīng)用程序。消息傳遞系統(tǒng)可以將消息從一個(gè)應(yīng)用程序發(fā)送到另一個(gè)應(yīng)用程序，即使這兩個(gè)應(yīng)用程序位于不同的機(jī)器上。2.JMSAPIJMSAPI定義了一系列接口和類，用于發(fā)送和接收消息。這些接口和類包括：javax.jms.ConnectionFactory：用于創(chuàng)建連接到JMS服務(wù)器的連接。javax.jms.Connection：連接到JMS服務(wù)器的連接。javax.
Springboot中如何整合Activemq
May 21, 2023 pm 01:13 PM
1導(dǎo)入整合所需要的依賴：org.springframework.bootspring-boot-starter-activemq2創(chuàng)建application.properties文件spring.activemq.broker-url=tcp://127.0.0.1:61616spring.activemq.user=adminspring.activemq.password=adminserver.port=8080queue=myqueue3.自定義配置文件QueueConfig讀取配置文件
Java ActiveMQ：助力企業(yè)實(shí)現(xiàn)可靠、高效的消息傳輸
Feb 19, 2024 pm 10:12 PM
ActiveMQ是一個(gè)完全開源的Java消息服務(wù)器，也是Apache軟件基金會(huì)旗下最受歡迎的項(xiàng)目之一。它遵循Java消息服務(wù)(JMS)規(guī)范，提供了一套用于構(gòu)建分布式、異步和面向消息的應(yīng)用程序的api。ActiveMQ以其可靠性、高效性和靈活性而著稱，使其成為各種企業(yè)應(yīng)用程序的理想選擇?？煽啃裕篈ctiveMQ使用持久化存儲(chǔ)機(jī)制來(lái)確保消息的可靠傳遞。當(dāng)消息被發(fā)送到ActiveMQ時(shí)，它將被寫入磁盤，即使服務(wù)器發(fā)生故障，這些消息也不會(huì)丟失。當(dāng)服務(wù)器重新啟動(dòng)時(shí)，它會(huì)從持久化存儲(chǔ)中恢復(fù)這些消息，并將其傳
