RabbitMQ的自定义消费者使用
2018-08-14 本文已影响94人
HmilyMing
之前的文章里面,我都是在消费端的代码里面编写while循环,进行consumer.nextDelivery方法进行获取下一条消息,然后进行消费处理,这种方式太low了,耦合性太高,所以要使用自定义的consumer来解耦,这种方式更方便一些,也是在实际工作中最常用的使用方式
下面来看看具体的代码实现, 代码地址: https://github.com/hmilyos/rabbitmq-api-demo
如图所示,先来实现我们的自定义消费者

接着,重点来了,在声明消费者的代码里面使用刚才的自定义消费者

生产端代码基本不需要修改

先启动消费端,再启动生产端,查看运行结果:注意看消费端的日志,打印出了我们自定义消费者里面的东西了。


至此,简单的使用自定义消费者demo就完成了。