第18篇 .net使用RabbitMQ实现短信密码重置

社恐晚期

在 C# 中使用 RabbitMQ 通过短信发送重置后的密码到用户的手机号上，你可以按照以下步骤进行

1.安装 RabbitMQ 客户端库

首先，确保你已经安装了 RabbitMQ 客户端库。你可以通过 NuGet 包管理器来安装：

1. dotnet add package RabbitMQ.Client

复制代码

2.创建 RabbitMQ 连接和通道

创建一个 RabbitMQ 连接和通道，用于发送消息。

1. using RabbitMQ.Client;
2. using System;
3. using System.Text;
5. public class RabbitMQHelper
6. {
7.     private readonly string _hostName;
8.     private readonly string _userName;
9.     private readonly string _password;
10.     private readonly string _queueName;
12. public RabbitMQHelper(string hostName, string userName, string password, string queueName)
13. {
14.     _hostName = hostName;
15.     _userName = userName;
16.     _password = password;
17.     _queueName = queueName;
18. }
20. public void SendMessage(string message)
21. {
22.     var factory = new ConnectionFactory()
23.     {
24.         HostName = _hostName,
25.         UserName = _userName,
26.         Password = _password
27.     };
29.     using (var connection = factory.CreateConnection())
30.     using (var channel = connection.CreateModel())
31.     {
32.         channel.QueueDeclare(queue: _queueName,
33.                              durable: false,
34.                              exclusive: false,
35.                              autoDelete: false,
36.                              arguments: null);
38.         var body = Encoding.UTF8.GetBytes(message);
40.         channel.BasicPublish(exchange: "",
41.                              routingKey: _queueName,
42.                              basicProperties: null,
43.                              body: body);
45.         Console.WriteLine($" [x] Sent {message}");
46.     }
47. }
48. }

复制代码

3.创建短信发送服务

创建一个短信发送服务，用于处理从 RabbitMQ 接收到的消息并发送短信。

1. public class SmsService
2. {
3.     public void SendSms(string phoneNumber, string message)
4.     {
5.         // 在这里实现短信发送逻辑
6.         Console.WriteLine($"Sending SMS to {phoneNumber}: {message}");
7.     }
8. }

复制代码

4.创建 RabbitMQ 消费者

创建一个 RabbitMQ 消费者，用于从队列中接收消息并调用短信发送服务。

1. using RabbitMQ.Client;
2. using RabbitMQ.Client.Events;
3. using System;
4. using System.Text;
6. public class RabbitMQConsumer
7. {
8. private readonly string _hostName;
9. private readonly string _userName;
10. private readonly string _password;
11. private readonly string _queueName;
12. private readonly SmsService _smsService;
14. public RabbitMQConsumer(string hostName, string userName, string password, string queueName, SmsService smsService)
15. {
16.     _hostName = hostName;
17.     _userName = userName;
18.     _password = password;
19.     _queueName = queueName;
20.     _smsService = smsService;
21. }
23. public void StartConsuming()
24. {
25.     var factory = new ConnectionFactory()
26.     {
27.         HostName = _hostName,
28.         UserName = _userName,
29.         Password = _password
30.     };
32.     using (var connection = factory.CreateConnection())
33.     using (var channel = connection.CreateModel())
34.     {
35.         channel.QueueDeclare(queue: _queueName,
36.                              durable: false,
37.                              exclusive: false,
38.                              autoDelete: false,
39.                              arguments: null);
41.         var consumer = new EventingBasicConsumer(channel);
42.         consumer.Received += (model, ea) =>
43.         {
44.             var body = ea.Body.ToArray();
45.             var message = Encoding.UTF8.GetString(body);
46.             var phoneNumber = "user_phone_number"; // 从消息中解析出手机号
47.             _smsService.SendSms(phoneNumber, message);
48.         };
50.         channel.BasicConsume(queue: _queueName,
51.                              autoAck: true,
52.                              consumer: consumer);
54.         Console.WriteLine(" Press [enter] to exit.");
55.         Console.ReadLine();
56.     }
57. }
58. }

复制代码

5.集成到用户密码重置流程

在你的用户密码重置流程中，生成新的密码并将其发送到 RabbitMQ 队列。

1. public class UserService
2. {
3. private readonly RabbitMQHelper _rabbitMQHelper;
5. public UserService(RabbitMQHelper rabbitMQHelper)
6. {
7.     _rabbitMQHelper = rabbitMQHelper;
8. }
10. public void ResetPassword(Guid userId)
11. {
12.     // 生成新的密码
13.     string newPassword = GeneratePassword();
15.     // 将新密码发送到 RabbitMQ 队列
16.     string message = $"Your new password is: {newPassword}";
17.     _rabbitMQHelper.SendMessage(message);
19.     // 其他逻辑，例如更新数据库中的密码
20. }
22. private string GeneratePassword()
23. {
24.     // 生成随机密码的逻辑
25.     return "random_password";
26. }
27. }

复制代码

6.启动 RabbitMQ 消费者

在应用程序启动时，启动 RabbitMQ 消费者以处理消息。

1. public class Program
2. {
3. public static void Main(string[] args)
4. {
5.     string hostName = "localhost";
6.     string userName = "guest";
7.     string password = "guest";
8.     string queueName = "sms_queue";
10.     var smsService = new SmsService();
11.     var rabbitMQConsumer = new RabbitMQConsumer(hostName, userName, password, queueName, smsService);
13.     // 启动消费者
14.     rabbitMQConsumer.StartConsuming();
15. }
16. }

复制代码

7.配置 RabbitMQ 连接信息

确保你的 RabbitMQ 连接信息（主机名、用户名、密码、队列名）是正确的，并且 RabbitMQ 服务器正在运行。
示例代码
以下是一个完整的示例代码，展示如何使用 RabbitMQ 通过短信发送重置后的密码到用户的手机号上：

1. using RabbitMQ.Client;using RabbitMQ.Client.Events;using System;using System.Text;public class RabbitMQHelper{private readonly string _hostName;private readonly string _userName;private readonly string _password;private readonly string _queueName;public RabbitMQHelper(string hostName, string userName, string password, string queueName){    _hostName = hostName;    _userName = userName;    _password = password;    _queueName = queueName;}public void SendMessage(string message){    var factory = new ConnectionFactory()    {        HostName = _hostName,        UserName = _userName,        Password = _password    };    using (var connection = factory.CreateConnection())    using (var channel = connection.CreateModel())    {        channel.QueueDeclare(queue: _queueName,                             durable: false,                             exclusive: false,                             autoDelete: false,                             arguments: null);        var body = Encoding.UTF8.GetBytes(message);        channel.BasicPublish(exchange: "",                             routingKey: _queueName,                             basicProperties: null,                             body: body);        Console.WriteLine($" [x] Sent {message}");    }}}public class SmsService{public void SendSms(string phoneNumber, string message){    // 在这里实现短信发送逻辑    Console.WriteLine($"Sending SMS to {phoneNumber}: {message}");}}public class RabbitMQConsumer{private readonly string _hostName;private readonly string _userName;private readonly string _password;private readonly string _queueName;private readonly SmsService _smsService;public RabbitMQConsumer(string hostName, string userName, string password, string queueName, SmsService smsService){    _hostName = hostName;    _userName = userName;    _password = password;    _queueName = queueName;    _smsService = smsService;}public void StartConsuming(){    var factory = new ConnectionFactory()    {        HostName = _hostName,        UserName = _userName,        Password = _password    };    using (var connection = factory.CreateConnection())    using (var channel = connection.CreateModel())    {        channel.QueueDeclare(queue: _queueName,                             durable: false,                             exclusive: false,                             autoDelete: false,                             arguments: null);        var consumer = new EventingBasicConsumer(channel);        consumer.Received += (model, ea) =>        {            var body = ea.Body.ToArray();            var message = Encoding.UTF8.GetString(body);            var phoneNumber = "user_phone_number"; // 从消息中解析出手机号            _smsService.SendSms(phoneNumber, message);        };        channel.BasicConsume(queue: _queueName,                             autoAck: true,                             consumer: consumer);        Console.WriteLine(" Press [enter] to exit.");        Console.ReadLine();    }}}public class UserService
2. {
3. private readonly RabbitMQHelper _rabbitMQHelper;
5. public UserService(RabbitMQHelper rabbitMQHelper)
6. {
7.     _rabbitMQHelper = rabbitMQHelper;
8. }
10. public void ResetPassword(Guid userId)
11. {
12.     // 生成新的密码
13.     string newPassword = GeneratePassword();
15.     // 将新密码发送到 RabbitMQ 队列
16.     string message = $"Your new password is: {newPassword}";
17.     _rabbitMQHelper.SendMessage(message);
19.     // 其他逻辑，例如更新数据库中的密码
20. }
22. private string GeneratePassword()
23. {
24.     // 生成随机密码的逻辑
25.     return "random_password";
26. }
27. }public class Program
28. {
29. public static void Main(string[] args)
30. {
31.     string hostName = "localhost";
32.     string userName = "guest";
33.     string password = "guest";
34.     string queueName = "sms_queue";
36.     var smsService = new SmsService();
37.     var rabbitMQConsumer = new RabbitMQConsumer(hostName, userName, password, queueName, smsService);
39.     // 启动消费者
40.     rabbitMQConsumer.StartConsuming();
41. }
42. }

复制代码

来源:https://www.cnblogs.com/chenshibao/p/18402707
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！