问题明细:在springboot中使用syncSendDelayTimeMills方法发送延时消息,消费者端直接消费并没有延时。
问题原因: rocketMQ安装客户端版本与springboot使用的jar包版本不一致导致
问题解决:
1.回退Jar包(不推荐,要改动代码,不同版本方法参数以及名称都不一样)
2.重装rocketMQ

上面是总结 下面记录我解决的过程:

1.重装rocketMQ

安装推荐 5.1安装教程.如果使用docker进行安装的话,要使用下面命令

docker pull docker.io/apache/rocketmq:5.1.0

但是不知道为什么,安装4.x版本的速度特别快,安装5.x就会非常慢,所以我选择直接在虚拟机安装

2.定义jar包

            <dependency>
                <groupId>org.apache.rocketmq</groupId>
                <artifactId>rocketmq-spring-boot-starter</artifactId>
                <version>2.2.3</version>
            </dependency>

2.2.3对应的rocketMQ版本可以从左边的加载目录看,可以发现2.2.3对应的是5.0.0 虽然我装的是5.1.0但是并不冲突,之前安装的4.x会冲突
在这里插入图片描述
在这里插入图片描述

3.测试发送和接收

  @GetMapping("/sendDelay")
  public SendStatus sendDelay() {
    SendResult result=rocketmqTemplate.syncSendDelayTimeMills("x_topic_1", LocalDateTime.now().format(DateTimeFormatter.ofPattern("消息发送时间:yyyy-MM-dd HH:mm:ss")),200000);
    return  result.getSendStatus();
  }
    @Override
    public void onMessage(String message) {
        // 处理消息的逻辑
        System.out.println("consumer_1  收到消息: " + message + LocalDateTime.now().format(DateTimeFormatter.ofPattern("  消息接收时间:yyyy-MM-dd HH:mm:ss")));
    }

在这里插入图片描述
成功延时,一开始以为是配置出了问题,后面尝试发现docker默认pull的lasted版本竟然是4.5不是5.0的,导致我一直以为我用的是最新版本没找到问题,后面看到控制台显示的4.5才去查了docker里mq版本,这波是被docker坑了,以为docker默认只下载最新的。

Logo

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。

更多推荐