dubbo中拦截生产者或消费者服务方法调用

/**
 * 回滚任务Dubbo拦截正在回滚或备份小区的方法调用，阻止执行
 * @author wl
 * @date 2019-08-16 13:24
 */
@Activate(group={ Constants.PROVIDER, Constants.CONSUMER })
public class DubboRollbackTaskFilter implements Filter {

    private static final Logger logger = LoggerFactory.getLogger(DubboRollbackTaskFilter.class);

    private RedisTemplate redisTemplate;

    /**
     * Filter中@Autowired会失效
     * 使用dubbo自动注入redisTemplate类
     * @param redisTemplate
     */
    public void setRedisTemplate(RedisTemplate redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    public static final String ROLLBACK_READIS_KEY = "server_rollback_task_region_ids";

    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        try {
            String method = invocation.getMethodName();
            String name = invoker.getInterface().getName();
            Object[] args = invocation.getArguments();
            String ageString = JSON.toJSONString(args);
            // redis中获取数据
            Object redisValues = redisTemplate.opsForValue().get(DubboRollbackTaskFilter.ROLLBACK_READIS_KEY);
            logger.debug(">>>>>dubboRollbackTaskFilter-className:{},method:{},args:{},redisValues:{}", name, method, ageString, JSON.toJSONString(redisValues));
            if (null != redisValues && redisValues.toString().trim().length() > 0) {
                String[] regionIds = redisValues.toString().split(",");
                for (String regionId : regionIds) {
                    if (regionId.trim().length() <= 0) {
                        continue;
                    }
                    // 只要包含当前有处理的小区，那么直接抛出参数异常
                    if (ageString.contains(regionId)) {
                        logger.info(">>>>>dubboRollbackTaskFilter-拦截:{},method:{},args:{},regionId:{}", name, method, ageString, regionId);
                        return new RpcResult(new IllegalArgumentException("回滚任务拦截提示：当前小区正在备份或回滚数据,一切操作不允许执行！"));
                    }
                }
            }
        } catch (Exception e) {
            // 拦截异常，不影响正常操作
            logger.error(">>>>>dubboRollbackTaskFilter-异常", e);
        }
        return invoker.invoke(invocation);
    }
}