[發明專利]一種分布式通訊系統及對應的分布式通訊方法

在審

• 申請號: 201610232818.5
• 申請日: 2016-04-15
• 公開（公告）號: CN105791419A
• 公開（公告）日: 2016-07-20
• 發明（設計）人: 韓宇峰
• 申請（專利權）人: 北京思特奇信息技術股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京輕創知識產權代理有限公司 11212
• 代理人: 楊立

1.一種分布式通訊系統，其特征在于，包括接口機集群和業務機集群， 所述接口機集群包括多個接口主機，所述業務機集群包括多個業務主機；

每一個接口主機，用于從接口主機本地獲取任務配置信息，并將獲取的 任務配置信息廣播給對應的多個業務主機；還用于從本地獲取待處理任務， 并將獲取的待處理任務分發給對應的業務主機；

每一個業務主機，用于接收對應的接口主機廣播的任務配置信息，并根 據接收的任務配置信息，更新本地的任務配置信息，且向對應的接口主機發 送信息接收響應；還用于獲取對應的接口主機發送的待處理任務，并根據本 地的任務配置信息對待處理任務進行處理，且向對應的接口主機發送任務接 收響應。

2.如權利要求1所述的一種分布式通訊系統，其特征在于，每一個接 口主機中包括一個pub組件、一個路由負載裝置和多個pull組件，每一個業 務主機中包括一個sub組件和多個push組件；

每一個接口主機中的pub組件，用于從本地獲取任務配置信息，并將獲 取的任務配置信息發送給路由負載裝置；

路由負載裝置，用于將pub組件發送的任務配置信息經過路由后轉發給 對應的多個業務主機；

每一個接口主機中的pull組件，用于從路由負載裝置中獲取信息接收響 應，根據信息接收響應，更新本地的任務配置信息發送狀態；

每一個業務主機中的sub組件，用于接收路由負載裝置轉發的任務配置 信息，并根據接口的任務配置信息，更新本地的任務配置信息；

每一個業務主機中的push組件，用于當sub組件接收到任務配置信息后， 向對應接口主機的路由負載裝置發送信息接收響應。

3.如權利要求2所述的一種分布式通訊系統，其特征在于，每一個接 口主機中的pub組件，還用于當本接口主機未接收到至少一個對應的業務主 機發送的信息接收響應，則等待預定時間后向對應的所有的業務主機重新發 送任務配置信息。

4.如權利要求2所述的一種分布式通訊系統，其特征在于，每一個接 口主機中還包括多個push組件，以及每一個業務主機中還包括多個pull組 件；

每一個接口主機中的push組件，用于從該接口主機本地獲取待分發任 務，并將待分發任務發送給路由負載裝置；

所述路由負載裝置，還用于接收每一個接口主機的push組件發送的待 分發任務，并將接收到的所有待分發任務存儲于任務隊列中；以及還用于接 收每一個業務主機中的push組件發送的任務接收響應，并將接收的所有任 務接收響應存儲于任務響應隊列中；

每一個接口主機中的pull組件，還用于從路由負載裝置的任務響應隊列 中主動獲取任務接收響應，根據任務接收響應，更新本地對應任務的發送狀 態；

每一個業務主機中的pull組件，用于根據預定路由規則從所述路由負載 裝置的任務隊列中主動獲取待分發任務；

每一個業務主機中的push組件，用于當該業務主機中的pull組件獲取 到待處理任務后，向對應接口主機的路由負載裝置發送任務接收響應。

5.如權利要求4所述的一種分布式通訊系統，其特征在于，每一個業 務主機中還包括任務處理池；

每一個業務主機中的pull組件，還用于將獲取的待處理任務發送給任務 處理池；

任務處理池，用于從本地獲取任務配置信息，根據任務配置信息，采用 多進程和多線程的方式對待處理任務進行處理；

每一個業務主機中的push組件，具體用于：

從任務處理池中獲取到任務的處理狀態，根據任務的處理狀態，向對應 接口主機的路由負載裝置發送任務接收響應。

6.如權利要求5所述的一種分布式通訊系統，其特征在于，當接口主 機中的pull組件從路由負載裝置的任務響應隊列中未找到業務主機發送的對 應任務接收響應時，該接口主機中的push組件等待預設閾值時間后進行任 務重發。