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

Question

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

Answer 1

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