jamma/mq-worker repository overview

⁠mq-worker

消息处理服务器负责订阅并处理来自 kafka 的消息，开发者负责开发处理消息的工作模块。

⁠两种模块

• 基础模块 kafka, 负责接收kafka服务器的消息
• 工作模块 worker, 负责处理接收到的消息

⁠基础模块 kafka

• 与kafka服务器建立和保持连接
• 订阅主题
• 收到消息后，转发给工作模块，如果消息体是json格式，自动转换为json对象后再转发

⁠工作模块 worker

• 工作模块基类，开发者继承这个类开发自己的工作模块

⁠工作模块 log

监听日志消息，并调用 log 服务保存日志

⁠工作模块 bank

银行系统相关信息同步

⁠配置参数

基本配置 请参考 [jm-server] (https://github.com/jm-root/ms/tree/master/packages/jm-server⁠)

gateway Gateway服务器Uri

kafka [] Zookeeper uri: zk://127.0.0.1:2181 或者 kafka uri: kafka://127.0.0.1:9092

groupId ['mq_worker'] kafka group id

• 配置参数与环境变量对照表