image.png
2，配置消息生產(chǎn)者的mq連接消息：
image.png
3，編寫測(cè)試類：
@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，運(yùn)行測(cè)試類，去mq的管理頁面查看
image.png
說明發(fā)送成功。
5，開發(fā)消費(fèi)者：
同樣，先修改mq的配置文件：
image.png
6，編寫監(jiān)聽類：
@Component
public class SpringRabbitListener {
@RabbitListener(queues = "simple.queue")
public void listenSimpleQueue(String msg) {
System.out.println("消費(fèi)者接收到simple.queue的消息：【" + msg + "】");
}
7，運(yùn)行主程序，會(huì)看到消息已經(jīng)被消費(fèi)。
image.png
image.png
