RabbitMQ的自定义消费者使用

之前的文章里面，我都是在消费端的代码里面编写while循环，进行consumer.nextDelivery方法进行获取下一条消息，然后进行消费处理，这种方式太low了，耦合性太高，所以要使用自定义的consumer来解耦，这种方式更方便一些，也是在实际工作中最常用的使用方式

下面来看看具体的代码实现， 代码地址：    https://github.com/hmilyos/rabbitmq-api-demo

如图所示，先来实现我们的自定义消费者

自定义消费者

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

使用自定义消费者

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

生产端代码

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

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