基于RPC应用程序推送订阅消息的方法以及装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN110417646A(43)申请公布日2019.11.05(21)申请号201910710338.9(22)申请日2019.08.01(71)申请人北京吉旗咨询服务有限公司地址100089北京市海淀区建材城中路27号8幢二层203号(72)发明人黄凯闵早华(74)专利代理机构北京棘龙知识产权代理有限公司11740代理人戴丽伟(51)Int.Cl.H04L12/58(2006.01)权利要求书2页说明书6页附图3页(54)发明名称基于RPC应用程序推送订阅消息的方法以及装置(57)摘要本申请公开了一种基于RPC应用程序推送订阅消息的方法以及装置。该方法包括消息服务拉取消息中间件中的订阅消息，轮询订阅消息并且在有新消息时获取客户端列表，以使在包装消息服务后，统一处理消息并推送至相关客户端。本申请解决了订阅消息接入复杂度的技术问题。通过本申请实现了接入消息中间件的灵活配置、打通服务之间的消息通道。CN110417646ACN110417646A权利要求书1/2页1.一种基于RPC应用程序推送订阅消息的方法，其特征在于，包括：消息服务拉取消息中间件中的订阅消息，轮询订阅消息并且在有新消息时获取客户端列表，以使在包装消息服务后，统一处理消息并推送至相关客户端。2.根据权利要求1所述的基于RPC应用程序推送订阅消息的方法，其特征在于，消息服务拉取消息中间件中的订阅消息，轮询订阅消息并且在有新消息时获取客户端列表包括：订阅消息推送的步骤，所述订阅消息推送的步骤包括：根据客户端订阅配置，从消息中间件订阅消息；消息服务收到消息后，从Redis数据库中获取客户端集群信息；使用Dubbo集群调用功能，将消息推送至指定服务集群，如果服务消费成功，则标记消息处理成功；如果服务消费失败，则等待重新推送，直到成功为止。3.根据权利要求1所述的基于RPC应用程序推送订阅消息的方法，其特征在于，消息服务拉取消息中间件中的订阅消息，轮询订阅消息并且在有新消息时获取客户端列表包括：断线重连的步骤，所述断线重连的步骤包括：如果客户端网络异常导致离线时，通过监听注册中心离线事件并标记服务离线；如果络异常恢复，客户端重新上线后，通过监听注册中心上线事件，并从Redis中获取信息重新注册后服务恢复。4.根据权利要求1所述的基于RPC应用程序推送订阅消息的方法，其特征在于，消息服务拉取消息中间件中的订阅消息，轮询订阅消息并且在有新消息时获取客户端列表包括：发送消息的步骤，所述发送消息的步骤包括：提供发送消息接口，接收客户端向指定通道发送消息，并将消息存入消息中间件；将消息推送至订阅服务。5.根据权利要求1所述的基于RPC应用程序推送订阅消息的方法，其特征在于，消息服务拉取消息中间件中的订阅消息，轮询订阅消息并且在有新消息时获取客户端列表，之后还包括：判断客户端的数量是否为零；如果判断客户端的数量为零，则客户端离线停止推送；如果判断客户端的数量不为零，则继续推送订阅消息。6.一种基于RPC应用程序推送订阅消息的装置，其特征在于，包括：推送模块，用于在消息服务拉取消息中间件中的订阅消息，轮询订阅消息并且在有新消息时获取客户端列表，以使在包装消息服务后，统一处理消息并推送至相关客户端。7.根据权利要求6所述的基于RPC应用程序推送订阅消息的装置，其特征在于，所述推送模块，用于根据客户端订阅配置，从消息中间件订阅消息；消息服务收到消息后，从Redis数据库中获取客户端集群信息；使用Dubbo集群调用功能，将消息推送至指定服务集群，如果服务消费成功，则标记消息处理成功；如果服务消费失败，则等待重新推送，直到成功为止。2CN110417646A权利要求书2/2页8.根据权利要求6所述的基于RPC应用程序推送订阅消息的装置，其特征在于，所述推送模块，用于如果客户端网络异常导致离线时，通过监听注册中心离线事件并标记服务离线；如果络异常恢复，客户端重新上线后，通过监听注册中心上线事件，并从Redis中获取信息重新注册后服务恢复。9.根据权利要求6所述的基于RPC应用程序推送订阅消息的装置，其特征在于，所述推送模块，用于提供发送消息接口，接收客户端向指定通道发送消息，并将消息存入消息中间件；将消息推送至订阅服务。10.根据权利要求6所述的基于RPC应用程序推送订阅消息的装置，其特征在于，所述推送模块，用于判断客户端的数量是否为零；如果判断客户端的数量为零，则客户端离线停止推送；如果判断客户端的数量不为零，则继续推送订阅消息。3CN110417646A说明书1/6页基于RPC应用程序推送订阅消息的方法以及装置技术领域[0001]本申请涉及微服务架构领域，具体而言，涉及一种基于RPC应用程序推送订阅消息的方法以及装置。背