技術共有

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

まず、マイクロサービス アーキテクチャを作成する必要があります。一般的に、これはマイクロサービス アーキテクチャで使用されるためです (もちろん、単一のエンティティに問題はありません。qps を参照)。

親プロジェクトでは、amqp 依存関係を導入する必要があります

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

次に、メッセージの初期化を完了するために必要なサブサービスを選択します。

1 つ目は、RabbitTemplate をメッセージ送信テンプレートとして使用し、メソッド 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);
    }
}

次に、リスナー パッケージの下にリスナー クラスを作成できます (Spring Bean として登録する必要があります) 完了メッセージ、@RabbitListener 経由

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

さて、これで springAMQP での Rabbitmq のメッセージ送受信が完了しました。