RabbitMQ的Java客户端-EW帮帮网

快速入门

这里省去了交换机，让入门案例变得更简单。

编写好监听类之后启动springboot项目就能监听消息队列了。值得注意的是，这里的方法形参中的String msg的String要和第三步的message的类型一致。第三步中的message可以是User类型，但第四步方法形参的msg也要是User类型，Spring会自动完成对象和消息之间的转换。

Work Queues

@Component
@Slf4j
public class SpringRabbitListener {

//    @RabbitListener(queues = "simple.queue")
//    public void listenSimpleQueue(String message) {
//        log.info("监听到simple.queue的消息:{}", message);
//    }

    @RabbitListener(queues = "work.queue")
    public void listenWorkQueue1(String message) {
        System.out.println("消费者1接收到消息:" + message + "," + LocalTime.now());
    }

    @RabbitListener(queues = "work.queue")
    public void listenWorkQueue2(String message) {
        System.err.println("消费者2.....接收到消息:" + message + "," + LocalTime.now());
    }
}

这是添加两个消费者的代码，可以看到是一个方法就是一个消费者。System.err.println打印出来是红色的，可以和sout区分开。然后编写发送50条数据（带编号）给消息队列的代码，比较简单就不贴出来了。运行之后发现，两个消费者各得到一半的消息，而且消费者2处理的是奇数数据，消费者1处理的是偶数数据。所以，队列中同一个消息只能被一个消费者处理。其次，如果有多个消费者，会通过轮询的方式平均交给消费者处理。

这个是consumer的配置，添加这个设置之后呢，就避免了之前”我管你处理没处理完，我就是给你分配消息“的问题。因为只有这个消费者处理完一条消息了，消息队列才能给这个消费者分配下一条数据。这样的话，处理慢的消费者就会被分配较少的消息，从而实现“能者多劳”。

Fanout交换机

Fanout Exchange会将接收到的消息路由到每一个与其绑定的queue上，所以也叫广播模式。通过Fanout Exchange，就实现了发送者发送一个消息，多个消费者都能处理同一个消息的功能。

指定交换机的名称和类型。

@RabbitListener(queues = "fanout.queue1")
public void listenFanoutQueue1(String message) {
    log.info("消费者1监听到fanout.queue1的消息:{}", message);
}

@RabbitListener(queues = "fanout.queue2")
public void listenSimpleQueue2(String message) {
    log.info("消费者2监听到fanout.queue2的消息:{}", message);
}

这是两个消费者监听不同队列。