利索能及
我要发布
收藏
专利号: 2019113111876
申请人: 东软集团股份有限公司
专利类型:发明专利
专利状态:已下证
更新日期:2025-04-10
缴费截止日期: 暂无
联系人

摘要:

权利要求书:

1.一种分布式系统,其特征在于,所述系统包括消息中间件以及多个微服务器;其中,第一微服务器用于,根据所述第一微服务器中的数据更新信息,生成事件消息,所述事件消息中包括事件处理信息、目的服务器的地址信息和事件主题信息,并将所述事件消息发送至所述消息中间件;

第二微服务器用于,获取所述消息中间件中的事件消息,确定该事件消息中包括的事件主题信息与所述第二微服务器的主题是否匹配,在该事件消息中包括的事件主题信息与所述第二微服务器的主题匹配时,判断该事件消息中包括的目的服务器的地址信息与所述第二微服务器的地址信息是否一致,当所述目的服务器的地址信息与所述第二微服务器的地址信息一致时,根据该事件消息中包括的事件处理信息生成用于更新数据的本地事件;

其中,当所述事件处理信息中存在与公共事件相对应的特征代码时,所述第二微服务器从所述消息中间件中获取该特征代码对应的公共事件,修改所述公共事件中的可定义数据以生成所述本地事件;当所述事件处理信息中不存在与公共事件相对应的特征代码时,所述第二微服务器根据所述事件处理信息生成所述本地事件。

2.根据权利要求1所述的系统,其特征在于,所述第一微服务器还用于:在将所述事件消息发送至所述消息中间件之前,确定所述事件消息包括的所述目的服务器的地址信息与所述第一微服务器的地址信息不一致;

所述第一微服务器还用于,在确定所述事件消息包括的所述目的服务器的地址信息与所述第一微服务器的地址信息一致时,根据所述事件处理信息生成本地事件。

3.根据权利要求1所述的系统,其特征在于,所述第一微服务器生成的所述事件消息还包括源地址信息,所述源地址信息为所述第一微服务器的地址信息。

4.根据权利要求1‑3任一项所述的系统,其特征在于,所述地址信息包括所述目的服务器的网络互连协议IP地址信息和端口信息。

5.根据权利要求1所述的系统,其特征在于,所述第二微服务器还用于,在确定该事件消息中包括的事件主题信息与所述第二微服务器的主题不匹配时,停止对所述事件消息的处理。

6.根据权利要求1所述的系统,其特征在于,所述第二微服务器还用于,在从所述消息中间件中获取到事件消息时,若该事件消息中的源地址信息与所述第二微服务器的地址信息一致,则停止对该事件消息的处理,所述源地址信息为发布该事件消息的微服务器的地址。

7.一种分布式系统的通信方法,其特征在于,所述方法包括:

所述分布式系统的第一微服务器根据所述第一微服务器中的数据更新信息,生成事件消息,所述事件消息中包括事件处理信息、目的服务器的地址信息和事件主题信息,并将所述事件消息发送至消息中间件;

所述分布式系统的第二微服务器获取所述消息中间件中的事件消息,确定该事件消息中包括的事件主题信息与所述第二微服务器的主题是否匹配,在该事件消息中包括的事件主题信息与所述第二微服务器的主题匹配时,判断该事件消息中包括的目的服务器的地址信息与所述第二微服务器的地址信息是否一致,当所述目的服务器的地址信息与所述第二微服务器的地址信息一致时,根据该事件消息中包括的事件处理信息生成用于更新数据的本地事件;

其中,当所述事件处理信息中存在与公共事件相对应的特征代码时,所述第二微服务器从所述消息中间件中获取该特征代码对应的公共事件,修改所述公共事件中的可定义数据以生成所述本地事件;当所述事件处理信息中不存在与公共事件相对应的特征代码时,所述第二微服务器根据所述事件处理信息生成所述本地事件。

8.根据权利要求7所述的方法,其特征在于,所述第一微服务器将所述事件消息发送至消息中间件包括:在确定所述事件消息包括的所述目的服务器的地址信息与所述第一微服务器的地址信息不一致时,将所述事件消息发送至消息中间件;

所述方法还包括:所述第一微服务器在确定所述事件消息包括的所述目的服务器的地址信息与所述第一微服务器的地址信息一致时,根据所述事件处理信息生成本地事件。

9.根据权利要求7所述的方法,其特征在于,所述方法还包括:

所述第二微服务器在确定该事件消息中包括的事件主题信息与所述第二微服务器的主题不匹配时,停止对所述事件消息的处理。

10.根据权利要求7所述的方法,其特征在于,所述第二微服务器在判断该事件消息包括的目的服务器的地址信息与所述第二微服务器的地址信息是否一致之前,所述方法还包括:所述第二微服务器确定该事件消息中包括的源地址信息与所述第二微服务器的地址信息一致;

所述方法还包括:所述第二微服务器在确定该事件消息中包括的源地址信息与所述第二微服务器的地址信息不一致时,停止对所述事件消息的处理。