备案控制台

游客rppje7k3ul2sc_个人页

个人头像照片 游客rppje7k3ul2sc
个人头像照片
文章
0
问答
1
视频
0

个人介绍

暂无个人介绍

擅长的技术

  • 数据库
获得更多能力
通用技术能力：

暂时未有相关通用技术能力~

云产品技术能力：

暂时未有相关云产品技术能力~

阿里云技能认证

详细说明
暂无更多信息

2021年09月

正在加载, 请稍后...
暂无更多信息
  • 回答了问题 2021-09-10

    RocketMQ消息重复消费（同一条消息2毫秒内分别在两台机器上被消费）

    我问题已解决，就是楼上说的instanceName 的原因，可以把mq客户端rocketmq-spring-boot-starter升级到最新版本，我目前最新版是2.2.1，见org.apache.rocketmq.spring.support.RocketMQUtil.getInstanceName()的方法，在254行处，如下，就解决了重复消费问题

    public static String getInstanceName(String identify) { char separator = '@'; StringBuilder instanceName = new StringBuilder(); instanceName.append(identify).append(separator).append(UtilAll.getPid()).append(separator).append(System.nanoTime()); return instanceName.toString(); }

    踩0 评论0
正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息