在上一期MQ系列文章“MQ高阶：基于MQ的分布式事务解决方案"中，小编为大家讲解了如何基于MQ提供分布式事务解决方案。不少小伙伴看完后反馈，想进一步了解MQ服务调用模型。

本期，小编就从MQ服务调用模型的流程框架、常见问题解答和常用调试入口三个方面入手，带你全方位了解MQ服务调用模型。

1 MQ调用模型简介

首先，小编带大家认识MQ调用模型的流程框架，如下图所示。

MQ调用模型示意图

接着，小编为大家详细讲讲MQ调用模型的流程原理：

1）首先，MQService启动时会根据队列信息配置文件初始化队列信息，启动消费者线程，并订阅相关队列主题。其中，队列信息配置文件主要包括以下三种：

1、平台的/kd/bos/mq/mqqueueconfig.xml；

2、各自业务的文件；

3、二开的文件。

2）接着，当业务服务产生消息时，将消息发送至MQ组件中（如单据提交到工作流）；

3）最后，订阅方线程消费相关消息。

注意：

如果队列发生阻塞，可能是因为MQ应用服务初始化消费者线程失败。在该问题场景下，需要注意消费者线程在哪个应用中启动。举个例子：

首先，我们看一个队列配置信息的示例：

<region name="workflow" appid="wf">
<queue name="messagecenter_service">
<consumer class="kd.bos.workflow.message.service.impl.MessageCenterConsumer"></consumer>
</queue>
</region>

在这个配置文件中，region配置了“appid=wf”（粒度可以细化到queue一级），“appid”决定了在哪一个应用中去启动该消费者线程。

如果当前节点采用分应用部署的模式，且系统变量“appids”中没有“wf”，那么当前节点就不会去消费该队列的消息。

2 常见问题解答

Q1：轻量级环境，工作流提交后收不到消息。

针对该问题，可检查下述代码，若参数设置为“false”，则本节点将不会消费MQ消息：

System.setProperty("dubbo.registry.register", "true");
System.setProperty("mq.consumer.register", "true");//该参数为false，本节点将不会消费mq消息

Q2：团队版开发环境，工作流提交后偶发收不到消息。

针对该问题，可通过下述代码进行调试：

System.setProperty("mq.debug.queue.tag", "每个人的专属tag");

Q3：生产环境，工作流提交后收不到消息，但开发环境可以收到消息。

针对该问题，可检查生产环境是否分应用部署，且bos应用下的"appids"要加上"wf"。

Q4：若以上方式都不能解决问题，该怎么办？

针对该问题，可尝试通过下述步骤解决：

① 检查MQ是否正常运行，如: telnet xxx.xxx 5672;

② 检查测试环境和其它环境是否共用vhost。共用vhost将导致测试环境的消息被其它环境消费，此时需要检查所有环境的vhost设置，保证每个环境使用独立的vhost（一般可用集群名）。

Q5：如何部署二开队列的配置文件和消费者插件？

针对该问题，可通过下述步骤解决：

1、首先，找到二开队列配置文件里的“appid”所在的服务节点及插件工程；

2、接着，将消费者插件部署在此插件工程下；

3、在消息发送方/消费方工程下，添加二开队列的配置文件；

4、在消息发送方/消费方服务节点处，增加启动参数“mqConfigFiles.config=配置文件的相对路径”。

注：若节点未采用分应用部署模式，则“appid”为空。部署配置文件及配置参数时，配置任意一方即可。

3 常用调试入口

1）调试MQ应用服务启动时是否正常。

调用代码：

kd.bos.mq.init.MQInit.init()
kd.bos.mq.config.UsageConfig.get()//可调试队列信息配置文件是否正常加载

2）调试消息中心发送消息。

调用代码：

kd.bos.servicehelper.workflow.MessageCenterServiceHelper.sendMessage(MessageInfo)

消费方：

kd.bos.workflow.message.service.impl.MessageCenterConsumer

查看消息是否正常发送：

select * from t_wf_msgfail，retry:重发次数，state：消息状态[
  normal:业务堆积,
  success:推送成功,
  fail:推送失败,
  intervene:业务干预
]

调试消息中心发送消息示例

3）查看队列是否阻塞。

可登录monitor查看，如下图所示：

MQ监控界面示例

以上就是本期的全部内容啦。看完这篇，是不是对MQ服务调用模型的原理更清晰了呢？

#往期推荐#

# MQ入门：跑通第一个单机案例

# MQ进阶：如何用MQ解决并发问题

# MQ高阶：基于MQ的分布式事务解决方案

更多精彩内容，“码”上了解！↓

想要玩转MQ？那就必须懂MQ服务调用模型！

想要玩转MQ？那就必须懂MQ服务调用模型！

恭喜您！