CN112527528B 基于消息队列的数据传输方法、装置及存储介质 （平安科技（深圳）有限公司）

道福安社区益田路5033号平安金融中本申请公开了一种基于消息队列的数据传中携带消息生产者生成的消息和消息关联的数接收消息消费者发送的携带数据源信息的消息存储区域中拉取目标消息主题对应的消息并向息队列中存储数据以及从消息队列中拉取数据2所述消息管理者确定所述数据源信息关联的消息队列，并根据所述消息管理者在所述消息队列中确定出所述目标消将所述目标消息主题和所述消息存储至所述目标当接收到消息消费者发送的消息订阅请求且所述消息订阅请求中携带所述数据源信内的至少一个存储区域，一个存储区域关联一个消息主题并用于存储所述消息主题的消根据所述项目名称和所述数据源名称生成目标消息主题，其中，一所述消息管理者将所述消息的消息模式注册到消息注册服务中心，通服务中心生成所述消息的消息模式对应的消当接收到所述消息消费者发送的消息模式获取请求且所述消息模式获取请求中携带消息消费者获取消息生产者创建的数据源的所述消息消费者从所述消息管理者接收所述目标消息主题关联的消息3所述消息消费者从所述消息的头部信息中获取消息模式标识信息，并根所述消息消费者从所述消息的头部信息中获取消息模式标识，并向消息从所述消息管理者获取所述消息模式标识对应的消息模式，并基于所述消息生产者创建数据源，并根据所述数据源生成消息和所述消息关联的数据源信息，所述消息生产者向消息管理者发送消息数据，所述消息数据中携4人员对消费者应用做代码调整和二次开发以适应上游生产者生成的新的消息主题。此外，都需要进行重构和代码的重新开发才能将消息存储至消息队列中或者从消息队列中拉取[0007]上述消息管理者在上述消息队列中确定出上述目标消息主题关联的目标存储区[0008]当接收到消息消费者发送的消息订阅请求且上述消息订阅请求中携带上述数据5注册服务中心生成上述消息的消息模式对应[0016]当接收到上述消息消费者发送的消息模式获取请求且上述消息模式获取请求中6域中拉取上述目标消息主题对应的上述消息并向上述消息消费服务中心生成上述消息的消息模式对应的消[0045]当接收到上述消息消费者发送的消息模式获取请求且上述消息模式获取请求中7块向消息管理者发送消息模式获取请求，上述消息模式获取请求中携带上述消息模式标述第一方面以及第一方面中任一种可能的实施方式述第二方面以及第二方面中任一种可能的实施方式述第三方面以及第三方面中任一种可能的实施方式上述第一方面以及第一方面中任一种可能的实中上述第二方面以及第二方面中任一种可能的实施方89户终端集群中的用户终端，消息生产者可以是生成并往消息的队列中存储消息的用户终务中心，或者从消息注册服务中心获取消息消费者请求的消息模式并下发给消息消费者10d为消息生产者10a或消息消费者10c创建且两者可以共同使用的数据源，或者协议规定数据源10d还需要项目，项目是用于区分用户所创建的不同用途的数据源的集合项目是实消息消费者10c创建数据源10d后上报给消息管理者10b，消息管理者10b绑定与该数据源对应的目标存储区域进行数据的生产和消费等操作。此时所创建的数据源10d可以是作为消息数据时可先自行创建数据源10d，消息管理者10b会根据消息生产者10a创建的数据源者10b将上述接收的消息数据存放至消息队列10f中的目标存储区域。只要消息生产者10a10b会根据消息生产者10a创建的数据源10d，在新的消息队列中创建一个新的目标存储区个通用的逻辑概念将携带有消息生产者10a生成的消息以及根据数据源信息生成的目标消从消息队列10f中的目标存储区域中确定出消息订阅请求的目标消息主题，从上述目标存储区域中拉取目标消息主题对应的消息，并将上述消息推送给消息消费者10c逐条进行消理者10b根据上述数据源信息从消息队列10f的目标存储区域确定出上述消息订阅请求订将上述消息模式发送给消息消费者10c。消息消费者10c通过上述消息模式解析并消费消括消息注册服务中心10e，上述消息注册服务中心10e用于记录消息管理者10b注册的消息心10e生成消息的消息模式对应的消息模式标识，将上述消息模式标识信息添加至消息的获取请求且上述消息模式请求携带有上述消息模式标识时，消息管理者10b从消息注册服务中心10e中获取上述消息模式标识对应的消息模式向消息消费者10c发送上述消息模式。可选的，上述消息注册服务中心10e可以为SpringCloud组件，它是一系列框架的有序集[0096]下面将结合图3-图5对本申请实施例提供的基于消息队列的数据传输方法进行示的数据源。这里的项目为区分用户所创建的不同用途的数据源集合(包括一个或者多个数带在消息的头部信息中的消息模式标识，上述消息模式标识用于标识上述消息的消息模[0100]在一些可行的实施方式中，在消息管理者接收消息生产者将上述消息数据的消息模式注册至消息注册服务中心可以为，将上述消息数据注册至中操作绑定一个同样与数据源绑定对应关系的目标存储区域用于存储与上述数据源所对消费者发送的携带有上述数据源信息的消息订阅请求后，会首先解析上述消息订阅请求，并根据上述消息订阅请求所携带的数据源信息找到与上述数据源在消息队列中相对应的述消息模式标识对应的消息模式向消息消费者发送上消费者和消息生产者仅需了解数据源名称和目标存储名称就可以进行消息的生成和消费[0120]其中，该步骤S201的具体实施方式可参见上述图3所对应实施例中对步骤S101的[0122]其中，该步骤S202的具体实施方式可参见上述图3所对应实施例中对步骤S103的[0124]其中，该步骤S203的具体实施方式可参见上述图3所对应实施例中对步骤S103的求接收到的消息属于何种消息模式。如果消息生产者生成的消息对应的消息模式发生变[0138]其中，该步骤S304的具体实施方式可参见上述图3所对应实施例中对步骤S109的区域中拉取上述目标消息主题对应的上述消息并向上述册服务中心生成上述消息的消息模式对应的消[0152]当接收到上述消息消费者发送的消息模式获取请求且上述消息模式获取请求中[0155]请一并参见图7，是本发明实施例提供的另一种基于消息队列的数据传输装置的块向消息管理者发送消息模式获取请求，上述消息模式获取请求中携带上述消息模式标块向消息管理者发送消息模式获取请求，上述消息模式获取请求中携带上述消息模式标[0166]请一并参见图8，是本发明实施例提供的另一种基于消息队列的数据传输装置的机存储记忆体(randomaccessmemory，RAM)存储器，也可以是非不稳定的存储器(non-[0178]当上述收发器1003接收到消息消费者发送的消息订阅请求且消息订阅请求中携模式标识对应的上述消息模式向上述消息消费者发送上[0183]应当理解，本申请中所描述的计算机设备1000可执行前文图4所对应实施例中对该基于消息队列的数据传输方法的描述，也可执行前文图6所对应实施例中对该基于消息可读存储介质中存储有前文提及的基于消息队列的数据传输装置1所执行的计算机程序，[0185]进一步的，请参见图10是本发明实施例提供的另一种计算机设备的结构示意高速随机存储记忆体(randomaccessmemory，RAM)存储器，也可以是非不稳定的存储器位于远离前述处理器2001的存储装置。如图10所示，作为一种计算机存储介质的存储器[0186]在图10所示的计算机设备2000中，网络接口2004主要用于用户终端进行网络通[0191]上述处理器2001，还用于根据上述消息模式标识信息确[0194]应当理解，本申请中所描述的计算机设备2000可执行前文图5所对应实施例中对该基于消息队列的数据传输方法的描述，也可执行前文图7所对应实施例中对该基于消息可读存储介质中存储有前文提及的基于消息队列的数据传输装置2所执行的计算机程序，[0196]进一步的，请参见图11是本发明实施例提供的另一种计算机设备的结构示意高速随机存储记忆体(randomaccessmemory，RAM)存储器，也可以是非不稳定的存储器位于远离前述处理器3001的存储装置。如图11所示，作为一种计算机存储介质的存储器[0197]在图11所示的计算机设备3000中，网络接口3004主要用于用户终端进行网络通[0201]应当理解，本申请中所描述的计算机设备3000可执行前文图3所对应实施例中对该基于消息队列的数据传输方法的描述，也可执行前文图8所对应实施例中对该基于消息可读存储介质中存储有前文提及的基于消息队列的数据传输装置3所执行的计算机程序，质可以是前述任一实施例提供的基于消息队列的数据传输装置或者上述设备的内部存储算机可读存储介质还可以用于暂时地存储已经输出或者施例可以与其它实施例相结合。在本发明说明书和所附权利要求书中使用的术语“和/或”