文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

SpringBoot整合RabbitMQ延迟队列&优先级队列详解

2024-11-30 10:14

关注

这里简单说下步骤:

  1. 创建一个队列,如:bs-queue, 设置死信交换机(死信交换机路由key(这是可选的))及队列,如:dead-exchange; 消息的消费端监听该dead-queue队列。设置消息有效期参数x-message-ttl参数(值为自己需要延迟的时间,单位:毫秒)。
  2. 发送消息发送到bs-queue上。由于消息消费端监听的是死信队列,所以只需要等待指定的时间后消息会自动被转发到死信队列上(dead-queue)。
  3. 消息的消费端监听dead-queu队列即可。

优先级队列

优先级队列是在RabbitMQ3.5.0之后的版本才支持的。

具有高优先级的队列具有高的优先权,优先级高的消息具备优先被消费的特权。

队列的优先级通过x-max-priority参数设置。

建立一个priority-exchange交换机,类型:direct。

图片

建立一个priority-queue队列,并与priority-exchange绑定。

图片

设置x-max-priority参数的值为100,表示最大优先级为100。

注意:x-max-priority参数的值应该介于1到255。建议使用1到10之间的队列。如果设置的优先级更大将使用更多的Erlang进程消耗更多的CPU资源。运行时调度也会受到影响。

接下来演示优先级队列

我们先只发送消息,然后再把消息的消费功能打开。

发送消息接口:

@GetMapping("/sendPriority")
public Object sendPriority(String msg, Integer priority) {
  ms.sendPriorityQueue(msg, priority) ;
  return "success" ;
}
public void sendPriorityQueue(String msg, Integer priority) {
  logger.info("准备发送消息:{}", msg);
  Message message = MessageBuilder.withBody(msg.getBytes()).setPriority(priority).build() ;
  rabbitTemplate.convertAndSend("priority-exchange", "pe.msg", message) ;
}

发送4条消息:

// 第一条消息
msg=第一条消息&priority=2 
// 第二条消息
msg=第二条消息&priority=10
// 第三条消息
msg=第三条消息&priority=1
// 第四条消息
msg=第四条消息&priority=7

查看消息队列:

图片

消息消费端:

@RabbitListener(queues = { "priority-queue" })
@RabbitHandler
public void listenerPriority(Message message, Channel channel) {
  System.out.println("接受到消息.....income");
  byte[] body = message.getBody();
  MessageProperties mps = message.getMessageProperties();
  String content = new String(body, Charset.forName("UTF-8"));
  try {
    System.out.println("接受到消息来自交换机: 【" + mps.getReceivedExchange() + "】, 队列:【" + mps.getConsumerQueue()+ "】:\n内容: " + content);
    channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
  } catch (Exception e) {
    e.printStackTrace();
    try {
      channel.basicReject(mps.getDeliveryTag(), false);
    } catch (IOException e1) {
      e1.printStackTrace() ;
    }
  }
}

启动服务

图片

根据打印出的结果,正好是我们设置优先级的顺序输出。

上面设置的消息优先级都是在指定的范围<100,如果消息的优先级超过这个值会怎么样呢?

发送8条消息:

// 第一条消息
msg=第一条消息&priority=2 
// 第二条消息
msg=第二条消息&priority=10
// 第三条消息
msg=第三条消息&priority=1
// 第四条消息
msg=第四条消息&priority=7
// 第五条消息
msg=第五条消息&priority=101

消费消息:

图片

同样是按照顺序输出的。


来源:Spring全家桶实战案例源码内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯