ActiveMQ中Session设置的相关理解
参考博文: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设置成哪种模式,互不影响。

Alat AI Hot

Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Undress AI Tool
Gambar buka pakaian secara percuma

Clothoff.io
Penyingkiran pakaian AI

AI Hentai Generator
Menjana ai hentai secara percuma.

Artikel Panas

Alat panas

Notepad++7.3.1
Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1
Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6
Alat pembangunan web visual

SublimeText3 versi Mac
Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Topik panas



1. Pilih protokol pengangkutan pelanggan yang sesuai ActiveMQ menyokong pelbagai protokol pengangkutan pelanggan, termasuk STOMP, AMQP dan OpenWire. Pilih protokol yang betul berdasarkan keperluan aplikasi anda untuk mengoptimumkan prestasi dan kebolehpercayaan. 2. Konfigurasikan ketabahan mesej berterusan walaupun selepas pelayan dimulakan semula, manakala mesej tidak berterusan tidak. Untuk mesej kritikal, pilih ketekunan untuk memastikan penghantaran yang boleh dipercayai. Kod demo: //Tetapkan kegigihan mesej MessageProducerproducer=session.createProducer(destination);producer.setDeliveryMode(Deliv

1. Penghalaan mesej menggunakan JMSSelectors untuk menapis mesej: Gunakan JMSSelectors untuk menapis mesej masuk berdasarkan atribut mesej dan hanya memproses mesej yang berkaitan. Cipta penghala mesej tersuai: Lanjutkan keupayaan penghalaan ActiveMQ untuk menghantar mesej ke destinasi tertentu dengan menulis penghala tersuai. Konfigurasikan pengimbangan beban undian: sebarkan mesej masuk secara sama rata kepada berbilang pengguna mesej untuk meningkatkan keupayaan pemprosesan. 2. Kegigihan membolehkan sesi berterusan: memastikan bahawa walaupun aplikasi atau pelayan gagal, mesej boleh disimpan secara berterusan untuk mengelakkan kehilangan. Konfigurasi Baris Gilir Surat Mati (DLQ): Alihkan mesej yang gagal diproses ke DLQ untuk pemprosesan semula atau analisis. Menggunakan Storan Jurnal: Tingkatkan prestasi mesej berterusan, kurangkan

ActiveMQ ialah perisian tengah mesej sumber terbuka yang dihasilkan oleh Apache Ia dibangunkan menggunakan bahasa Java dan mempunyai ciri-ciri pemesejan yang boleh dipercayai, komunikasi tak segerak dan sokongan kluster. ActiveMQ boleh bertukar-tukar data antara aplikasi yang berbeza dan menyokong berbilang protokol pemesejan, seperti JMS, AMQP dan MQtT. 1. Kelebihan ActiveMQ ActiveMQ ialah perisian tengah mesej yang sangat matang Ia mempunyai kelebihan berikut: Penghantaran mesej yang boleh dipercayai: ActiveMQ boleh menjamin penghantaran mesej yang boleh dipercayai Walaupun dalam kes kegagalan rangkaian atau masa henti pelayan, mesej itu tidak akan hilang . Komunikasi tak segerak: ActiveMQ menyokong komunikasi tak segerak, membenarkan komunikasi bukan masa nyata antara aplikasi yang berbeza.

目录结构引入maven依赖org.springframework.bootspring-boot-starter-parent1.5.4.RELEASEUTF-8UTF-81.8org.springframework.bootspring-boot-starterorg.springframework.bootspring-boot-starter-bootframe.web. starter-testtestorg.springframework

1. Broker Mesej ialah komponen teras ActiveMQ dan bertanggungjawab untuk memproses semua aliran mesej. Ia menyediakan platform di mana aplikasi boleh menyambung, menghantar dan menerima mesej. BrokerServicebroker=newBrokerService();broker.addConnector("tcp://0.0.0.0:61616");broker.start();2. Baris gilir mesej ialah bekas konsep logik untuk menyimpan mesej dalam ActiveMQ. Baris gilir mesej boleh menerima mesej daripada berbilang pengeluar dan menghantarnya kepada berbilang pengguna. Queuequeue=session.createQueue("my

1Import kebergantungan yang diperlukan untuk penyepaduan: org.springframework.bootspring-boot-starter-activemq2Buat fail application.properties spring.activemq.broker-url=tcp://127.0.0.1:61616spring.activemq.user=adminspring.activemq =adminserver.port=8080queue=myqueue3 Fail konfigurasi tersuai QueueConfig membaca fail konfigurasi

1. Pengenalan kepada JavaJMS JavaJMS ialah API Java yang digunakan untuk mencipta, menghantar dan menerima mesej. Ia menyediakan keupayaan pemesejan yang boleh dipercayai dan sesuai untuk sistem teragih dan aplikasi peringkat perusahaan. Sistem pemesejan boleh menghantar mesej dari satu aplikasi ke aplikasi yang lain, walaupun kedua-dua aplikasi berada pada mesin yang berbeza. 2.JMSAPIJMSAPI mentakrifkan satu siri antara muka dan kelas untuk menghantar dan menerima mesej. Antara muka dan kelas ini termasuk: javax.jms.ConnectionFactory: digunakan untuk membuat sambungan ke pelayan JMS. javax.jms.Connection: Sambungan ke pelayan JMS. javax.

ActiveMQ ialah pelayan mesej Java sumber terbuka sepenuhnya dan salah satu projek paling popular Yayasan Perisian Apache. Ia mengikut spesifikasi Perkhidmatan Mesej Java (JMS) dan menyediakan satu set API untuk membina aplikasi teragih, tak segerak dan berorientasikan mesej. ActiveMQ terkenal dengan kebolehpercayaan, kecekapan dan fleksibiliti, menjadikannya ideal untuk pelbagai aplikasi perusahaan. Kebolehpercayaan: ActiveMQ menggunakan mekanisme storan yang berterusan untuk memastikan penghantaran mesej yang boleh dipercayai. Apabila mesej dihantar ke ActiveMQ, ia ditulis ke cakera dan walaupun pelayan gagal, mesej ini tidak akan hilang. Apabila pelayan dimulakan semula, ia memulihkan mesej ini dari kedai yang berterusan dan menghantarnya
