式而每个地区的客户要求的中间件存在差异为了实现基础框架和业务代码的复用需要实现一套基础框架同时引入多个同类型的中间件基于配置实现底层组件切换并且禁用未开启组件的自启动

案例说明

这里以MQ为例我们同时引入rabbitmq、rocketmq和cmq基于配置framework.mq.rocketmq.type实现不同mq的切换默认使用rabbitmq切换时只有启用类型的mq才会触发自动装配连接和健康检查

备注如果只是单纯同时引入多个组件依赖项目启动阶段未配置连接资源的组件会提示连接异常或者类装载冲突

实现方案

1.以starter组件形式定义组件通过spring.factories声明组件初始化对象和配置文件这里不详细描述

2.在starter内引入rabbitmq、rocketmq和cmq的starter依赖

!--

dependencygroupIdcom.bosssoft.gp/groupIdartifactIdstarter-gp-stream-client/artifactIdversionV5.0.7.4.Release/version

/dependency

dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId

/dependency

dependencygroupIdorg.springframework.amqp/groupIdartifactIdspring-amqp/artifactId

/dependency

dependencygroupIdorg.apache.rocketmq/groupIdartifactIdrocketmq-spring-boot-starter/artifactIdversion2.3.2/version

/dependency3.在组件内排除掉rabbitmq、rocketmq和cmq的AutoConfiguration对象这样在spring容器加载时就不会自启动对应组件也不会在项目启动阶段去连接对应mq(cmq采用手动创建监听器不会触发自启动可以不处理)

org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration,org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration3.2.也可以通过EnableAutoConfiguration的exclude实现排包

import

org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration;

import

org.springframework.boot.autoconfigure.EnableAutoConfiguration;

import

org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration;

import

org.springframework.context.annotation.Configuration;

/***

description:这里独立配置是因为其他config类都被spring.factories声明,添加EnableAutoConfiguration会提示异常*

date:

//#在配置中把默认的RabbitMQ/RocketMQ自动配置类排除掉,

再通过自定义配置开关控制装载RabbitMQ/RocketMQ,

EnableAutoConfiguration(exclude

{RabbitAutoConfiguration.class,

RocketMQAutoConfiguration.class,

public

{}3.3.这里延伸个场景有部分三方组件比如tomcat由于配置加载优先级较高导致在自定义的starter组件内用exclude属性排包太晚加载导致排包不生效(直接在项目的application内声明是有效的但是组件化声明失效)可以采用自定义配置并且优先加载的方案

Configuration

classpath:application-web.yml,encoding

utf-8,factory

GpmsCloudWebMvcAutoConfiguration

implements

postProcessEnvironment(ConfigurableEnvironment

environment,

environment.getPropertySources();MapString,

Object

HashMap();properties.put(spring.autoconfigure.exclude,org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration,com.bosssoft.gp.stream.client.starter.MqClientConfiguration,com.bosssoft.gp.stream.client.starter.MqClientConfiguration);//

添加到属性源中优先级设置为较高MapPropertySource

propertySource

MapPropertySource(mqContainerExcludeProperties,

properties);propertySources.addFirst(propertySource);}}4.基于配置动态加载mq实现

rabbitmq默认开启

CustomRocketAutoConfiguration(Environment

environment)

以此业务服务在引入我们自定义的framework-starter-mq模块后就可以通过framework.mq.rocketmq.type配置来切换不同的mq组件业务模块对于mq的消费和发生可以根据ConditionalOnProperty(prefix

“framework.mq.xxx”,

其他同类型三方组件接入也可以采用该思路来实现自定义的动态加载组件