消息接收

首先配置MQ地址，在consumer服務的application.yml中添加配置：

spring:rabbitmq:host: 192.168.150.101 # 主機名port: 5672 # 端口virtual-host: / # 虛擬主機username: rabbitmq# 用戶名password: rabbitmq# 密碼

然后在consumer服務的cn.itcast.mq.listener包中新建一個類SpringRabbitListener，代碼如下：

import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component;@Component public class SpringRabbitListener {@RabbitListener(queues = "simple.queue")public void listenSimpleQueueMessage(String msg) throws InterruptedException {System.out.println("spring 消費者接收到消息：【" + msg + "】");} }

測試

啟動consumer服務，然后在publisher服務中運行測試代碼，發送MQ消息

總結

以上是生活随笔為你收集整理的SpringAMQP--入门案例的消息接收的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。