如果因某bug导致连续一段消息的丢失,仅依靠最后一条消息的“前趋”拿不到完整的消息链。 是否由“定序服务”将每个消息的前驱消息id持久化到DB中去,在“撮和服务”中递归向前拿消息,拿到序号对得上为止。 这样“撮和”服务还需要持久化当前处理到的消息id,将当前消息id和订单状态更新打包到一个事务中去。 是有些复杂。。
Sign in to make a reply
用户8851712173
如果因某bug导致连续一段消息的丢失,仅依靠最后一条消息的“前趋”拿不到完整的消息链。 是否由“定序服务”将每个消息的前驱消息id持久化到DB中去,在“撮和服务”中递归向前拿消息,拿到序号对得上为止。 这样“撮和”服务还需要持久化当前处理到的消息id,将当前消息id和订单状态更新打包到一个事务中去。 是有些复杂。。