2,配置消息生产者的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
说明发送成功。
5,开发消费者:
同样,先修改mq的配置文件:
image.png
6,编写监听类:
@Component
public class SpringRabbitListener {
@RabbitListener(queues = "simple.queue")
public void listenSimpleQueue(String msg) {
System.out.println("消费者接收到simple.queue的消息:【" + msg + "】");
}
7,运行主程序,会看到消息已经被消费。
image.png image.png
网友评论