Cara menggunakan Java untuk membangunkan aplikasi middleware pemesejan yang diedarkan berdasarkan RocketMQ-javaTutorial-php.cn

Cara menggunakan Java untuk membangunkan aplikasi middleware pemesejan yang diedarkan berdasarkan RocketMQ

WBOY

Lepaskan： 2023-09-21 14:30:11

asal

1011 orang telah melayarinya

Cara menggunakan Java untuk membangunkan aplikasi middleware pemesejan yang diedarkan berdasarkan RocketMQ

Cara menggunakan Java untuk membangunkan aplikasi perisian tengah pemesejan teragih berdasarkan RocketMQ

Pengenalan:
Dengan perkembangan pesat Industri Internet Dengan pembangunan, sistem teragih menjadi semakin biasa. Sebagai salah satu komponen yang biasa digunakan dalam sistem teragih, perisian tengah mesej memainkan peranan penting dalam menghubungkan pelbagai komponen teragih, mencapai penyahgandingan dan memastikan ketekalan data. Artikel ini akan memperkenalkan cara menggunakan Java untuk membangunkan aplikasi perisian tengah pemesejan teragih berdasarkan RocketMQ, bertujuan untuk membantu pembaca memahami dan menguasai cara menggunakan RocketMQ untuk pemesejan diedarkan.

1 Persediaan

Pasang RocketMQ dan mulakan NameServer dan Broker
Alamat muat turun: http://rocketmq.apache.org/#🎜 #
Buat projek Maven baharu dalam IDE dan tambahkan kebergantungan seperti berikut:

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.8.0</version>
</dependency>

Salin selepas log masuk

2. Hantar mesej

# 🎜 🎜#

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.common.RemotingHelper;

public class Producer {
    public static void main(String[] args) throws Exception {
        DefaultMQProducer producer = new DefaultMQProducer("producerGroup");
        producer.setNamesrvAddr("localhost:9876");
        producer.start();

        Message message = new Message("TopicTest", "TagA", "Hello RocketMQ".getBytes(RemotingHelper.DEFAULT_CHARSET));
        producer.send(message);
        System.out.println("发送消息成功");

        producer.shutdown();
    }
}

Salin selepas log masuk

Buat kelas bernama Producer, buat contoh DefaultMQProducer dalam kaedah utama dan tetapkan alamat NameServer. Seterusnya, buat contoh Mesej dan tentukan subjek, label dan kandungan mesej yang akan dihantar. Panggil kaedah producer.send(message) untuk menghantar mesej, dan akhirnya tutup pengeluar.

Run ProducerJalankan kaedah utama kelas Producer Jika semuanya dikonfigurasikan dengan betul, anda akan melihat output "Mesej dihantar dengan jayanya" pada konsol.

rreee#🎜🎜 buat contoh DefaultMQPushConsumer dalam kaedah utama, dan tetapkan alamat NameServer. Seterusnya, langgan topik dan teg yang anda mahu gunakan dengan menghubungi kaedah consumer.subscribe. Kemudian, gunakan kaedah registerMessageListener objek Pengguna untuk mendaftarkan pendengar mesej dan melaksanakan logik perniagaan apabila mesej tiba. Akhirnya, mulakan pengguna.

Run Consumer
Jalankan kaedah utama kelas Consumer Jika semuanya dikonfigurasikan dengan betul, anda akan melihat output "Consumer Started" dalam konsol dan dapat. menerima Mesej yang dihantar oleh pengeluar.
4. Ringkasan

Atas ialah kandungan terperinci Cara menggunakan Java untuk membangunkan aplikasi middleware pemesejan yang diedarkan berdasarkan RocketMQ. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!