job是通过Mq触发的
image.png
web在启动的时候回去加载MQ
image.png
读取Consumer.xml文件
image.png

1. 普通MQ

topic：设置主题
value-ref：设置接收类
发送的时候通过topic发送，然后会找到对应接收类去处理发送过来的数据处理，进行业务操作

  1. CommonProducer.getProducer().sendMessage("BTC_REQ_COC1", "batchPreNewConnectionJob", "batchPreNewConnectionJob:5332:1:0", "{}");

image.png
数据解析

触发job时，Mq的key需要已job在bean中定义的id开头，如下执行批开job
image.png
发送MQ如下

  1. CommonProducer.getProducer().sendMessage("BTC_REQ_COC1", "batchPreNewConnectionJob", "batchPreNewConnectionJob:5332:1:0", "{}");

MQ的配置参数：
image.png
mq.producer.PID_CRM.NamesrvAddr：消费者注册地址
mq.consumer.PID_CRM_01.NamesrvAddr：生产者注册地址

FQA：

  1. 如果是一个新的topic，发现掉不通，怎么办？

检查ZMQ的监控
image.png
通过服务器名称(就是前面设置的注册地址)和主题找一下，是否可以找到,找不到就掉不通
a. 新的主题，没有在这里增加，需要点击新增主题，将你的新主题加进来
b. 你本地mq没启好

2. MQ集群配置(现在开发环境是MQ集群)

集群是多个项目公用一个MQ，所以不同项目需要设置对应命名空间，才可以使用
命名空间配置：设置环境变量ZMQ_NAMESPACE=项目Code
image.png
image.png
然后配置topic
image.png
image.png
这里选中你使用的MQ服务器，点击进入
image.png
image.png
主题管理
image.png
查询条件 Server Name：服务器名 project Name：项目code， Topic：主题
image.png
这里可以看到详细发送详情