一种基于消息链的轻量级数据处理方法
基本信息
| 申请号 | CN201310714072.8 | 申请日 | - |
| 公开（公告）号 | CN103677844B | 公开（公告）日 | 2017-02-01 |
| 申请公布号 | CN103677844B | 申请公布日 | 2017-02-01 |
| 分类号 | G06F9/44(2006.01)I | 分类 | 计算；推算；计数; |
| 发明人 | 熊梦;杨松;莫展鹏;季统凯 | 申请（专利权）人 | 湖南中科国云大数据产业发展有限公司 |
| 代理机构 | 北京科亿知识产权代理事务所（普通合伙） | 代理人 | 国云科技股份有限公司;湖南中科国云大数据产业发展有限公司 |
| 地址 | 523808 广东省东莞市松山湖科技产业园区松科苑14号楼 | ||
| 法律状态 | - | ||
摘要
| 摘要 | 本发明涉及分布式计算技术领域，特别是指一种基于消息链的轻量级数据处理框架。当消息被接收后进入消息处理链模块；经过链上每个处理器上行处理逻辑的处理后，缓存到上行消息队列中；上行消息队列管理线程取出消息放入消息线程池；消息线程池将消息解析成对象或者结构体；消息观察者根据类型决定是否接受消息，并对其进行特殊业务逻辑处理；另外，用户请求或响应经过消息解析模块转化成消息缓存到下行消息队列中；消息队列把下行消息保存在待发送队列中；按顺序出列进入消息处理链，经过链上每个处理器下行处理逻辑处理后发送至消息通道。本发明解决了采用消息中间件所存在的问题，可用于实现基于本数据处理框架的第三方软硬件的快速集成开发。 |
