一种消息处理方法、系统及消息生产者集群.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN108076103A(43)申请公布日2018.05.25(21)申请号201611020095.9(22)申请日2016.11.18(71)申请人北京优朋普乐科技有限公司地址100123北京市朝阳区高碑店高井文化园8号东亿国际传媒产业园三期B座6层(72)发明人张彦忠(74)专利代理机构北京同达信恒知识产权代理有限公司11291代理人黄志华(51)Int.Cl.H04L29/08(2006.01)权利要求书2页说明书6页附图3页(54)发明名称一种消息处理方法、系统及消息生产者集群(57)摘要本申请涉及消息处理技术领域，公开了一种消息处理方法、系统及消息生产者集群，用以提高消息处理能力。该方法为：消息生产者集群生产第一消息，并在缓存节点集群中按照设定路由方式确定所述第一消息的待缓存节点；所述消息生产者集群在确定所述待缓存节点中不存在与所述第一消息相同的第二消息时，向消息队列集群发送所述第一消息，所述第一消息用于所述消息队列集群对外提供订阅服务。CN108076103ACN108076103A权利要求书1/2页1.一种消息处理方法，其特征在于，包括：消息生产者集群生产第一消息，并在缓存节点集群中按照设定路由方式确定所述第一消息的待缓存节点；所述消息生产者集群判断所述待缓存节点中是否存在与所述第一消息相同的第二消息，在确定所述待缓存节点中不存在与所述第一消息相同的第二消息时，向消息队列集群发送所述第一消息，所述第一消息用于所述消息队列集群对外提供订阅服务。2.如权利要求1所述的方法，其特征在于，所述消息生产者集群按照设定路由方式确定所述第一消息的待缓存节点，包括：所述消息生产者集群按照所述缓存节点集群中缓存节点的数量为各个缓存节点顺序编号；所述消息生产者集群获取所述第一消息的唯一标识，确定所述唯一标识对应的数值，将所述数值对所述缓存节点集群中缓存节点的数量值进行取余计算，获得余数；所述消息生产者集群将编号为所述余数的缓存节点确定为所述第一消息的待缓存节点。3.如权利要求2所述的方法，其特征在于，所述消息生产者集群确定所述唯一标识对应的数值，包括：所述消息生产者集群根据哈希算法，确定所述唯一标识对应的数值。4.如权利要求1所述的方法，其特征在于，所述消息生产者集群在确定所述待缓存节点中不存在与所述第一消息相同的第二消息时，还包括：所述消息生产者集群将所述第一消息的相关信息缓存在所述待缓存节点。5.如权利要求1～4任一项所述的方法，其特征在于，所述方法还包括：所述消息生产者集群在确定所述待缓存节点中存在与所述第一消息相同的第二消息时，丢弃所述第一消息。6.一种消息生产者集群，其特征在于，所述消息生产者集群中包括至少一个消息生产者，任一消息生产者包括：生产单元，用于生产第一消息；路由单元，用于在缓存节点集群中按照设定路由方式确定所述生产单元生产的所述第一消息的待缓存节点；确定单元，用于确定所述待缓存节点中是否存在与所述第一消息相同的第二消息，所述第一消息用于所述消息队列集群对外提供订阅服务；发送单元，用于在所述确定单元确定所述待缓存节点中不存在与所述第一消息相同的第二消息时，向消息队列集群发送所述第一消息。7.如权利要求6所述的消息生产者集群，其特征在于，所述路由单元具体用于：按照所述缓存节点集群中缓存节点的数量为各个缓存节点顺序编号；获取所述第一消息的唯一标识，确定所述唯一标识对应的数值，将所述数值对所述缓存节点集群中缓存节点的数量值进行取余计算，获得余数；将编号为所述余数的缓存节点确定为所述第一消息的待缓存节点。8.如权利要求7所述的消息生产者集群，其特征在于，所述路由单元具体用于：根据哈希算法，确定所述唯一标识对应的数值。2CN108076103A权利要求书2/2页9.如权利要求6所述的消息生产者集群，其特征在于，所述确定单元还用于：在确定所述待缓存节点中存在与所述第一消息相同的第二消息时，丢弃所述第一消息。10.一种消息处理系统，其特征在于，包括如权利要求6～10任一项所述的消息生产者集群、缓存节点集群、消息队列集群和消费者集群；所述消息生产者集群中包括至少一个消息生产者，所述缓存节点集群包括至少一个缓存节点，所述消息队列集群中包括至少一个服务器，所述消费者集群中包括至少一个消费者；每个消息生产者用于向所述至少一个服务器提交消息，每个消费者用于向所述至少一个服务器订阅消息；所述缓存节点集群，与所述消息生产者集群相连，用于所述消息生产者在向所述至少一个服务器提交消息之前，对待提交的消息进行过滤处理。3CN108076103A说明书1/6页一种消息处理方法、系统及消息生产者集群技术领域[0001]本申请涉及消息处理技术领域，特别涉及一种消息处理方法、系统