Compartir tecnología

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

Primero necesitamos crear una arquitectura de microservicio, porque en términos generales esto se usa en una arquitectura de microservicio (por supuesto, no hay nada de malo en una sola entidad, consulte qps).

En el proyecto principal necesitamos introducir dependencias amqp.

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

Luego seleccione el subservicio que necesitamos para completar la inicialización del mensaje.

El primero es el envío de mensajes, utilizando RabbitTemplate como plantilla de envío de mensajes, el método 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);
    }
}

Luego podemos crear la clase de escucha en el paquete de escucha (Necesita estar registrado como frijol primaveral.) mensaje de finalización, a través de @RabbitListener

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

Bien, ahora se completa el envío y recepción de mensajes para RabbitMQ en SpringAMQP.