RabbitMQ java API

Posted 2022-03-16 向天再借500年V

RabbitMQ java API

队列持久化

# 生成一个队列 1、队列名称 2、队列里面的消息是否进行持久化 3、是否共享消息 4、是否自动删除 5、其他高级参
channel.queueDeclare(QUEUE_NAME, true, false, false, null);

消息持久化

# 发送一个消息 1、发送到哪个交换机 2、路由的key 3、其他的参数信息 4、发送消息内容
# 参数3：设置消息持久化
channel.basicPublish("", QUEUE_NAME, MessageProperties.PERSISTENT_TEXT_PLAIN,msg.getBytes("UTF-8"));

不公平分发（能力越大责任越大，多劳多得）

# 消费者代码处增加
channel.basicQos(1);