本发明实施例涉及云计算，尤其涉及一种消息处理方法、装置、设备、介质及程序产品。
背景技术：
1、在当前的分布式服务架构之下，应用程序直接连接消息中间件，以通过消息中间件发送服务调用消息和服务回流消息。消息中间件的连接地址通常配置于应用程序的本地配置中。
2、当消息中间件的地址发生改变或者消息中间件存在宕机故障时，本地配置的地址将会失效。需要重启应用程序，才可以与新的连接地址对应的消息中间件建立连接。但是，由于当前分布式设备的规模庞大，一项服务可能由多个设备同时参与。因此，对应用程序进行重启需要消耗大量时间资源。同时，应用程序重启可能会导致服务中断及数据丢失。
技术实现思路
1、本发明实施例提供一种消息处理方法、装置、设备、介质及产品，可以动态管理消息中间件的连接地址，避免应用程序的服务中断或数据丢失。
2、第一方面，本发明实施例提供了一种消息处理方法，包括：服务器集群包括主服务容器和辅助容器，所述辅助容器用于运行所述主服务容器中应用程序对应的代理服务，所述辅助容器通过配置中心客户端组件与所述配置中心通信连接；
3、所述方法应用于所述辅助容器，包括：
4、根据查询请求获取配置中心中所述消息中间件的配置项，所述配置项包括消息中间件的连接信息，其中，所述查询请求包括消息中间件标识；
5、若所述连接信息与历史消息中间件对应的历史连接信息不一致，则基于所述连接信息更新所述历史连接信息，基于所述连接信息建立与目标消息中间件的连接；
6、获取所述目标消息中间件发送的服务调用消息，发送加工后的服务调用消息至所述应用程序；
7、获取所述应用程序基于加工后的服务调用消息产生的数据回流消息，发送加工后的数据回流消息至所述目标消息中间件，以通过所述目标消息中间件返回加工后的数据回流消息。
8、第二方面，本发明实施例提供了一种消息处理装置，包括：服务器集群包括主服务容器和辅助容器，所述辅助容器用于运行所述主服务容器中应用程序对应的代理服务，所述辅助容器通过配置中心客户端组件与所述配置中心通信连接；
9、所述装置应用于所述辅助容器，包括：
10、配置项获取模块，用于根据查询请求获取配置中心中所述消息中间件的配置项，所述配置项包括消息中间件的连接信息，其中，所述查询请求包括消息中间件标识；
11、消息中间件切换模块，用于若所述连接信息与历史消息中间件对应的历史连接信息不一致，则基于所述连接信息更新所述历史连接信息，基于所述连接信息建立与目标消息中间件的连接；
12、消息发送模块，用于获取所述目标消息中间件发送的服务调用消息，发送加工后的服务调用消息至所述应用程序；
13、消息获取模块，用于获取所述应用程序基于加工后的服务调用消息产生的数据回流消息，发送加工后的数据回流消息至所述目标消息中间件，以通过所述目标消息中间件返回加工后的数据回流消息。
14、第三方面，本发明实施例提供了一种电子设备，包括存储器，处理器及存储在存储器上并可在处理器运行的计算机程序，所述处理器执行所述计算机程序时实现本发明实施例中任一项所述的消息处理方法。
15、第四发明，本发明实施例提供了一种计算机可读存储介质，其上存储有计算机程序，该程序被处理器执行时实现如本发明实施例中任一所述的消息处理方法。
16、第五方面，本发明实施例提供了一种计算机程序产品，包括计算机程序，所述计算机程序在被处理器执行时实现如本发明实施例中任一项所述的消息处理方法。
17、本发明实施例提供了一种消息处理方法、装置、设备、介质及产品，该方法包括：根据查询请求获取配置中心中所述消息中间件的配置项，所述配置项包括消息中间件的连接信息，其中，所述查询请求包括消息中间件标识；若所述连接信息与历史消息中间件对应的历史连接信息不一致，则基于所述连接信息更新所述历史连接信息，基于所述连接信息建立与目标消息中间件的连接；获取所述目标消息中间件发送的服务调用消息，发送加工后的服务调用消息至所述应用程序；获取所述应用程序基于加工后的服务调用消息产生的数据回流消息，发送加工后的数据回流消息至所述目标消息中间件，以通过所述目标消息中间件返回加工后的数据回流消息。具体的，通过获取配置中心的配置项，可以确定消息中间件的最新的连接信息。若最新的连接信息与历史消息中间件对应的历史连接信息不一致，则采用最新的连接信息更新历史连接信息。然后基于最新的连接信息建立与消息中间件的连接。通过此方式，可以保证辅助容器在消息中间件的连接地址变换后，及时连接至最新的消息中间件，避免了重启应用程序所导致的时间资源消耗巨大的问题，同时避免了重启应用程序导致的服务中断或数据丢失。
1.一种消息处理方法，其特征在于，服务器集群包括主服务容器和辅助容器，所述辅助容器用于运行所述主服务容器中应用程序对应的代理服务，所述辅助容器通过配置中心客户端组件与所述配置中心通信连接；
2.根据权利要求1所述的方法，其特征在于，所述配置项包括以kafka标识为键，以连接信息为值，构成的键值对。
3.根据权利要求1所述的方法，其特征在于，所述根据查询请求获取配置中心中所述消息中间件的配置项，所述配置项包括消息中间件的连接信息，包括：
4.根据权利要求1所述的方法，其特征在于，所述若所述连接信息与历史消息中间件对应的历史连接信息不一致，则基于所述连接信息更新所述历史连接信息，包括：
5.根据权利要求1所述的方法，其特征在于，还包括：
6.根据权利要求1所述的方法，其特征在于，所述获取所述目标消息中间件发送的服务调用消息，发送加工后的服务调用消息至所述应用程序，包括：
7.根据权利要求6所述的方法，其特征在于，所述获取所述应用程序基于加工后的服务调用消息产生的数据回流消息，发送加工后的数据回流消息至所述目标消息中间件，以通过所述目标消息中间件返回加工后的数据回流消息，包括：
8.根据权利要求7所述的方法，其特征在于，还包括：
9.一种消息处理装置，其特征在于，服务器集群包括主服务容器和辅助容器，所述辅助容器用于运行所述主服务容器中应用程序对应的代理服务，所述辅助容器通过配置中心客户端组件与所述配置中心通信连接；
10.根据权利要求9所述的装置，其特征在于，所述配置项获取模块具体用于：
11.根据权利要求9所述的装置，其特征在于，所述消息发送模块具体用于：
12.根据权利要求9所述的装置，其特征在于，所述消息获取模块具体用于：
13.一种电子设备，其特征在于，包括存储器，处理器及存储在存储器上并可在处理器运行的计算机程序，其特征在于，所述处理器执行所述计算机程序时实现如权利要求1-8中任一项所述的消息处理方法。
14.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，该程序被处理器执行时实现如权利要求1-8中任一所述的消息处理方法。
15.一种计算机程序产品，包括计算机程序，其特征在于，所述计算机程序在被处理器执行时实现如权利要求1-8中任一项所述的消息处理方法。
