Konsep lanjutan JMS termasuk kumpulan mesej, pemilih mesej, urus niaga dan mod pengesahan, dan beratur surat mati. Kumpulan mesej memastikan bahawa kumpulan mesej yang sama diproses oleh pengguna yang sama melalui JMSxGroupID untuk memastikan urutan; Mesej pemilih mesej menapis mesej berdasarkan atribut, seperti MessageConsumer Consumer = session.CreateConsumer (Topic, "EventType = 'Login'"); urus niaga ini menyokong sesi.Session_transacted mod, menyedari atomik pengirim dan menerima operasi; Giliran surat mati menangkap pelbagai mesej yang gagal, yang memudahkan analisis dan cuba lagi, dan meningkatkan keupayaan toleransi kesalahan sistem.

Dalam bekerja dengan Java Messaging Service (JMS), mudah untuk mendapatkan asas -asas -topik, beratur, pengeluar, dan pengguna. Tetapi apabila anda melewati asas -asas, terdapat beberapa konsep lanjutan yang boleh menjadikan sistem pemesejan anda lebih mantap, berskala, dan boleh dipercayai.

Berikut adalah beberapa bidang utama yang perlu menyelam jika anda membina atau mengekalkan aplikasi berasaskan JMS yang serius.

Kumpulan mesej

Kumpulan mesej menyelesaikan masalah biasa dalam sistem yang diedarkan: Bagaimana untuk memastikan pesanan pesanan apabila menggunakan pelbagai pengguna.

Biasanya, mesej yang dihantar ke barisan boleh diproses oleh mana -mana bilangan pengguna. Itu bagus untuk berskala tetapi buruk jika pesanan mesej penting. Sebagai contoh, jika anda memproses perdagangan saham untuk akaun tertentu, anda tidak mahu perdagangan B diproses sebelum berdagang hanya kerana dua pengguna yang berbeza mengambilnya daripada perintah.

Bagaimana ia berfungsi:

• Setiap mesej diberikan ID Kumpulan ( JMSXGroupID ) yang mengenal pasti kumpulan logik.
• Pembekal JMS memastikan bahawa semua mesej dalam kumpulan yang sama diproses oleh pengguna yang sama pada satu masa.
• Sebaik sahaja satu pengguna mengambil kumpulan, tiada pengguna lain akan memproses mesej dari kumpulan itu sehingga mereka dibebaskan.

Ini memberi anda pesanan setiap kumpulan semasa masih membenarkan paralelisme di seluruh kumpulan.

Petua: Berhati -hati untuk tidak memberikan terlalu banyak mesej kepada satu kumpulan. Sekiranya anda berbuat demikian, anda akan kehilangan manfaat pemprosesan selari.

Pemilih mesej

Kadang -kadang, anda tidak mahu setiap pengguna menerima setiap mesej. Di situlah pemilih mesej berguna.

Pemilih membenarkan pengguna menapis mesej yang mereka terima berdasarkan sifat tajuk mesej atau sifat tersuai yang ditetapkan oleh pengeluar.

Contoh:

Katakan anda mempunyai topik yang menyiarkan acara pengguna seperti log masuk, logout, kemas kini profil, dan lain -lain. Anda mungkin mempunyai pengguna berasingan yang berminat hanya dalam jenis peristiwa tertentu.

 MessageConsumer consumer = session.createConsumer (topik, "eventType = 'login'");

Dalam kes ini, pengguna hanya menerima peristiwa log masuk.

Kes penggunaan termasuk:

• Mesej routing ke perkhidmatan yang berbeza berdasarkan jenis kandungan
• Menghantar mesej ujian ke pengguna ujian khas tanpa menjejaskan yang hidup
• Melaksanakan penapis pub/sub ringan tanpa menguruskan pelbagai topik

Nota: Tidak semua penyedia JMS melaksanakan pemilih dengan prestasi yang sama. Dalam persekitaran yang tinggi, ujian bagaimana pemilih mempengaruhi kelajuan penghantaran.

Urus niaga dan mengakui mod

Mendapatkan penghantaran mesej yang betul bermakna memahami urus niaga dan mod pengakuan.

Apabila anda menerima mesej, anda perlu memberitahu broker sama ada anda telah berjaya mengendalikannya. Sekiranya ada masalah, anda mungkin mahu mesej itu disampaikan semula.

Terdapat beberapa mod pengakuan utama:

• Session.AUTO_ACKNOWLEDGE - Mengakui secara automatik menerima sebaik sahaja mesej diterima
• Session.CLIENT_ACKNOWLEDGE - Memerlukan pelanggan untuk memanggil message.acknowledge()
• Session.DUPS_OK_ACKNOWLEDGE - pengakuan malas yang boleh menyebabkan pendua tetapi meningkatkan prestasi
• Session.SESSION_TRANSACTED - Membolehkan transaksi tempatan (lebih lanjut mengenai yang di bawah)

Urus niaga membolehkan anda menghantar mesej menghantar dan menerima bersama supaya semua berjaya atau tidak. Ini berguna apabila anda perlu menyelaras antara penggunaan mesej dan kemas kini pangkalan data.

 Sesi sesi = Connection.CreateSession (True, 0);
MessageProducer producer = session.createProducer (giliran);
Mesej TextMessage = session.CreateTextMessage ("Hello");
producer.send (mesej);

session.commit (); // Semua operasi dalam sesi ini dilakukan

Sekiranya pengecualian berlaku sebelum memanggil commit , anda boleh melancarkan dan mencuba semula.

PENTING: Urus niaga adalah setempat ke sesi dan tidak merangkumi pelbagai sumber melainkan jika anda menggunakan transaksi XA dan pengurus transaksi.

Beratur surat mati (DLQs)

Tidak kira betapa padat sistem anda, beberapa mesej tidak akan diproses dengan betul. Sama ada disebabkan oleh data yang cacat, logik perniagaan yang gagal, atau isu perkhidmatan luaran, akhirnya anda akan mengalami mesej yang terus gagal.

Beratur surat mati bertindak sebagai jaring keselamatan. Apabila mesej gagal dihantar selepas beberapa percubaan, ia akan dipindahkan ke DLQ dan bukannya melengkung tanpa henti melalui sistem anda.

Cara mengkonfigurasinya bergantung kepada penyedia JMS , tetapi kebanyakan broker menawarkan tetapan seperti:

• Percubaan Max Redelivery
• Kelewatan masa antara pengambilan semula
• Nama giliran huruf mati sasaran

Sebaik sahaja mesej berakhir di DLQ, anda boleh memeriksa mereka secara manual atau membina alat untuk memproses semula mereka kemudian.

Petua Pro: Pantau DLQ anda dengan kerap. Ia sering menjadi tempat pertama untuk melihat apabila perkara -perkara mula menjadi salah hilir.

Ini bukan satu -satunya ciri canggih di JMS, tetapi mereka meliputi beberapa yang paling berkesan apabila sistem pemesejan atau penyelesaian masalah.

Setiap konsep menangani masalah dunia yang memerintahkan, menapis, kebolehpercayaan, dan pengendalian ralat-dan mengetahui bagaimana dan bila memohon mereka membuat perbezaan besar dalam tingkah laku sistem.

Pada dasarnya itu sahaja.

Atas ialah kandungan terperinci Konsep Lanjutan Pesanan Java (JMS). Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!