1.simple简单模式
一个生产者一个消费者
无需交换机，RabbitMQ会通过默认的交换机将消息投递到指定的队列，这是一种Direct类型的交换机，队列与它绑定时的binding key就是队列的名称
2.work模式
一个生产者，多个消费者
多个消费者监听同一个队列
消费者1：
public class Recv { private final static String QUEUE_NAME = "test_queue_work"; public static void main(String[] argv) throws Exception { // 获取到连接以及mq通道 Connection connection = ConnectionUtil.getConnection(); Channel channel = connection.createChannel(); // 声明队列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 同一时刻服务器只会发一条消息给消费者 //channel.basicQos(1); // 定义队列的消费者 QueueingConsumer consumer = new QueueingConsumer(channel); // 监听队列，false表示手动返回完成状态，true表示自动 channel.basicConsume(QUEUE_NAME, true, consumer); // 获取消息 while (true) { QueueingConsumer.Delivery delivery = consumer.nextDelivery(); String message = new String(delivery.getBody()); System.out.println(" [y] Received '" + message + "'"); //休眠 Thread.sleep(10); // 返回确认状态，注释掉表示使用自动确认模式 //channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false); } } }
消费者2：
public class Recv2 { private final static String QUEUE_NAME = "test_queue_work"; public static void main(String[] argv) throws Exception { // 获取到连接以及mq通道 Connection connection = ConnectionUtil.getConnection(); Channel channel = connection.createChannel(); // 声明队列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); // 同一时刻服务器只会发一条消息给消费者 //channel.basicQos(1); // 定义队列的消费者 QueueingConsumer consumer = new QueueingConsumer(channel); // 监听队列，false表示手动返回完成状态，true表示自动 channel.basicConsume(QUEUE_NAME, true, consumer); // 获取消息 while (true) { QueueingConsumer.Delivery delivery = consumer.nextDelivery(); String message = new String(delivery.getBody()); System.out.println(" [x] Received '" + message + "'"); // 休眠1秒 Thread.sleep(1000); //下面这行注释掉表示使用自动确认模式 //channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false); } } }
生产者，生产100条消息
public class Send { private final static String QUEUE_NAME = "test_queue_work"; public static void main(String[] argv) throws Exception { // 获取到连接以及mq通道 Connection connection = ConnectionUtil.getConnection(); Channel channel = connection.createChannel(); // 声明队列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); for (int i = 0; i < 100; i++) { // 消息内容 String message = "" + i; channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); System.out.println(" [x] Sent '" + message + "'"); Thread.sleep(i * 10); } channel.close(); connection.close(); } }
结果：一个消息只能被消费一次，Recv1消费的是基数消息，Recv2消费的是偶数消息
存在问题：
Recv1线程停顿的时间短，应该消费更多的消息，RabbitMQ默认将消息顺序发送给下一个消费者，这样，每个消费者消费的消息都是一样的，轮询分发消息
如何按照消费者的能力分配消息：联合使用Qos和Acknowledge，basicQos方法设置了当前信道最大欲获取(prefetch)消息数量为1，消息从队列异步推送给消费者，消费者的ack也是异步发送给队列，从队列的角度看，总由一批消息已近推送但是未收到ack确认，Qos的prefetchCount参数就是用来限制这批未确认消息数量的，设置为1的时候，队列只有再消费者发回的上一条消息ack确认之后才会继续推送消息，prefetchCount的默认值是0，所以会一直推送消息
轮询分发
默认情况下，RabbitMQ将逐个发送消息给在序列的下一个消费者，不考虑任务的时长，一次性分配，一个一个按序分配
公平分发
轮询的时候，可能所有的奇数都是很复杂的消息，偶数是简单的消息，这样对消费者的待遇不公平，引入公平分发，使用BasicQos(prefetchCount = 1)方法，限制队列只发一条消息给同一个消费者，只有收到ack确认之后再发送第二次，使用公平分发，必须关闭自动应答，改为手动应当
2.1消息的确认模式
队列推送消息如何知道消息成功被消费了
模式1：自动确认，推送之后，无论是否什么结果都判定为成功消费
模式2：手动确认，推送之后，队列将消息标记为不可用状态，如果一直没有反馈，该消息一直处于不可用状态
3.Publish/Subscribe发布订阅模式
1个生产者，多个消费者
每个消费者都有自己的队列
生产者将消息发到交换机
每个队列都绑定交换机
生产者发送的消息经过交换机到达队列，一个消息可以被多个消费者消费
注意：一个消费者队列可以有多个消费者实例，但是只有一个消费者实例会消费，消费发送到交换机后消息会消失，因为交换机只能转发消息，没有存储功能
4.Routing路由模式
路由模式下，对应使用的交换机是Direct交换机，生产者发送消息时需要指定routing key(和发布订阅模式的区别)，交换机会根据routing key将消息投递到指定的队列
5.Topic主题模式
Topic主题模式采用的是Topic类型的交换机，因此是支持模糊匹配，消息能被投递到一个或多个队列中。生产者发送消息时指定routing key，Topic类型的交换机会根据routing key找到所有符合队列与交换机绑定时指定的binding key规则的队列，并将消息投递到那些队列中。
