一种集群切换方法、装置、终端及存储介质.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115756855A(43)申请公布日2023.03.07(21)申请号202211477039.3(22)申请日2022.11.23(71)申请人北京沃东天骏信息技术有限公司地址100176北京市大兴区北京经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东世纪贸易有限公司(72)发明人卢杰胡晓花(74)专利代理机构北京品源专利代理有限公司11332专利代理师初春(51)Int.Cl.G06F9/50(2006.01)G06F9/54(2006.01)G06F15/16(2006.01)权利要求书3页说明书17页附图8页(54)发明名称一种集群切换方法、装置、终端及存储介质(57)摘要本发明实施例公开了一种集群切换方法、装置、终端及存储介质。该方法应用生产服务端，该生产客户端当前连接在切换前集群上，且与切换后集群下的目标主题对应，该方法包括：响应于集群切换事件，获取切换后集群的节点集合，从节点集合中获取元数据请求节点，并将元数据请求发送至元数据请求节点上；接收元数据请求节点针对元数据请求返回的元数据，该元数据用于表示节点集合中位于目标主题下的各个主题节点的信息；基于元数据从各个主题节点中确定当前服务节点，并连接到当前服务节点上，以从切换前集群切换连接到切换后集群上。本发明实施例的技术方案，可以在无需重启客户端的情况下，实现生产客户端的自动化集群切换过程。CN115756855ACN115756855A权利要求书1/3页1.一种集群切换方法，其特征在于，应用于生产客户端，所述生产客户端当前连接在切换前集群上，且与切换后集群下的目标主题对应，所述方法包括：响应于集群切换事件，获取所述切换后集群的节点集合，从所述节点集合中获取元数据请求节点，并将元数据请求发送至所述元数据请求节点上；接收所述元数据请求节点针对所述元数据请求返回的元数据，其中，所述元数据用于表示所述节点集合中位于所述目标主题下的各个主题节点的信息；基于所述元数据从所述各个主题节点中确定当前服务节点，并连接到所述当前服务节点上，以从所述切换前集群切换连接到所述切换后集群上。2.根据权利要求1所述的方法，其特征在于，还包括：获取已缓存的元数据，其中，所述已缓存的元数据与所述切换前集群下的对应于所述目标主题的原始主题关联；基于接收到的元数据对所述已缓存的元数据进行更新；所述基于所述元数据从所述各个主题节点中确定当前服务节点，包括：基于所述已缓存的元数据从所述各个主题节点中确定当前服务节点。3.根据权利要求1所述的方法，其特征在于，所述生产客户端对应有生产线程，所述方法还包括：挂起所述生产线程；获取所述切换前集群的切换前集群标识；在成功接收到所述元数据的情况下，基于所述元数据确定所述切换后集群的切换后集群标识，并将所述切换后集群标识与所述切换前集群标识进行对比；在根据得到的对比结果确定所述切换后集群标识与所述切换前集群标识不一致的情况下，唤醒已挂起的所述生产线程，以通过已唤醒的所述生产线程向已连接至的所述当前服务节点上发送生产请求。4.根据权利要求1所述的方法，其特征在于，所述响应于集群切换事件，包括：在检测到来自于配置中心的集群切换事件的情况下，响应于所述集群切换事件，其中，所述集群切换事件在所述配置中心内的配置出现变更时被触发；所述获取所述切换后集群的节点集合，包括：从所述配置中心内获取当前配置的所述切换后集群的切换后集群标识，并基于所述切换后集群标识获取所述切换后集群的节点集合。5.根据权利要求4所述的方法，其特征在于，在所述在检测到来自于配置中心的集群切换事件的情况下之前，还包括：响应于集群异常事件，将所述配置中心内的当前配置的所述切换前集群的切换前集群标识变更为所述切换后集群标识。6.根据权利要求1所述的方法，其特征在于，所述从所述节点集合中获取元数据请求节点，包括：针对所述节点集合中的每个可连接节点，确定已连接在所述可连接节点上的已连接客户端的连接数量；将所述节点集合中连接数量最小的所述可连接节点，作为元数据请求节点；所述将元数据请求发送至所述元数据请求节点上，包括：2CN115756855A权利要求书2/3页连接至所述元数据请求节点上，并将元数据请求发送到已连接至的所述元数据请求节点上。7.一种集群切换方法，其特征在于，应用于消费客户端，所述消费客户端当前连接在切换前集群上，且与切换后集群下的目标主题对应，所述方法包括：响应于集群切换事件，获取所述切换后集群的节点集合，从所述节点集合中获取元数据请求节点，并将元数据请求发送至所述元数据请求节点上；接收所述元数据请求节点针对所述元数据请求返回的元数据，其中，所述元数据用于表示所述节点集合中位于所述目标主题下的各个主题节点的信息；基于所述