Rumah php教程 PHP开发 ActiveMQ中Session设置的相关理解

ActiveMQ中Session设置的相关理解

Nov 22, 2016 pm 01:14 PM
activemq

参考博文: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);##第一个参数控制事务,第二个参数控制消息
Salin selepas log masuk

在不带事务的 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);
Salin selepas log masuk
session.commit();
Salin selepas log masuk

总结:

1、对于生产者:服务端端为P,客户端为ActiveMQ服务。  Session设置为AUTO_ACKNOWLEDGE 和CLIENT_ACKNOWLEDGE ,相对来说区别不是很大,根据情况考虑。

2、对于消费者:服务端为ActiveMQ为服务,客户端为C。 Session设置为AUTO_ACKNOWLEDGE ,接收到消息(receive 或 onMessage成功返回时),即为消费成功,然后从队列里移除该数据。不关心该数据有没有正确被处理成我们想要的结果;Session设置为CLIENT_ACKNOWLEDGE 时,必须手动调用acknowledge 方法才为消费成功,然后从队列里移除该条数据。

3、P和C的Session设置成哪种模式,互不影响。


Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn

Alat AI Hot

Undresser.AI Undress

Undresser.AI Undress

Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover

AI Clothes Remover

Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Undress AI Tool

Undress AI Tool

Gambar buka pakaian secara percuma

Clothoff.io

Clothoff.io

Penyingkiran pakaian AI

AI Hentai Generator

AI Hentai Generator

Menjana ai hentai secara percuma.

Alat panas

Notepad++7.3.1

Notepad++7.3.1

Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina

SublimeText3 versi Cina

Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1

Hantar Studio 13.0.1

Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6

Dreamweaver CS6

Alat pembangunan web visual

SublimeText3 versi Mac

SublimeText3 versi Mac

Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

20 Amalan Terbaik untuk Java ActiveMQ 20 Amalan Terbaik untuk Java ActiveMQ Feb 20, 2024 pm 09:48 PM

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

20 Petua Lanjutan untuk Java ActiveMQ 20 Petua Lanjutan untuk Java ActiveMQ Feb 20, 2024 pm 09:51 PM

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

Java ActiveMQ: Melaksanakan komunikasi tak segerak dalam sistem teragih dengan mudah Java ActiveMQ: Melaksanakan komunikasi tak segerak dalam sistem teragih dengan mudah Feb 19, 2024 pm 10:18 PM

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.

Bagaimana untuk mengintegrasikan ActiveMQ dalam SpringBoot Bagaimana untuk mengintegrasikan ActiveMQ dalam SpringBoot May 11, 2023 pm 06:16 PM

目录结构引入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

20 konsep yang mesti diketahui untuk Java ActiveMQ 20 konsep yang mesti diketahui untuk Java ActiveMQ Feb 21, 2024 am 08:40 AM

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

Bagaimana untuk mengintegrasikan Activemq dalam Springboot Bagaimana untuk mengintegrasikan Activemq dalam Springboot May 21, 2023 pm 01:13 PM

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

Bermula dengan Java JMS: Kuasai Asas Teknologi Pemesejan Dengan Mudah Bermula dengan Java JMS: Kuasai Asas Teknologi Pemesejan Dengan Mudah Feb 26, 2024 am 10:34 AM

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.

Java ActiveMQ: Membantu perusahaan mencapai penghantaran mesej yang boleh dipercayai dan cekap Java ActiveMQ: Membantu perusahaan mencapai penghantaran mesej yang boleh dipercayai dan cekap Feb 19, 2024 pm 10:12 PM

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

See all articles