一种云消息服务中实现消息传递的方法和装置

摘要

本发明实施例提供一种云消息服务中实现消息传递的方法和设备，该方法包括：接收第一分布式程序发送的消息，在分布式Key-Value存储系统中存储所述消息携带的消息数据，并递增所述消息对应的消息队列的发送消息序列号；接收第二分布式程序读取消息数据的请求，在所述分布式Key-Value存储系统中读取所述消息数据，将读取的所述消息数据发送给所述第二分布式程序，并在所述消息数据为所述消息队列的接收消息序列号对应的消息数据时，递增所述消息队列的接收消息序列号。本发明实施例通过为消息队列设置发送消息序列号和接收消息序列号，当第一分布式程序发送消息数据时，云消息服务设备按照消息队列的发送消息序列号在分布式Key-Value存储系统中存储接收到的消息数据，并递增修改发送消息序列号；当第二分布式程序请求接收消息数据时，云消息服务设备按照消息队列的接收消息序列号读取消息数据，并递增修改接收消息序列号。从而实现了云消息服务的高可用性和伸缩性要求，同时又保障了消息传递的顺序保证。