SimpleConsumer.changeInvisibleDuration似乎有点问题？

[bugCats]

服务端：rocketMQ 5.1.1
客户端：rocketmq-client-java 5.0.5

自己打算基于SimpleConsumer封装一个通用方法，程序可以自动调用changeInvisibleDuration延长消息不可见时间。但是测试过程中，changeInvisibleDuration并不能总是生效。

首先使用SimpleConsumer.receive批量获取消息集合，计算出消息的最终不可见时间；
然后使用线程池异步消费这些消息。

另外还有个监测线程，每隔1秒检查消息集合中元素，如果当前时间临近消息的不可见时间，就会调用SimpleConsumer.changeInvisibleDuration再次续上时间，重复此步骤。

这是打印的日志：

[1] 2023-05-26 12:24:26:=>15
[2] 截止时间：2023-05-26 12:24:41
[3] 2023-05-26 12:24:28: =>[322]017032178E9BB750E80481CE760000000C {"uid":12}
[4] 2023-05-26 12:24:29: =>[320]017032178E9BB750E80481CE760000000A {"uid":10}
[5] 2023-05-26 12:24:29: =>[321]017032178E9BB750E80481CE7600000005 {"uid":5}
[6] 2023-05-26 12:24:31: =>[321]017032178E9BB750E80481CE7600000006 {"uid":6}
[7] 2023-05-26 12:24:35: =>[320]017032178E9BB750E80481CE7600000003 {"uid":3}
[8] 2023-05-26 12:24:35: =>[322]017032178E9BB750E80481CE7600000002 {"uid":2}
[9] 2023-05-26 12:24:37: =>[321]017032178E9BB750E80481CE760000000B {"uid":11}

[10] [id=017032178E9BB750E80481CE760000000A] done.
[11] [id=017032178E9BB750E80481CE7600000005] done.
[12] [id=017032178E9BB750E80481CE760000000C] done.
[13] [id=017032178E9BB750E80481CE7600000002] done.
[14] [id=017032178E9BB750E80481CE7600000003] done.
[15] [id=017032178E9BB750E80481CE7600000006] done.
[16] [id=017032178E9BB750E80481CE760000000B] done.
[17] [id=017032178E9BB750E80481CE7600000004]续期，当前时间：2023-05-26 12:24:38；续期时间：2023-05-26 12:24:56
[18] [id=017032178E9BB750E80481CE7600000008]续期，当前时间：2023-05-26 12:24:38；续期时间：2023-05-26 12:24:56
[19] [id=017032178E9BB750E80481CE7500000000]续期，当前时间：2023-05-26 12:24:38；续期时间：2023-05-26 12:24:56
[20] [id=017032178E9BB750E80481CE760000000E]续期，当前时间：2023-05-26 12:24:38；续期时间：2023-05-26 12:24:56
[21] [id=017032178E9BB750E80481CE7600000007]续期，当前时间：2023-05-26 12:24:38；续期时间：2023-05-26 12:24:56
[22] [id=017032178E9BB750E80481CE7600000009]续期，当前时间：2023-05-26 12:24:38；续期时间：2023-05-26 12:24:56
[23] [id=017032178E9BB750E80481CE7600000001]续期，当前时间：2023-05-26 12:24:38；续期时间：2023-05-26 12:24:56
[24] [id=017032178E9BB750E80481CE760000000D]续期，当前时间：2023-05-26 12:24:38；续期时间：2023-05-26 12:24:56
[25] 续期检查结束：2023-05-26 12:24:38
 
[26] 2023-05-26 12:24:40: =>[322]017032178E9BB750E80481CE7600000008 {"uid":8}
[27] 2023-05-26 12:24:41: =>[320]017032178E9BB750E80481CE7600000004 {"uid":4}
[28] 2023-05-26 12:24:42: =>[321]017032178E9BB750E80481CE7500000000 {"uid":0}
[29] 2023-05-26 12:24:44: =>[322]017032178E9BB750E80481CE760000000E {"uid":14}
[30] 2023-05-26 12:24:45: =>[321]017032178E9BB750E80481CE7600000009 {"uid":9}
[31] 2023-05-26 12:24:46: =>[320]017032178E9BB750E80481CE7600000007 {"uid":7}
[32] 2023-05-26 12:24:48: =>[321]017032178E9BB750E80481CE760000000D {"uid":13}
[33] 2023-05-26 12:24:48: =>[322]017032178E9BB750E80481CE7600000001 {"uid":1}

[34] 2023-05-26 12:24:59:=>2
[35] 截止时间：2023-05-26 12:25:14
[36] 2023-05-26 12:25:01: =>[321]017032178E9BB750E80481CE760000000E {"uid":14}
[37] 2023-05-26 12:25:02: =>[320]017032178E9BB750E80481CE7600000008 {"uid":8}

[1]是获取到消息的时间与数量，共15条；
[2] 12:24:41 是消息最终不可见时间；（设置时间15s）
[3]~[9]消费消息；

[10]~[25]监测线程打印。其中[17]~[24]检查出来，需要续期，续期后的不可见时间为：12:24:56。
[25]监测线程结束时间：12:24:38，明显小于[2]-12:24:41，也就是说此时[17]~[24]未超时未提交消费状态。

[26]~[33] 消息正式消费；消费时间，小于续期之后的 12:24:56；

[34]~[37]第二轮开始，但是仍然获取到[29]、[26]这2条消息。

如果续期失败，第二轮应该会再次获取[28]~[33]6条消息，但是实际上第二轮只有2条。
感觉changeInvisibleDuration有用，但是又没完全有用。

[cserwen]

changeInvisibleDuration 并不是修改当前获取到的消息的到期时间，而是将这一批消息认为消费失败，经过不可见时间（15s）后再次对消费者可见，实际上在你续期操作的15s后，这些消息应该就能被再次拉到了

[bugCats]

在正常消费消息之后，会马上执行SimpleConsumer.ack提交消费状态。

监测线程会在第13秒的时候，把[17]~[24]消息的不可见时间重置为15s；

我理解是，在[26]~[33]这里，正常消费之后执行SimpleConsumer.ack提交消费状态，应该是算消费成功，不应该再次对消费者可见。
simpleconsumer消费重试策略

[cserwen]

ack此时已经没有效果了，因为你执行了changeInvisibleDuration，旧的消息实际上已经被ack了，服务端重新生产了一条记录（ck）去标记重新消费，ack操作无法对这条记录生效

[bugCats]

这样的话，似乎无法实现在运行过程中自动延长消息不可见时间的功能？

[cserwen]

嗯，消息不可见时间是预分配的，分配好了这次拉取的消息就无法更改了，但是可以修改下次消费的，这个需求的目的是什么？避免频繁因超时而消费失败吗，实际上消费逻辑增加个幂等逻辑即可，同时根据业务情况设置合理的不可见时间，尽量降低消费超时出现的概率

[bugCats]

消息产生之后，需要调第三方系统http接口，把数据传给对方。但是第三方系统的性能堪忧，http设置30秒都可能超时。
所以希望可以根据消息的实际消费情况，控制超时时间，避免大量重复消费的情况。