基于 Spring Boot 策略模式的短信服务提供商动态切换实现

一、整体设计思路

为了实现在短信服务提供商变更时,不修改现有代码就能无缝切换到新服务实现,可采用策略模式结合依赖注入以及配置中心化管理的方式来设计软件系统。

二、 具体实现步骤

1. 定义统一接口(以短信服务为例,接口命名为 SmsService

创建一个抽象的接口,用于定义该类服务的统一行为规范,所有具体服务提供商的实现类都需要遵循这个接口所定义的方法。例如:

public interface SmsService {
            
    Response sendSms(Request request);
}

这里定义了 sendSms 方法,意味着不同短信服务提供商的具体实现类都要实现该方法来完成发送短信的操作,从外部调用角度来看,调用这个接口的 sendSms 方法就能获取相应的短信发送服务结果,无需关心具体是由哪个服务商来提供服务。

2. 实现具体服务提供商

针对不同的短信服务提供商,分别实现上述定义的 SmsService 接口,并在各自的实现类中封装对应服务商特有的业务逻辑。比如:

// 阿里云短信服务实现
@Service("aliyunSmsService")
public class AliyunSmsServiceImpl implements SmsService {
            
    public AliyunSmsServiceImpl(
        @Value("${sms.aliyun.accessKey}") String accessKey,
        @Value("${sms.aliyun.secretKey}") String secretKey
    ) {
             /* 初始化相关参数 */ }

    @Override
    public Response sendSms(Request request) {
            
        // 此处编写调用阿里云短信 API 的具体逻辑
    }
}

// 腾讯云短信服务实现
@Service("tencentSmsService")
public class TencentSmsServiceImpl implements SmsService {
            
    public TencentSmsServiceImpl(
        @Value("${sms.tencent.appId}") String appId,
        @Value("${sms.tencent.secretKey}") String secretKey
    ) {
             /* 初始化相关参数 */ }

    @Override
    public Response sendSms(Request request) {
            
        // 编写调用腾讯云短信 API 的具体逻辑
    }
}
3. 配置文件管理(以 application.yml 为例)

在配置文件中指定当前使用的短信服务提供商,同时配置各个提供商所需的相关参数,方便后续根据配置来获取和使用对应的服务。示例配置如下:

sms:
  provider: aliyun  # 可选值如: aliyun, tencent 等,代表不同的短信服务提供商

  aliyun:
    accessKey: your-aliyun-key
    secretKey: your-aliyun-secret

  tencent:
    appId: your-tencent-app-id
    secretKey: your-tencent-secret
4. 动态选择服务实现(配置类)

创建一个 Spring 配置类,用于根据配置文件中指定的短信服务提供商名称,从 Spring 容器中获取对应的具体服务实现类实例,并将其作为一个 Bean 提供给其他需要使用短信服务的地方。代码如下:

@Configuration
public class SmsServiceConfig {
            
    @Bean
    public SmsService smsService(
        @Value("${sms.provider}") String provider,
        Map<String, SmsService> smsServiceMap
    ) {
            
        return smsServiceMap.get(provider + "SmsService");
    }
}

这里的 smsService 方法被标注为 @Bean,意味着该方法返回值会作为 Bean 被添加到 Spring 容器中供其他组件依赖注入使用。在方法参数中:

@Value("${sms.provider}") String provider 用于从配置文件中获取当前指定的短信服务提供商名称(如 "aliyun""tencent" 等)。
Map<String, SmsService> smsServiceMap 是 Spring 容器自动管理的一个 Map 结构,它的键(String)是各个实现了 SmsService 接口的 Bean 名称(像 "aliyunSmsService""tencentSmsService" 等,由 @Service 注解指定名称时确定),值(SmsService)就是对应的实现了 SmsService 接口的具体短信服务 Bean 实例。Spring 容器在初始化 SmsServiceConfig 类并处理 smsService 这个 @Bean 方法时,会自动查找类型为 Map<String, SmsService>Bean(也就是收集了所有实现 SmsService 接口的 Bean 实例的 Map)并注入到该方法的参数中。然后在方法体内部通过 return smsServiceMap.get(provider + "SmsService"); 语句,根据配置文件中指定的提供商名称,从这个 Map 中获取对应的具体服务 Bean 实例,并返回该实例作为可供其他组件注入使用的 Bean

4.1 示例

假设我们有上述提到的两个短信服务实现类:

@Service("aliyunSmsService")  // Bean 名称为 "aliyunSmsService"
public class AliyunSmsServiceImpl implements SmsService {
            ... }

@Service("tencentSmsService") // Bean 名称为 "tencentSmsService"
public class TencentSmsServiceImpl implements SmsService {
            ... }

当 Spring 容器启动后,会自动按照其自动装配机制生成一个如下的 Map

{
            
    "aliyunSmsService": new AliyunSmsServiceImpl(),
    "tencentSmsService": new TencentSmsServiceImpl()
}

这个 Map 会被自动注入到 SmsServiceConfig 类的 smsService 方法的 smsServiceMap 参数中。我们可以通过在 smsService 方法中添加日志输出语句来验证这一过程,代码如下:

@Bean
public SmsService smsService(
    @Value("${sms.provider}") String provider,
    Map<String, SmsService> smsServiceMap
) {
            
    System.out.println("Map 中的所有 Bean 名称:" + smsServiceMap.keySet());
    // 预期输出: [aliyunSmsService, tencentSmsService]
    return smsServiceMap.get(provider + "SmsService");
}

启动应用后,查看控制台输出,就能看到这个 Map 中包含的所有具体短信服务实现类对应的 Bean 名称,从而验证 Spring 容器是否正确地将实现类 Bean 收集并注入到 Map 中,以及整个配置类是否能按照预期根据配置获取相应的服务 Bean

4.2关键点总结

自动装配机制:Spring 会自动识别 SmsService 接口的所有实现类,并将它们注册为 Bean。在扫描类路径时,一旦发现被 @Service(或其他合适的组件扫描注解,如 @Component@Repository 等)注解标记且实现了指定接口的类,就会将其纳入 Spring 容器管理,使其成为一个可被注入和使用的 Bean
Map 注入:通过 Map<String, SmsService> 这样的参数类型声明,Spring 利用其依赖注入功能,自动将所有实现了 SmsService 接口的 Bean 注入到这个 Map 中。这种方式为动态选择具体服务实现类提供了便利,是实现根据配置切换服务提供商的关键环节。
命名规则:确保 Bean 的名称(通过 @Service("自定义名称") 等方式指定)与配置文件中的 provider 值匹配是很重要的。例如,配置文件中 sms.provider 的值为 "aliyun" 时,期望能通过 provider + "SmsService"(即 "aliyunSmsService")这样的命名规则在 Map 中准确找到对应的具体服务 Bean 实例,否则可能导致无法正确获取到期望的服务实现类,影响服务切换功能的正常运作。

通过这样的设计,系统可以在完全不修改业务代码的情况下,仅通过修改配置文件(如 application.yml 中的 sms.provider 值)来动态切换短信服务提供商,完全符合开闭原则,即对扩展(新增服务提供商实现类及配置)开放,对修改(现有业务代码)关闭,极大地提高了系统的可维护性和扩展性,方便应对不同业务场景下对短信服务的多样化需求。

三、使用短信服务

在业务代码中,直接注入 SmsService 接口即可,无需关心具体是由哪个短信服务提供商来实现,这样就能方便地调用短信发送服务,如下所示:

@Service
public class BusinessSmsService {
            
    private final SmsService smsService;

    @Autowired
    public BusinessSmsService(SmsService smsService) {
            
        this.smsService = smsService;
    }

    public void sendBusinessSms() {
            
        Request smsRequest = new Request(); // 构建短信请求对象
        Response response = smsService.sendSms(smsRequest);
        // 根据响应进行后续处理,比如判断发送是否成功等
    }
}

四、切换服务提供商

若要切换短信服务提供商,只需修改配置文件 application.yml 中的 sms.provider 值即可,无需对业务代码进行任何修改,例如:

sms:
  provider: tencent  # 从 aliyun 切换到 tencent

五、核心优势

解耦服务实现与使用:通过定义 SmsService 接口,将短信服务的使用者与具体的服务实现类进行了分离,降低了代码的耦合度,使得各部分代码职责更加清晰。
配置中心化管理:所有短信服务提供商的相关配置信息都集中在配置文件中,方便进行统一管理和维护,易于根据不同环境、需求等进行配置调整。
良好的可扩展性:当需要新增短信服务提供商时,只需创建一个新的实现了 SmsService 接口的类,并在配置文件中添加对应提供商的配置信息,无需对现有代码进行修改,符合开闭原则,便于系统功能的扩展。
依赖注入便利性:借助 Spring 的依赖注入机制,能够自动管理服务实例的创建、获取以及切换等操作,简化了代码编写,提高了开发效率。

六、动态选择服务实现(配置类)的其它实现方案

以下是一套基于 @ConditionalOnProperty 注解实现服务提供商切换的完整示例,以短信服务为例,包含了接口定义、不同服务提供商实现类、配置类以及使用示例等部分,你可以根据实际情况进行调整和扩展。

1. 引入依赖

首先,确保项目的 pom.xml(如果是 Maven 项目)中包含了 Spring Boot 相关依赖,示例如下:

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!-- 用于处理配置相关的依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-configuration-processor</artifactId>
        <optional>true</optional>
    </dependency>
</dependencies>
2. 定义短信服务接口

创建一个统一的短信服务接口 SmsService,用于定义发送短信的抽象方法,所有具体的短信服务提供商实现类都需要实现该接口。

public interface SmsService {
            
    /**
     * 发送短信方法
     *
     * @param phoneNumber 接收短信的手机号码
     * @param message     短信内容
     * @return 发送结果,true表示成功,false表示失败
     */
    boolean sendSms(String phoneNumber, String message);
}
3. 实现具体短信服务提供商
3.1 阿里云短信服务实现类
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

@Service
public class AliyunSmsService implements SmsService {
            

    private final String accessKeyId;
    private final String accessKeySecret;
    private final String signName;

    // 通过 @Value 注解从配置文件中获取对应的配置参数
    public AliyunSmsService(
            @Value("${sms.aliyun.accessKeyId}") String accessKeyId,
            @Value("${sms.aliyun.accessKeySecret}") String accessKeySecret,
            @Value("${sms.aliyun.signName}") String signName
    ) {
            
        this.accessKeyId = accessKeyId;
        this.accessKeySecret = accessKeySecret;
        this.signName = signName;
    }

    @Override
    public boolean sendSms(String phoneNumber, String message) {
            
        // 这里编写调用阿里云短信 API 的具体逻辑,此处仅为示例,实际需引入阿里云 SDK 并按其要求调用接口
        System.out.println("使用阿里云短信服务发送短信,手机号:" + phoneNumber + ",短信内容:" + message);
        // 假设返回 true 表示发送成功,实际需根据 API 调用结果返回
        return true;
    }
}
3.2 腾讯云短信服务实现类
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

@Service
public class TencentCloudSmsService implements SmsService {
            

    private final String secretId;
    private final String secretKey;
    private final String smsSdkAppId;
    private final String signName;

    public TencentCloudSmsService(
            @Value("${sms.tencent.secretId}") String secretId,
            @Value("${sms.tencent.secretKey}") String secretKey,
            @Value("${sms.tencent.smsSdkAppId}") String smsSdkAppId,
            @Value("${sms.tencent.signName}") String signName
    ) {
            
        this.secretId = secretId;
        this.secretKey = secretKey;
        this.smsSdkAppId = smsSdkAppId;
        this.signName = signName;
    }

    @Override
    public boolean sendSms(String phoneNumber, String message) {
            
        // 编写调用腾讯云短信 API 的具体逻辑,此处为示例,实际需引入对应 SDK 操作
        System.out.println("使用腾讯云短信服务发送短信,手机号:" + phoneNumber + ",短信内容:" + message);
        return true;
    }
}
4. 配置类

创建 SmsConfig 配置类,通过 @ConditionalOnProperty 注解来根据配置文件中的属性值决定创建哪个具体的短信服务 Bean

import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class SmsConfig {
            

    @Bean
    @ConditionalOnProperty(name = "sms.provider", havingValue = "aliyun")
    public SmsService aliyunSmsService() {
            
        return new AliyunSmsService();
    }

    @Bean
    @ConditionalOnProperty(name = "sms.provider", havingValue = "tencent")
    public SmsService tencentCloudSmsService() {
            
        return new TencentCloudSmsService();
    }
}
5. 配置文件(application.yml

在配置文件中指定当前使用的短信服务提供商,以及各提供商对应的配置参数信息。

sms:
  provider: aliyun  # 可切换为 "tencent" 来选择不同的短信服务提供商

  aliyun:
    accessKeyId: your-aliyun-access-key-id
    accessKeySecret: your-aliyun-access-key-secret
    signName: 阿里云短信签名

  tencent:
    secretId: your-tencent-secret-id
    secretKey: your-tencent-secret-key
    smsSdkAppId: your-tencent-sms-sdk-app-id
    signName: 腾讯云短信签名
6. 使用短信服务

在需要发送短信的业务类中,直接注入 SmsService 接口,然后调用 sendSms 方法即可,无需关心具体是由哪个服务提供商来实现短信发送功能。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class SmsBusinessService {
            

    private final SmsService smsService;

    @Autowired
    public SmsBusinessService(SmsService smsService) {
            
        this.smsService = smsService;
    }

    public void sendBusinessSms(String phoneNumber, String message) {
            
        boolean result = smsService.sendSms(phoneNumber, message);
        if (result) {
            
            System.out.println("短信发送成功");
        } else {
            
            System.out.println("短信发送失败");
        }
    }
}
7. 测试示例

以下是在启动类中简单测试的示例代码,你可以运行启动类查看效果。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;

@SpringBootApplication
public class SmsServiceApplication {
            

    public static void main(String[] args) {
            
        ConfigurableApplicationContext context = SpringApplication.run(SmsServiceApplication.class, args);

        SmsBusinessService smsBusinessService = context.getBean(SmsBusinessService.class);
        smsBusinessService.sendBusinessSms("13812345678", "这是一条测试短信");

        context.close();
    }
}

通过上述完整示例,你可以根据配置文件中 sms.provider 的配置值,轻松切换短信服务提供商,而无需修改业务代码,实现了灵活且可维护的服务切换功能。同时,遵循了策略模式的设计思想,保持了良好的代码扩展性和低耦合性。

© 版权声明
THE END
如果内容对您有所帮助,就支持一下吧!
点赞0 分享
评论 抢沙发

请登录后发表评论

    暂无评论内容