Partage de technologie

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

Nous devons d’abord créer une architecture de microservices, car de manière générale, elle est utilisée dans une architecture de microservices (bien sûr, il n’y a rien de mal à avoir une seule entité, voir qps)

Dans le projet parent, nous devons introduire les dépendances amqp

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

Sélectionnez ensuite le sous-service dont nous avons besoin pour terminer l'initialisation du message

Le premier est l'envoi de messages, en utilisant RabbitTemplate comme modèle d'envoi de message, la méthode 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);
    }
}

Ensuite, nous pouvons créer la classe d'écoute sous le package d'écoute (Doit être enregistré comme haricot de printemps) message de fin, via @RabbitListener

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

ok, maintenant l'envoi et la réception des messages pour lapinmq sous springAMQP sont terminés.