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