一种云消息系统及云消息发送和接收方法

摘要

本发明实施例公开了一种云消息系统，包括用户接口模块、云消息协议栈管理模块、云消息队列管理模块、连接池动态维护模块、线程池动态维护模块、云消息分发模块和云消息处理模块，以提供准确及时的用户资源请求的响应，实现云环境下各应用间的通信，同时完成云环境内部相关功能的管理和云消息的管理。利用该系统可实现对用户资源请求响应的优化，能避免单点瓶颈及故障的问题；同时可实现对云环境下各应用间通信的优化，能简化云环境下构建和部署相关应用的程序逻辑，从而系统具有很好的移植性；并可实现对云环境内部相关功能管理的优化，系统具有很好的伸缩性；更进一步地可实现对云消息管理的优化，保证消息能准确及时的被处理，系统具有高可靠性。

主权项

一种云消息系统，其特征在于，所述系统包括：用户接口模块，用于提供用户访问云环境下的资源以及提供云消息发送/接收/处理的接口，所述云消息发送/接收/处理的接口用于云环境下其他应用程序使用；云消息协议栈管理模块，用于配置云消息协议栈，所述云消息协议栈的每层协议都配置有云环境内部相关功能的管理；云消息队列管理模块，用于管理云消息队列，其中，所述云消息队列包括发送消息队列和接收消息队列，且每个云消息具有优先级信息；连接池动态维护模块，用于提供每两个云成员之间的消息传递的可用连接，所述可用连接从所述连接池中选取空闲的可用连接得到；线程池动态维护模块，用于动态增加或减少线程池中的线程，使得所述云消息队列中的云消息能被及时处理；云消息分发模块，用于从所述线程池和连接池中分别选择可用的线程和连接，按消息优先级依次取出发送消息队列中的云消息并发往群组或单个成员；云消息处理模块，用于从所述线程池和连接池中分别选择可用的线程和连接，按消息优先级依次取出接收消息队列中的消息并处理。