rabitMQ
程序员文章站
2024-01-05 11:11:28
...
@RabbitListener(queuesToDeclare = @Queue("productInfo"))
配置这个注解会在mq里面自动生成一个列队,name为 productInfo,并监听这个列队的消息,mq里面有消息时会在这里被监听到并消费,如果消费者抛异常,就会一直接收到这个消息,直到消费完这条消息
amqpTemplate.convertAndSend("productInfo","msg");
这个方法会向mq的"productInfo"列队发送消息,发送的信息一般默认处理为base64编码