Technologieaustausch

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

Zuerst müssen wir eine Microservice-Architektur erstellen, da diese im Allgemeinen in einer Microservice-Architektur verwendet wird (an einer einzelnen Entität ist natürlich nichts auszusetzen, siehe qps).

Im übergeordneten Projekt müssen wir amqp-Abhängigkeiten einführen

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

Wählen Sie dann den Unterdienst aus, den wir benötigen, um die Initialisierung der Nachricht abzuschließen

Das erste ist das Senden von Nachrichten, wobei RabbitTemplate als Vorlage zum Senden von Nachrichten verwendet wird, die Methode „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);
    }
}

Dann können wir die Listener-Klasse unter dem Listener-Paket erstellen (Muss als Frühlingsbohne registriert werden) Abschlussmeldung über @RabbitListener

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

Ok, jetzt ist das Senden und Empfangen von Nachrichten für RabbitMQ unter SpringAMQP abgeschlossen.