.NET8集成阿里云短信服务实现短信发送功能

dotnet new webapi -n AliyunSmsDemo
cd AliyunSmsDemo

dotnet add package Aliyun.SDK.Core
dotnet add package Aliyun.SDK.Dysmsapi

{
  "AliyunSms": {
    "AccessKeyId": "your-access-key-id",
    "AccessKeySecret": "your-access-key-secret",
    "Endpoint": "dysmsapi.aliyuncs.com",
    "SignName": "your-sign-name",
    "TemplateCode": "your-template-code"
  }
}

public class AliyunSmsSettings
{
    public string AccessKeyId { get; set; }
    public string AccessKeySecret { get; set; }
    public string Endpoint { get; set; }
    public string SignName { get; set; }
    public string TemplateCode { get; set; }
}

public interface ISmsService
{
    Task<bool> SendVerificationCodeAsync(string phoneNumber, string code);
}

public class AliyunSmsService : ISmsService
{
    private readonly AliyunSmsSettings _settings;
    private readonly ILogger<AliyunSmsService> _logger;

    public AliyunSmsService(IOptions<AliyunSmsSettings> settings, ILogger<AliyunSmsService> logger)
    {
        _settings = settings.Value;
        _logger = logger;
    }

    public async Task<bool> SendVerificationCodeAsync(string phoneNumber, string code)
    {
        try
        {
            var client = CreateClient();
            var request = new SendSmsRequest
            {
                PhoneNumbers = phoneNumber,
                SignName = _settings.SignName,
                TemplateCode = _settings.TemplateCode,
                TemplateParam = $"{{\"code\":\"[code]\"}}"
            };

            var response = await client.SendSmsAsync(request);
            
            _logger.LogInformation($"短信发送结果: {JsonSerializer.Serialize(response)}");
            
            return response.Body.Code == "OK";
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "发送短信时发生异常");
            return false;
        }
    }

    private DysmsapiClient CreateClient()
    {
        var config = new Config
        {
            AccessKeyId = _settings.AccessKeyId,
            AccessKeySecret = _settings.AccessKeySecret,
            Endpoint = _settings.Endpoint
        };
        
        return new DysmsapiClient(config);
    }
}

builder.Services.Configure<AliyunSmsSettings>(builder.Configuration.GetSection("AliyunSms"));
builder.Services.AddTransient<ISmsService, AliyunSmsService>();

[ApiController]
[Route("api/[controller]")]
public class SmsController : ControllerBase
{
    private readonly ISmsService _smsService;
    private readonly ILogger<SmsController> _logger;

    public SmsController(ISmsService smsService, ILogger<SmsController> logger)
    {
        _smsService = smsService;
        _logger = logger;
    }

    [HttpPost("send-verification-code")]
    public async Task<IActionResult> SendVerificationCode([FromBody] SendVerificationCodeRequest request)
    {
        // 生成随机验证码（实际项目中可能需要更复杂的生成逻辑）
        var code = new Random().Next(100000, 999999).ToString();
        
        // 发送短信
        var result = await _smsService.SendVerificationCodeAsync(request.PhoneNumber, code);
        
        if (result)
        {
            // 实际项目中应该将验证码存储到数据库或缓存中，并设置过期时间
            _logger.LogInformation($"验证码发送成功: [code]");
            return Ok(new { Success = true, Message = "验证码发送成功" });
        }
        
        return BadRequest(new { Success = false, Message = "验证码发送失败" });
    }
}

public class SendVerificationCodeRequest
{
    [Required]
    [Phone]
    public string PhoneNumber { get; set; }
}

[Fact]
public async Task SendVerificationCode_ShouldReturnSuccess_WhenSmsSent()
{
    // Arrange
    var mockSmsService = new Mock<ISmsService>();
    mockSmsService.Setup(x => x.SendVerificationCodeAsync(It.IsAny<string>(), It.IsAny<string>()))
                 .ReturnsAsync(true);
    
    var controller = new SmsController(mockSmsService.Object, Mock.Of<ILogger<SmsController>>());
    var request = new SendVerificationCodeRequest { PhoneNumber = "13800138000" };
    
    // Act
    var result = await controller.SendVerificationCode(request);
    
    // Assert
    var okResult = Assert.IsType<OkObjectResult>(result);
    var response = Assert.IsType<dynamic>(okResult.Value);
    Assert.True(response.Success);
}