CN111427708B 消息消费方法、装置、计算机设备和存储介质 （中国平安财产保险股份有限公司）

层质的名称从预存消费规则配置文件中获取相应消2根据数据源的名称从预存消费规则配置文件中获取消息进入的应根据所述需要消费的消息的通信协议与对应的消息中间件进行通信将所述消费的消息按照所述保存所述消息的文件的命名方式、保存根据所述消息消费规则，从消息中间件中查询开始消费的消息的位依次对所述开始消费的消息的位置和所述结束消费的消息的位置之间的消息进行消记录每个所述消费的消息的大小和/或统计所述将所述消费的消息按照预设文件大小或者预设条数存储到文本文件储预设文件大小的消息或者预设条数的消息，并设置所述起止时间为所述文本文件的名了需要消费的消息的起止时间，所述起止时间根据消息到达消息中间件的预估时间设定，3消费模块，用于根据所述需要消费的消息的通信协议与对应的消息中间件进行通信，存储模块，用于将所述消费的消息按照所述保存所述消息的文件的文件的命名方式包括设置所述起止时间为所述目标文每个所述消费的消息的大小和/或统计所述消9.一种计算机设备，包括存储器和处理器，所述存储器存被处理器执行时实现权利要求1至4中任一项所述的45的消息的位置和所述结束消费的消息的位置之间的消息6台终端102和第二平台终端106通过网络与消息中间件服务器104通过网络进行通信。第一平台终端102根据数据源的名称从预存消费规则配置文件中获取相应消息消费规则；所述7[0038]步骤S110，根据数据源的名称从预存消费规则配置文件中获取相应消息消费规8[0050]其中，消息进入的应用程序接口主要用于定义一套数据源进入处理的API[0052]其中，消息输出的应用程序接口用于定义一套数据输出的API(Application30号12点55分0秒，则将存储所述消费的消息为文本文件命名为“20161230075500_9述消息输出的应用程序接口配置保存所述消息的文件的目录能够便于消费的消息的位置和所述结束消费的消息的位置之间的消者预设条数存储到文本文件，所述文本文件存储预设文件大小的消息或者预设条数的消是可以与其它步骤或者其它步骤中的步骤或者阶段的至少一部分轮流或[0066]消息消费规则获取模块210，用于根据数据源的名称从预存消费规则配置文件中所述消息输出的应用程序接口配置了需要消费的消息的述消息按照到达所述消息中间件的时间的先后顺序在所述消息中间件依次排序；消费单元，依次对所述开始消费的消息的位置和所述结束消费的消息的位置之间的消息进行消[0077]其中，输入应用程序接口主要用于定义一套数据源进入处理的API(Application根据相应的API与所述消息中间件进行通信，通过消费规则配置文件根据消息中间件的类消息的TCP(TransmissionControlProtocol，传输控制协议)连接,TCP是一种面向连接[0078]其中，输出应用应用程序接口主要用于定义一套数据输出的API(Application需要将其分割成多条消息段并设置每条消息段的字节大小；消息位置获取模块pos控制获机设备的通信接口用于与外部的终端进行有线或无线方式的通信，无线方式可通过WIFI、包括非易失性和易失性存储器中的至少一种。非易失性存储器可包括只读存储器(Read