基于RabbitMQ和Socket的分布式查询系统设计与实现

作者：任军锋; 孟亚旗

来源：自动化仪表, 2020, 41(12): 92-95.

DOI：10.16086/j.cnki.issn1000-0380.2019120044

• RabbitMQ
• 分布式
• 机器节点
• 查询代理
• 查询服务
• 分层
• 快速扩展缩减
• 多级缓存
• 索引结构

为了应对数据分散在不同的机器节点,通过条件查找,可快速查询到所需的信息内容,设计了分布式查询系统。该系统由查询代理QueryAgent和查询服务QueryService二级结构组成。业务端将查询条件通过RabbitMQ发送给查询代理。查询代理根据查询的条件和信息,找到信息所在机器节点;通过QueryService查询结果,并将结果反馈给查询代理,查询代理通过RabbitMQ将结果反馈给业务前端。根据实际业务数据的增减,可以适时增减机器节点数量,无需调整系统架构和二次开发,即可实现系统快速扩展缩减和最大化资源利用。通过这种分层分布式的设计,可以快速定位数据信息位置,并查询信息详情。系统测试结果表明,所设计的分布式查询系统可以快速、准确地获取查询结果,满足业务端的需求。该设计也降低了模块功能之间的耦合性,为后续增加多级缓存、优化索引结构、提升系统性能提供了便利。

• 单位
  上海工业自动化仪表研究院有限公司