阶段5 3.微服务项目【学成在线】_day05 消息中间件RabbitMQ_6.RabbitMQ研究-入门程序-消费者

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


首先是新建这个层级的包

建立入门程序的消费者

消费者也须要和mq创建通道。创建链接建立通道


在顶部都声明这个队列

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

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

有不少的重载方法,咱们取其中的一个


测试

实现消费方法

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

handleDelivery

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


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

经过envelope是信封 的意思。经过envelope能够拿到不少东西例如拿到交换机

还能够拿到消息Id

参数列表 各个参数的意思

输出消息的内容

把channel定义在try catch的外面


3d

启动测试 





若是再次执行一次 发送的方法。


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

流程

 

相关文章
相关标签/搜索