Giliran Mesej adalah mekanisme komunikasi silang proses yang digunakan untuk melaksanakan pemprosesan asynchronous, decoupling dan trafik pemotongan puncak. Fungsi terasnya termasuk: 1. Decoupling pengirim dan penerima; 2. Asynchronization meningkatkan kelajuan tindak balas; 3. Buffering permintaan serentak yang tinggi. Beratur mesej arus perdana di Java termasuk RabbitMQ (sesuai untuk senario dengan keperluan kebolehpercayaan yang tinggi), Kafka (sesuai untuk senario throughput yang tinggi), ActiveMQ (sesuai untuk keserasian yang baik tetapi prestasi purata), dan RocketMQ (sesuai untuk sistem disebarkan berskala besar). Apabila menggunakannya, anda perlu memberi perhatian kepada kehilangan maklumat, penggunaan berulang, penalaan prestasi dan kos operasi dan penyelenggaraan.

Komunikasi asynchronous adalah penting dalam sistem yang diedarkan moden, dan barisan mesej Java adalah alat penting untuk mencapai matlamat ini. Menggunakan beratur mesej membolehkan gandingan longgar antara komponen yang berbeza, meningkatkan kelajuan tindak balas sistem, dan meningkatkan toleransi kesalahan. Jika anda sedang mempertimbangkan untuk melaksanakan komunikasi tak segerak di Java, perlu memahami beberapa skim antrian mesej arus perdana dan senario yang berkenaan.

Apakah giliran mesej? Mengapa anda memerlukannya?

Ringkasnya, beratur mesej adalah mekanisme komunikasi di seluruh proses atau perkhidmatan. Pengeluar menghantar tugas ke barisan, dan pengguna mengambilnya dari barisan dan memprosesnya. Manfaat pendekatan ini adalah:

• Decoupling : Pengirim dan penerima tidak perlu berada dalam talian pada masa yang sama
• Pemotongan puncak dan pengisian lembah : Semasa berurusan dengan permintaan serentak yang tinggi, aliran boleh diserang
• Pemprosesan Asynchronous : Meningkatkan kelajuan tindak balas sistem keseluruhan

Sebagai contoh, selepas pengguna membuat pesanan, dia tidak segera melakukan operasi seperti menghantar e -mel dan menolak inventori, tetapi sebaliknya melemparkan tugas -tugas ini ke dalam barisan dan diproses perlahan -lahan oleh latar belakang.

Beberapa teknik beratur mesej yang biasa digunakan di java

Pada masa ini, dalam ekosistem Java, terdapat giliran mesej biasa berikut:

• RabbitMQ : Middleware pemesejan lama, fungsi yang kuat, menyokong pelbagai protokol, dan sesuai untuk senario dengan keperluan kebolehpercayaan yang tinggi.
• Kafka : Dikenali dengan throughput yang tinggi, sesuai untuk senario seperti Big Data Log Collection, pemprosesan aliran masa nyata, dll.
• ActiveMQ : Produk lama di bawah Apache, dengan keserasian yang baik, tetapi prestasinya tidak sebaik Kafka dan Rabbitmq.
• RocketMQ : Produk sumber terbuka Alibaba, menekankan ketersediaan yang tinggi dan ciri-ciri yang diedarkan, sesuai untuk sistem berskala besar.

Giliran mesej yang dipilih bergantung terutamanya kepada keperluan perniagaan anda. Contohnya:

• Jika ia adalah senario seperti pemprosesan pesanan dan pemberitahuan pembayaran yang tidak sensitif terhadap kelewatan tetapi memerlukan kebolehpercayaan, RabbitMQ adalah pilihan yang baik;
• Jika ia adalah senario di mana pengumpulan log, data pemantauan, dan lain -lain memerlukan throughput yang tinggi, Kafka lebih sesuai;
• Jika anda sudah menggunakan ekosistem awan Alibaba, RockeTMQ mungkin lebih mudah diintegrasikan.

Bagaimana cara menggunakan beratur mesej di Java?

Mengambil Rabbitmq sebagai contoh, proses asas adalah seperti berikut:

1. Memperkenalkan kebergantungan pelanggan (Maven):

    <geterlihat>
       <groupId> com.rabbitmq </groupId>
       <stifactid> amqp-client </artifactid>
       <versi> 5.21.0 </versi>
   </ketergantungan>

2. Mewujudkan Sambungan dan Saluran:

    Kilang ConnectionFactory = ConnectionFactory baru ();
   kilang.Sethost ("localhost");
   Sambungan sambungan = factory.newConnection ();
   Saluran saluran = connection.CreateChannel ();

3. Mengisytiharkan barisan dan menghantar mesej:

    Channel.queuedeClare ("Task_queue", palsu, palsu, palsu, null);
   Mesej String = "Hello World!";
   Channel.BasicPublish ("", "Task_queue", null, message.getBytes ());

4. Mesej monitor sampingan pengguna:

    DeliverCallback DeliverCallback = (Pengguna, Penghantaran) -> {
       String msg = rentetan baru (penghantaran.getBody (), "UTF-8");
       System.out.println ("Mesej yang diterima:" msg);
   };
   Channel.BasicConsume ("Task_queue", benar, penghantaranCallback, consumerTag -> {});

Ini hanya satu contoh mudah. Dalam perkembangan sebenar, ia juga perlu menangani isu -isu seperti semula, giliran surat mati, dan mekanisme pengesahan.

Isu yang perlu diperhatikan semasa menggunakan beratur mesej

• Masalah Kehilangan Mesej : Pastikan untuk membolehkan mod Kegigihan dan Pengesahan Manual untuk mengelakkan mesej hilang tanpa dimakan dengan betul.
• Masalah Penggunaan Berulang : Apabila merancang logik pengguna, idempotence mesti dipastikan, seperti deduplikasi melalui ID unik.
• Bottleneck Prestasi : Parameter yang munasabah seperti bilangan benang, prefetches, dan lain -lain untuk mengelakkan sisa sumber atau penyumbatan.
• Kos Operasi dan Penyelenggaraan : Sebagai infrastruktur, penggunaan, pemantauan dan pengembangan barisan mesej memerlukan tenaga.

Sesetengah pasukan akan menggunakan perkhidmatan MQ secara langsung yang disediakan oleh pengeluar awan (seperti AWS SQS, Alibaba Cloud RocketMQ), yang dapat menjimatkan banyak kerja operasi dan penyelenggaraan.

Pada dasarnya itu sahaja. Menguasai penggunaan dan senario giliran mesej yang boleh membantu anda untuk menjadi selesa apabila membina aplikasi berprestasi tinggi dan berskala.

Atas ialah kandungan terperinci Beratur mesej Java untuk komunikasi tak segerak. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!