Berbagi teknologi

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

Pertama kita perlu membuat arsitektur microservice, karena secara umum ini digunakan dalam arsitektur microservice (tentunya tidak ada yang salah dengan satu entitas, lihat qps)

Di proyek induk kita perlu memperkenalkan dependensi amqp

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
</dependencies>

Kemudian pilih sub-layanan yang kita perlukan untuk menyelesaikan inisialisasi pesan

Yang pertama adalah pengiriman pesan, menggunakan RabbitTemplate sebagai template pengiriman pesan, metode convertAndSend

@SpringBootTest
public class SpringAmqpTest {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Test
    void testMsgCaiyiTestQueue(){
        String msg = "this is message from caiyi";
        rabbitTemplate.convertAndSend("cybg_study_queue",msg);
    }
}

Kemudian kita dapat membuat kelas pendengar di bawah paket pendengar (Perlu didaftarkan sebagai spring bean) pesan penyelesaian, melalui @RabbitListener

@RabbitListener(queues = "cybg_study_queue")
public void listenQueueMsg(String msg){
    System.out.println("接收到的msg："+msg);
}

oke, sekarang pengiriman dan penerimaan pesan untuk Rabbitmq di springAMQP selesai.