RabbitMQ（二）生产消费

RabbitMQ（二）生产消费 复习 pom依赖

	
		com.rabbitmq
		amqp-client
		5.14.0
	
	
		commons-io
		commons-io
		2.6
	

mq工具类

public class RabbitUtil {
	public static Channel getConn() throws Exception {
		ConnectionFactory cf = new ConnectionFactory();
		cf.setHost("localhost");
		cf.setUsername("guest");
		cf.setPassword("guest");
		return cf.newConnection().createChannel();
	}
}

通道获取与关闭

获取

Channel channel = RabbitUtil.getConn();

关闭

channel.getConnection().close();

生产者

//获取通道
Channel channel = RabbitUtil.getConn();
//声明队列
channel.queueDeclare("q", false, false, false, null);
//简单发送：1-10
for (int i = 1; i <= 10; i++) {
	channel.basicPublish("", "q", null, (i + "").getBytes());
}
//关闭
channel.getConnection().close();

API

queueDeclare

1. 队列名
2. 是否持久化
3. 是否多消费者
4. 是否自动删除
5. 其他参数

basicPublish

1. 目标交换机
2. 路由键 || 队列名
3. 其他参数
4. 消息数据

测试

发送了十条数据

消费者

//获取通道
Channel channel = RabbitUtil.getConn();

//声明回调
DeliverCallback deliver = (consumerTag, message) -> {
	System.out.println(new String(message.getBody()));
};
CancelCallback cancel = consumerTag -> {
	System.out.println("取消了");
};
//消费消息
channel.basicConsume("q", true, deliver, cancel);

API

basicConsume

1. 队列名称
2. 是否自动回复
3. 接收回调
4. 取消回调

单个消费者挨个处理

控制台输出了，队列中的数据也被消费一空。

多消费者轮流处理

开启IDEA运行设置
一个生产者，两个消费者：

不难猜到，默认是轮询

运行流程