我们在consumer这个功能下进行代码的编写


首先是新建这个层级的包

创建入门程序的消费者

消费者也需要和mq建立通道。建立连接创建通道


在顶部都声明这个队列

下面写核心代码监听队列。basicConsume方法这就是核心方法

Ctrl+T--选择最后一个PublisherCallbackChannelImpl

有很多的重载方法，我们取其中的一个

实现消费方法

这里用原始的消费方法
这个里面需要重写方法

handleDelivery

当接收到消息后就会调用hanleDelivery


滴一个参数consumerTag在实现类的方法里面有一个地方是设置这个consumerTag 也就是消费者标签的地方。这个参数是可设也可不设置的

通过envelope是信封 的意思。通过envelope可以拿到很多东西例如拿到交换机

还可以拿到消息Id

参数列表 各个参数的意思

输出消息的内容

把channel定义在try catch的外面

启动测试 

如果再次执行一次 发送的方法。


那么接收的这里也会自动接收消息

流程