SpringBoot基于配置实现短信服务策略的动态切换

sms:
  default-provider: aliyun
  providers:
    aliyun:
      enabled: true
      app-id: xxx
      app-secret: yyy
    tencent:
      enabled: true
      app-id: aaa
      app-secret: bbb
    huawei:
      enabled: false
      app-id: 123
      app-secret: 456

@Component
@ConfigurationProperties(prefix = "sms")
@Data
public class SmsProperties {

    private String defaultProvider;

    private Map<String, ProviderConfig> providers;

    @Data
    public static class ProviderConfig {
        private boolean enabled;
        private String appId;
        private String appSecret;
    }
}

public interface SmsProvider {
    String getProviderKey(); // aliyun / tencent / huawei
    boolean isEnabled();     // 是否启用（可从配置读取）
    void sendSms(String phone, String message);
}

@Component
public class AliyunSmsProvider implements SmsProvider {

    private final SmsProperties smsProperties;

    public AliyunSmsProvider(SmsProperties smsProperties) {
        this.smsProperties = smsProperties;
    }

    @Override
    public String getProviderKey() {
        return "aliyun";
    }

    @Override
    public boolean isEnabled() {
        SmsProperties.ProviderConfig config = smsProperties.getProviders().get(getProviderKey());
        return config != null && config.isEnabled();
    }

    @Override
    public void sendSms(String phone, String message) {
        System.out.println("【阿里云】发送短信：" + phone + " - " + message);
        // 实际调用 SDK
    }
}

@Component
public class TencentSmsProvider implements SmsProvider {

    private final SmsProperties smsProperties;

    public TencentSmsProvider(SmsProperties smsProperties) {
        this.smsProperties = smsProperties;
    }

    @Override
    public String getProviderKey() {
        return "tencent";
    }

    @Override
    public boolean isEnabled() {
        SmsProperties.ProviderConfig config = smsProperties.getProviders().get(getProviderKey());
        return config != null && config.isEnabled();
    }

    @Override
    public void sendSms(String phone, String message) {
        System.out.println("【腾讯云】发送短信：" + phone + " - " + message);
        // 实际调用 SDK
    }
}

@Component
public class SmsProviderRouter {

    private final SmsProperties smsProperties;
    private final Map<String, SmsProvider> providerMap;

    public SmsProviderRouter(List<SmsProvider> providers, SmsProperties smsProperties) {
        this.smsProperties = smsProperties;
        this.providerMap = providers.stream()
        .collect(Collectors.toMap(SmsProvider::getProviderKey, p -> p));
    }

    public void sendSms(String phone, String message, @Nullable String providerKey) {
        String key = (providerKey != null) ? providerKey : smsProperties.getDefaultProvider();
        SmsProvider provider = providerMap.get(key);

        if (provider == null || !provider.isEnabled()) {
            throw new IllegalStateException("短信服务商不可用: " + key);
        }

        provider.sendSms(phone, message);
    }
}

@RestController
@RequestMapping("/sms")
public class SmsController {

    private final SmsProviderRouter router;

    public SmsController(SmsProviderRouter router) {
        this.router = router;
    }

    @PostMapping("/send")
    public String send(@RequestParam String phone,
                       @RequestParam String msg,
                       @RequestParam(required = false) String provider) {
        router.sendSms(phone, msg, provider);
        return "发送成功";
    }
}

POST /sms/send?phone=13800138000&msg=测试一波

POST /sms/send?phone=13800138000&msg=测试一波&provider=tencent