在分布式消息系统中实现消息持久化的方法及装置

摘要

本发明提供了在分布式消息系统中实现消息持久化的方法及装置，其中的一个方法包括：获取需要发布和/或订阅的消息所属的类信息和逻辑分区信息；根据类信息和逻辑分区信息确定消息对应的物理条所在的消息存储节点信息，并传输给消息发布方和/或消息订阅方，以便于消息发布方和/或消息订阅方向消息存储节点发布和/或订阅消息；其中，属于同一类的消息持久化存储于一个消息队列中，一个消息队列分布于至少一个逻辑分区中，一个逻辑分区分布于至少一个物理条中，一个物理条位于一个消息存储节点中，且属于同一个逻辑分区的所有物理条位于至少一个消息存储节点中。本发明提高了分布式消息系统的灵活性以及健壮性，并降低了消息发布/订阅的延时。