说明

在博客 RabbitMQ实现消费者接收消息 的基础上修改，接收消息的基本配置查看前面的博客即可

实现过程

修改消费者Service类

添加接口方法receiveMessage2()

1
2
3
4
5
6
/**
 * 监听队列接收消息
 *
 * @param message
 */
void receiveMessage2(String message);

修改消费者Service实现类

实现RabbitMQConsumerService类的接口方法receiveMessage2()，添加注解@RabbitListener实现监听，可以监听多个队列，在{}中用 , 隔开多个队列名称即可

1
2
3
4
5
@Override
@RabbitListener(queues = {RabbitMQConfig.DIRECT_QUEUE})
public void receiveMessage2(String message) {
    System.out.println("接收到的消息:" + message);
}

测试

去rabbitmq-consumer模块启动的控制台查看结果，每成功发送消息一次控制台就打印一次，如果原来就有多个消息就会逐个打印完