Menggunakan RabbitMQ2 untuk pemprosesan mesej tak segerak dalam pembangunan API Java

Dalam proses pembangunan Java API, pemprosesan mesej tak segerak ialah teknologi yang sangat biasa. Pemprosesan mesej tak segerak boleh meningkatkan kelajuan tindak balas sistem dan meningkatkan kebolehskalaan sistem.

RabbitMQ ialah sistem baris gilir mesej sumber terbuka Ia menyediakan mekanisme penghantaran mesej yang mudah dan boleh dipercayai dan digunakan secara meluas dalam sistem yang diedarkan. Dalam pembangunan API Java, terdapat banyak faedah menggunakan RabbitMQ untuk pemprosesan mesej tak segerak. Artikel ini akan memperkenalkan cara menggunakan RabbitMQ2 untuk pemprosesan mesej tak segerak.

1. Prasyarat

Sebelum mula menggunakan RabbitMQ2, anda perlu membuat persediaan berikut.

1.1 Pasang RabbitMQ

RabbitMQ ditulis berdasarkan Erlang, jadi Erlang perlu dipasang terlebih dahulu. Anda boleh memuat turun versi terkini Erlang dari https://www.erlang.org/downloads dan ikut wizard pemasangan untuk memasangnya.

Selepas memasang Erlang, anda boleh memasang RabbitMQ. Pakej pemasangan RabbitMQ boleh dimuat turun dari https://www.rabbitmq.com/download.html dan dipasang mengikut wizard pemasangan.

Selepas memasang RabbitMQ, anda perlu memulakan perkhidmatan RabbitMQ. Dalam sistem Linux/Mac, anda boleh menjalankan arahan berikut untuk memulakan perkhidmatan RabbitMQ:

sudo rabbitmq-server

Dalam sistem Windows, rabbitmq-server.bat boleh didapati dalam pemasangan RabbitMQ direktori, klik dua kali fail untuk memulakan perkhidmatan RabbitMQ.

1.2 Memperkenalkan kebergantungan RabbitMQ2

Menggunakan RabbitMQ2 untuk pemprosesan mesej tak segerak memerlukan pengenalan kebergantungan RabbitMQ2. Anda boleh membuka fail pom.xml projek dan menambah kandungan berikut di bawah teg fce2022be5e87c17c94245fd7ccbf1d9:

b4b38e33757a6497aa8690936b905cc1

<groupId>com.rabbitmq</groupId>
<artifactId>rabbitmq-client</artifactId>   
<version>5.5.1</version>

09a0e22e5aaafd848ae04665be625b91

2. Pengenalan kepada konsep asas RabbitMQ2

Sebelum mula menggunakan RabbitMQ2 untuk pemprosesan mesej tak segerak, anda perlu memahami beberapa konsep asas RabbitMQ2.

2.1 Pengeluar

Pengeluar ialah pengeluar mesej dan bertanggungjawab menghantar mesej ke pelayan RabbitMQ.

2.2 Pengguna

Pengguna ialah pengguna mesej dan bertanggungjawab untuk menerima mesej daripada pelayan RabbitMQ dan memprosesnya.

2.3 Pertukaran

Pertukaran ialah pertukaran mesej, digunakan untuk menerima mesej yang dihantar oleh Pengeluar dan menghalakan mesej ke Baris Gilir yang sepadan.

2.4 Baris Gilir

Baris gilir ialah baris gilir mesej, digunakan untuk menyimpan mesej.

2.5 RoutingKey

RoutingKey ialah kunci penghalaan mesej, yang digunakan untuk menghalakan mesej dari Exchange ke Baris Gilir yang sepadan.

3. Menggunakan RabbitMQ2

Setelah memahami konsep asas RabbitMQ2, anda boleh mula menggunakan RabbitMQ2 untuk pemprosesan mesej tak segerak. Berikut akan memperkenalkan cara menggunakan RabbitMQ2 untuk pemprosesan mesej tak segerak.

3.1 Sambung ke pelayan RabbitMQ

Sebelum menggunakan RabbitMQ2 untuk pemprosesan mesej tak segerak, anda perlu menyambung ke pelayan RabbitMQ terlebih dahulu. Anda boleh menggunakan kod berikut untuk menyambung:

ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setPort(5672);
kilang. setUsername( "guest");
factory.setPassword("guest");
Connection connection = factory.newConnection();

Dalam kod di atas, ConnectionFactory digunakan untuk membuat Sambungan ke pelayan RabbitMQ. Antaranya, setHost menetapkan nama hos pelayan RabbitMQ, setPort menetapkan nombor port pelayan RabbitMQ, setUsername dan setPassword masing-masing menetapkan nama pengguna dan kata laluan apabila menyambung ke pelayan RabbitMQ.

3.2 Menghantar mesej

Selepas berjaya menyambung ke pelayan RabbitMQ, anda boleh mula menghantar mesej. Mesej boleh dihantar menggunakan kod berikut:

Saluran saluran = connection.createChannel();
channel.queueDeclare("queue_name", false, false, false, null);
channel.basicPublish (" ", "queue_name", null, "message".getBytes());
channel.close();

Dalam kod di atas, connection.createChannel() digunakan untuk mencipta Saluran saluran. Pengisytiharan Queue boleh dilengkapkan melalui kaedah channel.queueDeclare() Parameter pertama kaedah ialah nama Queue Parameter kedua menunjukkan sama ada Queue yang berterusan. Parameter keempat menunjukkan sama ada Padamkan Baris secara automatik Parameter kelima ialah atribut Baris.

Penghantaran mesej diselesaikan melalui kaedah channel.basicPublish() Parameter pertama mewakili nama Exchange Anda boleh menghantar rentetan kosong untuk menunjukkan menggunakan Exchange lalai , menunjukkan bahawa mesej akan dihalakan Dalam Baris Gilir, parameter ketiga mewakili atribut mesej, null boleh dihantar dan parameter keempat mewakili kandungan mesej.

3.3 Terima mesej

Selepas menghantar mesej, anda boleh menggunakan kod berikut untuk menerima mesej:

Saluran saluran = connection.createChannel();
saluran .queueDeclare(" queue_name", false, false, false, null);
Consumer consumer = new DefaultConsumer(channel) {

@Override
public void handleDelivery(String consumerTag, Envelope envelope,
                           AMQP.BasicProperties properties, byte[] body) throws IOException {
    String message = new String(body, "UTF-8");
    System.out.println("Received: " + message);
}

};
channel.basicConsume("queue_name", true, pengguna);

Dalam kod di atas, kaedah connection.createChannel() juga digunakan untuk mencipta saluran Saluran. Pengisytiharan Queue juga dilakukan menggunakan kaedah channel.queueDeclare(). Tentukan kaedah pemprosesan mesej dengan mencipta objek DefaultConsumer Kaedah handleDelivery() akan dipanggil apabila mesej diterima dan mesej perlu diproses dalam kaedah ini.

Penerimaan mesej dilengkapkan melalui kaedah channel.basicConsume() Parameter pertama menunjukkan baris gilir mesej yang akan diterima Parameter kedua menunjukkan sama ada untuk mengesahkan penerimaan mesej secara automatik objek Pengguna, menunjukkan Bagaimana mesej diproses.

Di atas adalah proses asas menggunakan RabbitMQ2 untuk pemprosesan mesej tak segerak. Dengan menggunakan RabbitMQ2, pemprosesan mesej tak segerak boleh menjadi sangat mudah dan kelajuan tindak balas dan kebolehskalaan sistem boleh dipertingkatkan.

Atas ialah kandungan terperinci Menggunakan RabbitMQ2 untuk pemprosesan mesej tak segerak dalam pembangunan API Java. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!