多消息消费模式多存储处理方法及装置

摘要

多消息消费模式多存储处理方法及装置。本发明涉及数据处理领域，具体涉及消息消费模式多存储处理方法，其步骤如下：接收设备端接口的交易消息，并将交易消息桥接到kafka平台中；设备端接口的平台日志消息与kafka平台对接，并将平台日志消息传递给kafka平台；根据策略，交易消息清洗器消费kafka平台中的交易消息；交易服务集群消费交易消息清洗器中下发的清洗后的交易消息，按照业务将交易消息的数据做分库分表，保存到关系数据库；在平台日志消息与kafka平台对接同时，平台日志清洗器对消息路由器中的平台日志消息进行消费，并存储至分层数据库；在交易消息清洗器消费kafka平台中的交易消息同时；通过这种多层次存储架构可以有效的解决数据杂乱问题，后期可以做到高效，按需检索数据。