Обмен технологиями

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

Сначала нам нужно создать микросервисную архитектуру, потому что, вообще говоря, это используется в микросервисной архитектуре (конечно, нет ничего плохого в одном объекте, см. qps).

В родительском проекте нам нужно ввести зависимости amqp

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

Далее выбираем подсервис, который нам нужен для первого запуска сообщения

Первый — отправка сообщений с использованием 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);
}

ОК, теперь отправка и получение сообщений для RabbitMQ под SpringAMQP завершены.