Condivisione della tecnologia

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

Per prima cosa dobbiamo creare un'architettura a microservizi, perché in genere questa viene utilizzata in un'architettura a microservizi (ovviamente non c'è niente di sbagliato in una singola entità, vedi qps)

Nel progetto genitore dobbiamo introdurre le dipendenze amqp

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

Seleziona quindi il sottoservizio di cui abbiamo bisogno per completare l'inizializzazione del messaggio

Il primo è l'invio di messaggi, utilizzando RabbitTemplate come modello di invio dei messaggi, il metodo 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);
    }
}

Quindi possiamo creare la classe listener nel pacchetto listener (Deve essere registrato come fagiolo primaverile) messaggio di completamento, tramite @RabbitListener

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

ok, ora l'invio e la ricezione del messaggio per coniglimq sotto springAMQP sono completati.