zxcvbnm3057 opened a new issue #3272: URL: https://github.com/apache/rocketmq/issues/3272
遇到一个需求,消费者接收消息后使用netty向客户端发送数据,根据回执判断是否消费成功,现想出种解决办法 1. 全局维护一个HashMap,以消息id为键,是否需要消费为值,consumer接收消息先查询HashMap判断是否需要消费,若仍不能返回已消费,调用netty发送给客户端并返回`RECONSUME_LATER `,获取客户端回执后存入HashMap,下次consumer查询再进行判断(多线程HashMap加锁性能下降,多次重发消息影响rocketmq性能) 2. 直接返回`RECONSUME_LATER`多次推送,不考虑客户端回执(网络压力大,多次重发消息影响rocketmq性能) 3. 获取客户端回执后以某种方式通知consumer,或者直接向broker发送消息标注消息已被消费(不知道是否可以实现) 请问这种需求使用rocketmq是否可以实现呢,谢谢 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
