我们在consumer这个功能下进行代码的编写
首先是新建这个层级的包
创建入门程序的消费者
消费者也需要和mq建立通道。建立连接创建通道
在顶部都声明这个队列
下面写核心代码监听队列。basicConsume方法这就是核心方法
Ctrl+T--选择最后一个PublisherCallbackChannelImpl
有很多的重载方法，我们取其中的一个
实现消费方法
这里用原始的消费方法
这个里面需要重写方法
handleDelivery
当接收到消息后就会调用hanleDelivery
滴一个参数consumerTag在实现类的方法里面有一个地方是设置这个consumerTag 也就是消费者标签的地方。这个参数是可设也可不设置的
通过envelope是信封 的意思。通过envelope可以拿到很多东西例如拿到交换机
还可以拿到消息Id
参数列表 各个参数的意思
输出消息的内容
把channel定义在try catch的外面
启动测试
如果再次执行一次 发送的方法。
那么接收的这里也会自动接收消息
流程
