image.png
2零院，配置消息生產(chǎn)者的mq連接消息：
image.png
3，編寫測試類：
@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringAmqpTest {
@Autowired
private RabbitTemplate rabbitTemplate;
@Test
public void testSendMessage2SimpleQueue() {
String queueName = "simple.queue";
String message = "hello, spring amqp!";
rabbitTemplate.convertAndSend(queueName, message);
}
}
4村刨，運行測試類告抄，去mq的管理頁面查看
image.png
說明發(fā)送成功。
5嵌牺，開發(fā)消費者：
同樣打洼，先修改mq的配置文件：
image.png
6，編寫監(jiān)聽類：
@Component
public class SpringRabbitListener {
@RabbitListener(queues = "simple.queue")
public void listenSimpleQueue(String msg) {
System.out.println("消費者接收到simple.queue的消息：【" + msg + "】");
}
7逆粹，運行主程序募疮，會看到消息已經(jīng)被消費。
image.png
image.png
