消息队列中间件（MQ）是苍穹系统的重要组件，合理设计队列，规范使用场景，可以解决很多复杂业务场景，如应用解耦、异步消息、流量削峰等问题，最终实现高性能、高可用、可伸缩和一致性的架构。同时，苍穹MQ支持客户二次开发，遵循一定的开发规范即可快速实现。

本期小编送上一份贴心指南，教你使用MQ进行二次开发～

基本介绍

苍穹容器启动过程中，系统会加载标准产品的消息队列配置文件，路径如下：

5.0.023版本及以上：bos-mq.jar/kd/bos/mq/bos_mqqueueconfig.xml文件；

其余版本：bos-mq.jar/kd/bos/mq/mqqueueconfig.xml文件；

随后，系统将加载客户的队列配置。

这是MQ支持二次开发的整体逻辑，接下来为大家介绍具体的配置操作～

操作指引

前提条件

在进行二次开发之前，我们需注意以下事项：

1. 客户开发能增加消费队列，但不能替换标准产品消费者（相同region下如果queue name和标准产品相同，则该queue配置将不会被添加）；

2. 配置文件需以.xml结尾。

＋

配置文件

增加xml配置文件，如取名为custommqconfig.xml，放在包erkai下，开发工程中存放于以下目录：src/main/resources/erkai/custommqconfig.xml；

xml文件新增队列示例：

<root>  
   <region name="fi" >     
       <queue name="fi.gl.ercikaifa_queue" appid="gl">       
             <consumer class="kd.fi.gl.opplugin.ErKaiConsumer"></consumer>     
       </queue> 
              
       <queue name="fi.gl.ercikaifa_queue1" appid="gl">      
              <consumer class="kd.fi.gl.opplugin.ErKaiConsumer1"></consumer>      
       </queue>   
   </region>
 </root>

MC管理中心新增配置

1. key为mqConfigFiles.config；

2. 值为erkai.custommqconfig.xml；

3. 如果有多个文件，换行配置即可。

示例图如下：

上传图片

图1 新增配置

注：需添加到通用配置的prop，此目录的value支持换行。

＋

消息发送

根据需求配置对应的消息类型：

1. 事务消息

// Trascation begin 支持事务    

    MessagePublisher publisher = MQFactory.get().createSimplePublisher("demo", "demo_queue");    

    try {        

        publisher.publishInDbTranscation("hello world");    

    } finally {       

              //用完关闭       

          publisher.close();    

    }    

// Transcation end

2. 普通消息

//不支持事务
     MessagePublisher pub = MQFactory.get().createSimplePublisher("demo", "demo_queue");
     try {
           pub.publish("hello world");
     } finally{
           //用完关闭
           pub.close();
     }

消费消息

消费消息，可以参考以下示例执行：

public class DemoConsumer implements kd.bos.mq.MessageConsumer {
       public void onMessage(Object message, String messageId, boolean resend, MessageAcker acker) {
             try {
                  //业务处理
                  acker.ack(messageId);
             } catch (Throwable e) {
                  //记录异常日志
                  log.error("消费异常",e);
                  //是否废弃这条消息，根据具体场景判断
                  boolean discard = e instanceof IOException; 
                  if (discard){
                      //废弃
                      acker.discard(messageId); 
                  } else{
                      //告诉mq重发这条消息
                      acker.deny(messageId);
                  }
             }
       }
          //默认无需重写，当事务敏感时，发送方和消费方不在同一个库，需要重写消费方的routekey，如发送者在log库，重写该方法，返回DBRoute.log的retoueKey
       String getRouteKey() {
           return "consumerDbRouteKey";
       }
}

消息确认

对消息消费结果进行确认配置：

ack(messageId) //消息确认    
deny(messageId)//消息拒绝，重新消费这条消息
discard(messageId)//丢弃消息

本地开发配置

1. 主启动类增加

System.setProperty("mqConfigFiles.config", "erkai.custommqconfig.xml");

2. 重启应用。

常见问题

问：本地调试功能正常，环境上找不到我的消费者，这是什么原因？

答：1. 检查jar包是否输出到环境中；2. 若配置文件为erkai.custommqconfig.xml，有可能和其他同事的文件同名导致冲突，建议配置项添加业务标识，如erkai.myappid.custommqconfig.xml。

划重点

1. 消息队列配置文件必须以.xml结尾；

2. MC配置项mqConfigFiles.config必须放到通用配置/prop下，XXX.properties不支持换行符。

往期推荐

# 苍穹MQ分区指南，绝不给你“添堵”

# 一篇文章告诉你MQ的前世今生

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

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

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

上传图片

苍穹MQ二次开发指南，收藏不迷路！

苍穹MQ二次开发指南，收藏不迷路！

恭喜您！