技术摘要：
本申请提供一种消息处理方法、装置、设备和存储介质，方法包括：接收生产终端发送的消息请求，所述消息请求中包括消息体；解析所述消息请求，并根据解析结果，获取对应于所述消息请求的订阅信息；根据所述订阅信息，发送所述消息体至所述订阅信息指定的消费终端。本申  全部
背景技术：
随着信息技术的飞速发展，数据信息传输量日益增长。消息解决方案集成程度越 来越高，数据服务系统越来越庞大。膨胀的数据业务体系增加了服务器系统维护成本，也降 低了系统执行效率，随之而来的还有一些性能和安全性问题。为了解决上述问题，提出了解 耦方案。即将一个庞大的数据业务服务系统解耦成许多个数据服务器子系统，各个子系统 之间争取做到高内聚低耦合。 由于不同的数据服务器一般会有不同的消息传递方式，因此服务器与服务器之间 一般采用异步通讯的方式进行消息传递。比如使用异步线程技术，通讯发起端组装好报文 和URI后，通过开启异步线程实现RPC(Remote  Procedure  Call，远程过程调用)调用。 但是，单纯运用异步线程技术实现异步通讯，往往会存在线程丢失的情况，无法保 障通讯的完整性。并且异步线程使得服务器与服务器之间关系紧密，很难做到相互解耦，不 利于全局监控通讯过程的安全性和健壮性。
技术实现要素：
本申请实施例的目的在于提供一种消息处理方法、装置、设备和存储介质，用以实 现对来自生产终端的消息请求进行解析处理，并根据解析结果和用户的订阅信息，将消息 体发送至指定的消费终端。 本申请实施例第一方面提供了一种消息处理方法，包括：接收生产终端发送的消 息请求，所述消息请求中包括消息体；解析所述消息请求，并根据解析结果，获取对应于所 述消息请求的订阅信息；根据所述订阅信息，发送所述消息体至所述订阅信息指定的消费 终端。 于一实施例中，所述解析所述消息请求，并根据解析结果，获取对应于所述消息请 求的订阅信息，包括：从所述消息请求中解析出消息体和消息通道信息；根据所述消息通道 信息，在数据库中查找所述消息体的所述订阅信息。 于一实施例中，所述订阅信息包括：所述消费终端的地址信息；所述根据所述订阅 信息，发送所述消息体至所述订阅信息指定的消费终端，包括：根据所述消费终端的所述地 址信息，生成所述消息体的消费路由信息；根据消费路由信息，发送所述消息体至所述消费 终端。 于一实施例中，在所述解析所述消息请求，并根据解析结果，获取对应于所述消息 请求的订阅信息之前，还包括：验证所述消息请求是否符合预设条件；当所述消息请求符合 所述预设条件时，执行所述解析所述消息请求，并根据解析结果，获取对应于所述消息请求 的订阅信息的步骤。 4 CN 111552907 A 说　明　书 2/7 页 于一实施例中，在所述根据所述订阅信息，发送所述消息体至所述订阅信息指定 的消费终端之后，还包括：检测是否在预设时间段内接收到所述消费终端发送的确收信息； 若在预设时间段内，未接收到所述确收信息，以预设次数重新发送所述消息体至所述消费 终端，若仍未接收到所述确收信息，则输出所述消息体为无效信息。 本申请实施例第二方面提供了一种消息处理装置，包括：接收模块，用于接收生产 终端发送的消息请求，所述消息请求中包括消息体；解析模块，用于解析所述消息请求，并 根据解析结果，获取对应于所述消息请求的订阅信息；发送模块，用于根据所述订阅信息， 发送所述消息体至所述订阅信息指定的消费终端。 于一实施例中，所述解析模块用于：从所述消息请求中解析出消息体和消息通道 信息；根据所述消息通道信息，在数据库中查找所述消息体的所述订阅信息。 于一实施例中，所述订阅信息包括：所述消费终端的地址信息；所述发送模块用 于：根据所述消费终端的所述地址信息，生成所述消息体的消费路由信息；根据消费路由信 息，发送所述消息体至所述消费终端。 于一实施例中，还包括：验证模块，用于在所述解析所述消息请求，并根据解析结 果，获取对应于所述消息请求的订阅信息之前，验证所述消息请求是否符合预设条件；执行 模块，用于当所述消息请求符合所述预设条件时，执行所述解析所述消息请求，并根据解析 结果，获取对应于所述消息请求的订阅信息的步骤。 于一实施例中，还包括：检测模块，用于在所述根据所述订阅信息，发送所述消息 体至所述订阅信息指定的消费终端之后，检测是否在预设时间段内接收到所述消费终端发 送的确收信息；重发模块，用于若在预设时间段内，未接收到所述确收信息，以预设次数重 新发送所述消息体至所述消费终端，若仍未接收到所述确收信息，则输出所述消息体为无 效信息。 本申请实施例第三方面提供了一种电子设备，包括：存储器，用以存储计算机程 序；处理器，用以执行本申请实施例第一方面及其任一实施例的方法，以将消息体发送至指 定的消费终端。 本申请实施例第四方面提供了一种非暂态电子设备可读存储介质，包括：程序，当 其藉由电子设备运行时，使得所述电子设备执行本申请实施例第一方面及其任一实施例的 方法。 本申请提供的消息处理方法、装置、设备和存储介质，通过接对来自生产终端的消 息请求，并对消息请求进行解析处理，然后根据解析结果和用户的订阅信息，将消息体发送 至指定的消费终端，实现了在生产终端和消费终端之间的消息自动转发功能，保障了消息 传递的完整性。 附图说明 为了更清楚地说明本申请实施例的技术方案，下面将对本申请实施例中所需要使 用的附图作简单地介绍，应当理解，以下附图仅示出了本申请的某些实施例，因此不应被看 作是对范围的限定，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以 根据这些附图获得其他相关的附图。 图1为本申请一实施例的电子设备的结构示意图； 5 CN 111552907 A 说　明　书 3/7 页 图2A为本申请一实施例的分布式消息服务平台的数据交互场景示意图； 图2B为本申请一实施例的专用队列代码示意图； 图2C为本申请一实施例的通用队列代码示意图； 图2D为本申请一实施例的主题为A的消息1的数据交互场景示意图； 图3为本申请一实施例的消息处理方法的流程示意图； 图4为本申请一实施例的消息处理方法的流程示意图； 图5为本申请一实施例的消息处理装置的结构示意图。