首页 > 基于发布-订阅模式的即时通信如何处理消息必须到达这种情况?

基于发布-订阅模式的即时通信如何处理消息必须到达这种情况?

我是基于发布-订阅模式, 消息来了直接丢消息队列中, 然后开另外线程去处理。
目前已经实现了消息的发送。
但是,我需要每个收到消息的客户端回个ack。 1. 指定时间后再发一遍给没回ack的客户端
这个该如何考虑?2. 以及那些订阅了主题暂时不在线的订阅者, 如何处理? 3.另外有位大哥告诉我,你消息放消息队列里会被覆盖即丢失了,我不太理解。
请大家帮忙看看, 先谢过了


1、指定时间后再发一遍给没回ack的客户端,这个需要消息去重的处理
2、那些订阅了主题暂时不在线的订阅者,这个看需求,如果需要下次在线也能收到消息,则需要暂存消息一段时间,过期再丢掉
3、消息放队列会丢失,这个看队列大小限制

【热门文章】
【热门文章】