springAMQP的使用

1， image.png

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