本文分享自华为云社区《新特性速览！Sermant重磅更新，1.3.0 release版本发布》，作者：华为云开源。

Sermant社区在12月份正式发布了1.3.0 release版本，这次更新中，Sermant新增服务治理插件：消息队列禁止消费插件。该插件允许在微服务运行时动态地控制消费者（如Kafka、RocketMQ）的消费行为，实现禁止或开启消费，强化了Sermant的可用性治理能力。

除此之外，本次版本更新还对Seramnt框架存在的已知问题和部分功能进行了修复和优化。（Sermant官网：https://sermant.io/）

一、服务治理能力提升

1.1 动态调整消费者消费行为

本次Sermant更新新增了消息队列禁止消费插件，该插件允许微服务在运行态根据实际需求动态调整消费者对消息队列中间件的消费行为，确保在非正常环境或状态下，业务处理流程中的消息得到妥善管理，避免不必要的业务影响。例如，在多云多活架构系统中，如果发生区域性故障需要对流量做切流处理，可在发生故障的可用区开启消息队列禁止消费功能，让正常可用区的消费者来处理业务，避免故障区域消费流量导致业务异常，保障系统的高可用。待故障处理完成后，可重新开启消费。

图片1.jpg

图1 消息队列禁止消费插件故障切流场景使用

消息队列禁止消费插件目前支持Kafka和RocketMQ两种消息中间件。在Kafka方面，该插件实现了Topic级别的禁止和恢复消费功能。对于RocketMQ，控制消费的粒度为消费者实例级别。关于消费队列禁止消费插件的具体介绍、配置说明和场景演示等请参考官网文档消息队列禁止消费。

二、Sermant 框架提升

2.1 可观测性能力提升

支持通过指令查询Sermant对宿主应用的增强信息，包括被增强的类和方法以及具体的Interceptor，有助于提升Sermant的可观测能力。可用于开发调试场景中，判断是否对宿主类增强成功。

在Sermant通过任意方式启动成功后，运行官方提供的AgentLoader，并传入参数下发查询增强信息的指令command=CHECK_ENHANCEMENT，即可在日志中查看到Sermant已执行的增强信息，打印内容如下所示。具体操作请参考官网文档增强信息查询。

xxxx-xx-xx xx:xx:xx.xxx [INFO] [com.huaweicloud.sermant.core.command.CheckEnhancementsCommandExecutor] [execute:42] [Attach Listener] ---------- PLUGINS ----------  
xxxx-xx-xx xx:xx:xx.xxx [INFO] [com.huaweicloud.sermant.core.command.CheckEnhancementsCommandExecutor] [execute:44] [Attach Listener] test-plugin-A:1.0.0  
xxxx-xx-xx xx:xx:xx.xxx [INFO] [com.huaweicloud.sermant.core.command.CheckEnhancementsCommandExecutor] [execute:44] [Attach Listener] test-plugin-B:1.0.0  
xxxx-xx-xx xx:xx:xx.xxx [INFO] [com.huaweicloud.sermant.core.command.CheckEnhancementsCommandExecutor] [execute:46] [Attach Listener] ---------- ENHANCEMENT ----------  
xxxx-xx-xx xx:xx:xx.xxx [INFO] [com.huaweicloud.sermant.core.command.CheckEnhancementsCommandExecutor] [execute:58] [Attach Listener] test-plugin-A:1.0.0  
xxxx-xx-xx xx:xx:xx.xxx [INFO] [com.huaweicloud.sermant.core.command.CheckEnhancementsCommandExecutor] [execute:65] [Attach Listener] xxxxx.xxxx.TestClassA#testFunctionA(boolean,java.lang.String,java.lang.String,java.lang.String)@sun.misc.Launcher$AppClassLoader@5c647e05 [xxxx.xxxx.TestInterceptorA]  
xxxx-xx-xx xx:xx:xx.xxx [INFO] [com.huaweicloud.sermant.core.command.CheckEnhancementsCommandExecutor] [execute:65] [Attach Listener] xxxxx.xxxx.TestClassB#testFunctionB(boolean,java.lang.String,java.lang.String,java.lang.String)@sun.misc.Launcher$AppClassLoader@5c647e05 [xxxx.xxxx.TestInterceptorB,xxxx.xxxx.TestInterceptorC]