当前位置：首页 > news >正文

SpringBoot整合阿里云短信服务实战：从零到一构建企业级消息推送

news 2026/5/28 20:42:56

1. 为什么选择阿里云短信服务？

短信验证码、通知提醒、营销推广已经成为现代应用的标准配置。作为Java开发者，我们经常需要快速实现这些功能。阿里云短信服务（SMS）凭借其高可靠性（99%到达率）、高并发支持（单账号日发送量可达千万级）和丰富的模板管理功能，成为企业级应用的首选。

我在多个电商和金融项目中都采用过阿里云短信方案，实测下来发送成功率确实很稳定。特别是他们的秒级监控看板，能实时显示发送状态，这对排查问题特别有帮助。相比自建短信网关，使用云服务省去了服务器维护、通道对接等复杂工作，开发成本直接降低70%以上。

2. 前期准备工作

2.1 阿里云账号配置

首先需要登录阿里云官网完成实名认证，这个步骤大概需要10分钟。特别注意：个人账号和企业账号的短信功能权限有所不同，企业账号可以申请更高频次的发送额度。

在控制台搜索"访问控制RAM"，这里我们需要创建专门用于短信服务的子账号。建议遵循最小权限原则，只勾选"AliyunDysmsFullAccess"这个权限策略。生成的AccessKey ID和Secret要妥善保存，这相当于短信服务的账号密码。

2.2 短信服务开通

进入短信服务控制台后，需要完成两个重要配置：

短信签名：这是显示在短信开头的标识，比如"[XX商城]"。申请时需提供对应的网站备案号或APP Store链接。我遇到过签名审核被拒的情况，后来发现是因为网站底部没标注公司全称，这点要特别注意。
短信模板：分为验证码、通知和推广三种类型。验证码模板必须包含${code}变量，通知类模板需要明确业务场景。建议首次申请时在备注里详细说明使用场景，可以加快审核速度。

3. SpringBoot项目集成

3.1 基础环境搭建

创建新的SpringBoot项目时，建议选择2.3.x以上版本。在pom.xml中添加这些核心依赖：

<dependencies> <!-- 阿里云核心SDK --> <dependency> <groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-core</artifactId> <version>4.5.3</version> </dependency> <!-- 短信服务专用SDK --> <dependency> <groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-dysmsapi</artifactId> <version>2.1.0</version> </dependency> <!-- JSON处理 --> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.83</version> </dependency> </dependencies>

3.2 配置参数管理

推荐使用yml格式的配置文件，结构更清晰：

aliyun: sms: access-key-id: LTAI5txxxxxxxxxx access-key-secret: xxxxxxxxxxxxxxxx region-id: cn-hangzhou sign-name: 测试签名 template: verify: SMS_123456789 # 验证码模板 notify: SMS_987654321 # 通知模板 promo: SMS_567891234 # 推广模板

通过@ConfigurationProperties可以优雅地绑定配置：

@Configuration @ConfigurationProperties(prefix = "aliyun.sms") @Data public class SmsConfig { private String accessKeyId; private String accessKeySecret; private String regionId; private String signName; private Map<String, String> template; }

4. 核心功能实现

4.1 短信发送服务封装

创建SmsService时，建议采用建造者模式提高可读性：

@Service @RequiredArgsConstructor public class SmsService { private final SmsConfig config; public boolean sendVerifyCode(String phone, String code) { return sendSms(phone, config.getTemplate().get("verify"), Map.of("code", code)); } private boolean sendSms(String phone, String template, Map<String, String> params) { try { IAcsClient client = new DefaultAcsClient( DefaultProfile.getProfile(config.getRegionId(), config.getAccessKeyId(), config.getAccessKeySecret())); SendSmsRequest request = new SendSmsRequest() .setPhoneNumbers(phone) .setSignName(config.getSignName()) .setTemplateCode(template) .setTemplateParam(JSON.toJSONString(params)); SendSmsResponse response = client.getAcsResponse(request); return "OK".equalsIgnoreCase(response.getCode()); } catch (Exception e) { log.error("短信发送失败", e); return false; } } }

4.2 验证码完整流程

结合Redis实现带时效的验证码：

@RestController @RequiredArgsConstructor public class SmsController { private final SmsService smsService; private final RedisTemplate<String, String> redisTemplate; @GetMapping("/sms/verify/{phone}") public Result sendVerifyCode(@PathVariable String phone) { String key = "sms:verify:" + phone; if (redisTemplate.hasKey(key)) { return Result.fail("请勿频繁发送"); } String code = RandomStringUtils.randomNumeric(6); if (smsService.sendVerifyCode(phone, code)) { redisTemplate.opsForValue().set( key, code, 5, TimeUnit.MINUTES); return Result.success(); } return Result.fail("发送失败"); } }

5. 生产环境最佳实践

5.1 性能优化方案

在高并发场景下，建议采用这些优化措施：

使用连接池管理IAcsClient实例
对短信发送做异步化处理
增加本地缓存减少Redis访问
设置合理的重试机制

改造后的异步发送示例：

@Async public CompletableFuture<Boolean> sendAsync(String phone, String template, Map<String, String> params) { return CompletableFuture.completedFuture( sendSms(phone, template, params)); }

5.2 监控与告警

阿里云控制台提供了丰富的监控指标，但建议在应用中额外实现：

发送成功率统计
异常请求记录
到达率抽样检测

可以集成Prometheus实现自定义监控：

@Bean public MeterRegistryCustomizer<PrometheusMeterRegistry> metrics() { return registry -> { Counter.builder("sms.requests") .tag("type", "verify") .register(registry); }; }