| 主权项 |
一种跨开放平台社交消息优化计算的订阅推送引擎，其特征在于联接于业务系统和社交开发平台两者之间，实现业务系统和开放平台之间的用户社交消息的互联互通，在这基础上实现用户关注消息的个性化定制的订阅推送服务；业务系统业务模块的社交化需求，其需要关注的社交消息可能牵涉到多个社交平台，不同社交平台消息存储以及获取方式不同，并且还分别处于不同类型的开放系统中，本订阅引擎处在业务角度上考虑，引入一种内联所有开放平台的机制为业务系统业务模块屏蔽开放平台的差异，业务系统业务模块的信息与社交信息的互联互通，体现透明性特点；包括社交信息订阅规则采集、订阅规则解析计算、结果异步推送三部分，其中这三部分涉及的对接交互的系统包括有内部业务服务系统、公网的社交开放平台；其中客户端接入部分包括多个业务系统或者业务模块；开放平台部分包括适配多个不同类型的开放平台；引擎部分通过公共IP网或者内部网与客户端接入部分连接；引擎部分通过公共IP网与适配的开放平台部分连接；所述第一部分社交信息订阅规则采集，用于：接收业务系统中各个服务模块的社交信息订阅需求，同时处理多个业务系统并多个模块中的请求，不需要阻塞引擎系统，引擎根据上下文环境将请求数据以自描述的XML结构封装元数据和请求数据成订阅规则数据包，使其不必依赖静态定于的服务接口和数据结构，订阅规则数据包以队列形式存储并排队等候处理；所述第二部分订阅规则解析计算，用于：对第一步中收集的订阅请求进行跨开放平台的关联解析，订阅规则一般包括业务系统或者业务模块的社交信息需求，以XML格式封装起来，按照解析器所认知的约定规则格式。引擎内有一个集中式全局统筹的调度器，负责从第一步中采集的订阅规则数据队列中提取数据集，对规则数据按不同开放平台连接目标进行分拆和合并，再分发到开放平台类型相同的解析器解析执行，最后在集中式全局解析器中统筹合并结果，并存放到订阅结果队列中待推送；所述第三部分结果异步推送，用于：订阅请求经过解析器解析计算后存放在结果存储结构中，由统一集中的推送器将结果回推给业务系统，其中回推使 用回推策略包括有主动推送和储存待拉两种策略，灵活地化解业务系统接收超时致使消息堵塞。 |
