记账模块是我们项目的核心模块，也是用户使用最多的模块，因此这个模块的东西比较多，我们要分为多个部分编写代码。
一、需求
币种设置的需求涉及到了我们前面编写的代码，我们来具体看一下需求。
| 编号 | 需求 | 说明 |
|---|---|---|
| 1 | 主币种设置 | 1. 用户可修改主币种；2. 在注册新用户成功后，为用户设置主币种为人民币 |
二、功能编写
在主币种设置这个需求中我们需要增加一个配置表Config ，这个表用来存储用户的配置，就目前来说我们用这个表存储用户设置的主币种。同时我们也需要增加用来操作配置表的Controller ConfigController，这个Controller 中目前只需要两个Action Query 和Update。最后我们要在SysUserController中新增一个根据用户Id获取用户信息的Action QueryUserInfo，这个Action 返回的不仅包括SysUser表中的信息，还会返回用户的配置信息（到目前为止）。这些类和方法在这里就不列出了，大家按前面所说的自己动手编写代码实现业务功能，然后对比一下我写的代码。
这里我们讲解一下在注册新用户成功后，为用户设置主币种为人民币这个需求怎么实现。看到这个需求估计大部分人会觉得直接在Register Action 中增加设置主币种的代码就可以了，如果你也是这么想的那就错了。用户注册功能和设置主币种的关系不是很大，我们可以在注册时让系统设置主币种，也可以让用户自己手动设置，但是根据需求来看我们只能采用第一种方法，因此我们要需解决这么一个问题：在保持Register Action 单一职责的情况下，实现在注册时自动设置主币种为人民币。我相信已经有一部分读者想到可以使用通知来实现。是的没错，要实现这个功能我们可以使用通知的方式，也就是说当用户注册成功后Register Action会发送一条通知，告诉Config增加一条用户主币种。实现通知的功能我们可以选择的方法很多：基于事件机制、共享对象、使用消息队列等，在这里我们为了项目后期的扩展性就选用消息队列 来实现通知的功能，并且选目前在开发领域用的最多的MQ软件**RabbitMQ **。下面我们就一起来看一下如何实现需求吧。
2.1 安装 RabbitMQ
由于现在还处于开发阶段，因此可以把RabbitMQ安装到本地。接下来我们一起将RabbitMQ安装到Docker中吧。打开命令行工具，输入如下命令就可以吧RabbitMQ安装到我们本地了：
docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq
Tip：对于Docker不熟悉的同学，请先去Docker官网或者前往我的专栏Docker极简教程学习
2.2 实现需求
RabbitMQ 安装完了，我们现在就来开发需求。
-
在项目中安装RabbitMQ官方的.NET包RabbitMQ.Client
dotnet add package RabbitMQ.Client -
在项目中新建一个文件夹MQ，在这个文件夹下创建
RabbitMQConnection类，这个类是用来初始化连接，以及释放链接资源，代码如下：using RabbitMQ.Client; using SporeAccounting.MQ.Model; namespace SporeAccounting.MQ; /// <summary> /// RabbitMQ连接类 /// </summary> public class RabbitMQConnection : IDisposable { /// <summary> /// 连接 /// </summary> private readonly IConnection _connection; /// <summary> /// 构造函数 /// </summary> /// <param name="options"></param> public RabbitMQConnection(RabbitMQOptions options) { var factory = new ConnectionFactory { HostName = options.HostName, Port = options.Port, VirtualHost = options.VirtualHost, UserName = options.UserName, Password = options.Password }; _connection = factory.CreateConnectionAsync().Result; } /// <summary> /// 创建通道 /// </summary> /// <returns></returns> public async Task<IChannel> CreateChannel() { return await _connection.CreateChannelAsync(); } /// <summary> /// 释放资源 /// </summary> public void Dispose() => _connection.Dispose(); }这段代码实现了一个
RabbitMQConnection类，用于管理与 RabbitMQ 的连接和通道创建。它接收一个包含 RabbitMQ 配置的RabbitMQOptions对象作为参数，通过ConnectionFactory初始化连接。配置包括主机名、端口、虚拟主机、用户名和密码等信息。在构造函数中，利用CreateConnectionAsync().Result创建同步连接实例_connection。此外，该类提供了CreateChannel方法，通过调用_connection.CreateChannelAsync()异步生成消息通道，方便与 RabbitMQ 进行通信。为了防止资源泄漏，RabbitMQConnection实现了IDisposable接口，在调用Dispose方法时释放_connection占用的资源。这个类封装了连接和通道管理的逻辑，适合在需要频繁访问 RabbitMQ 的场景中使用，提高代码的可维护性和复用性。 -
然后我们新建发布类
RabbitMQPublisher代码如下：using RabbitMQ.Client; namespace SporeAccounting.MQ; /// <summary> /// RabbitMQ发布者类 /// </summary> public class RabbitMQPublisher { /// <summary> /// RabbitMQ连接 /// </summary> private readonly RabbitMQConnection _connection; /// <summary> /// 构造函数 /// </summary> /// <param name="connection"></param> public RabbitMQPublisher(RabbitMQConnection connection) { _connection = connection; } /// <summary> /// 发布消息 /// </summary> /// <param name="queue"></param> /// <param name="routingKey"></param> /// <param name="message"></param> public async System.Threading.Tasks.Task Publish(string queue, string routingKey, string message) { await using var channel = await _connection.CreateChannel(); await channel.QueueDeclareAsync(queue, durable: true); var body = System.Text.Encoding.UTF8.GetBytes(message); await channel.BasicPublishAsync(exchange: string.Empty, routingKey: routingKey, body: body); } }这段代码实现了一个
RabbitMQPublisher类，用于向 RabbitMQ 消息队列发布消息。类中通过依赖注入的方式，接受一个RabbitMQConnection对象用于管理与 RabbitMQ 的连接。其核心功能集中在Publish方法中，该方法负责将消息发送到指定的队列。调用时，方法首先通过_connection.CreateChannel异步创建一个消息通道，并确保通道在使用完毕后释放资源。接着调用QueueDeclareAsync方法声明队列，确保目标队列存在，并将队列设置为持久化。然后，将传入的消息字符串转换为 UTF-8 字节数组以符合 RabbitMQ 的消息格式要求。最终，通过BasicPublishAsync方法发送消息到指定的路由键和队列。此类有效地封装了消息发布的逻辑，提供了简洁的接口来进行队列操作和消息发送，适合构建发布订阅模式的生产者端代码。通过异步编程模式，它可以在处理大量并发消息时保持高性能和资源利用率。 -
接着我们编写订阅类
RabbitMQSubscriber，代码如下：using System.Text; using RabbitMQ.Client; using RabbitMQ.Client.Events; namespace SporeAccounting.MQ; /// <summary> /// RabbitMQ订阅者 /// </summary> public class RabbitMQSubscriber { /// <summary> /// RabbitMQ连接 /// </summary> private readonly RabbitMQConnection _connection; /// <summary> /// 构造函数 /// </summary> /// <param name="connection"></param> public RabbitMQSubscriber(RabbitMQConnection connection) { _connection = connection; } /// <summary> /// 订阅 /// </summary> /// <param name="queue"></param> /// <param name="routingKey"></param> /// <param name="onMessage"></param> /// <returns></returns> public async System.Threading.Tasks.Task Subscribe(string queue, string routingKey, Action<string> onMessage) { await using var channel = await _connection.CreateChannel(); await channel.QueueDeclareAsync(queue, durable: false, exclusive: false, autoDelete: false, arguments: null); var consumer = new AsyncEventingBasicConsumer(channel); consumer.ReceivedAsync += (sender, @event) => { var body = @event.Body.ToArray(); var message = Encoding.UTF8.GetString(body); onMessage(message); return System.Threading.Tasks.Task.CompletedTask; }; await channel.BasicConsumeAsync(queue, autoAck: true, consumer: consumer); } }这段代码定义了一个名为
RabbitMQSubscriber的类，用于实现 RabbitMQ 的订阅功能。类中包含一个_connection字段，表示与 RabbitMQ 的连接，通过依赖注入的方式传入RabbitMQConnection对象并在构造函数中初始化。核心方法是Subscribe，用于订阅指定队列的消息。调用时需要传入队列名称、路由键以及一个处理消息的回调函数onMessage。在方法内部，先通过_connection创建一个通道，然后声明队列以确保其存在。随后，实例化AsyncEventingBasicConsumer作为消息消费者，并在其ReceivedAsync事件中注册逻辑：每当接收到消息时，将消息体从字节数组解码为字符串，并通过onMessage回调执行自定义处理逻辑。最后，通过BasicConsumeAsync启动对队列的监听，启用消息自动确认模式，完成订阅过程。这种设计使得消息处理逻辑可动态配置，适用于异步场景。 -
我们将前面编写的三个类注入到项目中，代码如下：
builder.Services.AddSingleton(new RabbitMQOptions { HostName = configurationManager["RabbitMQ:Host"], Port = int.Parse(configurationManager["RabbitMQ:Port"]), UserName = configurationManager["RabbitMQ:UserName"], Password = configurationManager["RabbitMQ:Password"], VirtualHost = configurationManager["RabbitMQ:VirtualHost"], }); builder.Services.AddSingleton<RabbitMQConnection>(); builder.Services.AddSingleton<RabbitMQPublisher>(); builder.Services.AddSingleton<RabbitMQSubscriber>();这段代码通过依赖注入将
RabbitMQOptions配置、RabbitMQConnection、发布器和订阅器类注册为单例服务，供应用全局使用，简化了 RabbitMQ 的连接与消息处理管理。 -
接下来我们在
RegisterAction 中添加发布设置主币种消息的代码，更新后的代码如下：/// <summary> /// 注册 /// </summary> /// <param name="sysUserViewModel"></param> /// <returns></returns> [HttpPost] [Route("Register")] public ActionResult<ResponseData<bool>> Register(SysUserViewModel sysUserViewModel) { try { var role = _sysRoleServer.QueryByName("Consumer"); SysUser sysUser = _mapper.Map<SysUser>(sysUserViewModel); sysUser.Salt = Guid.NewGuid().ToString("N"); sysUser.Password = HashPasswordWithSalt(sysUser.Password, sysUser.Salt); sysUser.CreateUserId = sysUser.Id; sysUser.CreateDateTime = DateTime.Now; sysUser.RoleId = role.Id; _sysUserServer.Add(sysUser); //发布设置主币种消息 _ = _rabbitMqPublisher.Publish("SetMainCurrency", "SetMainCurrency", sysUser.Id); return Ok(new ResponseData<bool>(HttpStatusCode.OK, "", false)); } catch (Exception ex) { return Ok(new ResponseData<bool>(HttpStatusCode.InternalServerError, "服务端异常", false)); } } -
然后，我们还要在MQ文件夹下新建Message文件夹并编写接收主币种消息的类
SetMainCurrency，代码如下：using SporeAccounting.Models; using SporeAccounting.Server.Interface; namespace SporeAccounting.MQ.Message; /// <summary> /// 设置主货币 /// </summary> public static class SetMainCurrency { /// <summary> /// 开始监听 /// </summary> public static void Start(IServiceProvider serviceProvider) { var subscriber = serviceProvider.GetRequiredService<RabbitMQSubscriber>(); _ = subscriber.Subscribe("SetMainCurrency", "SetMainCurrency", async (userId) => { var accountBookServer = serviceProvider.GetRequiredService<IConfigServer>(); accountBookServer.Add(new Config() { Id = Guid.NewGuid().ToString(), UserId = userId, Value = "CNY", ConfigTypeEnum = ConfigTypeEnum.Currency, CreateDateTime = DateTime.Now, CreateUserId = userId }); }); } }这段代码定义了一个
SetMainCurrency静态类，负责监听 RabbitMQ 消息并处理设置主货币的操作。在Start方法中，它通过依赖注入获取了一个RabbitMQSubscriber实例，并调用Subscribe方法监听SetMainCurrency队列。监听到消息后，异步回调函数会执行，该回调通过serviceProvider获取IConfigServer服务。随后，它创建一个新的Config对象，设置其为主货币配置（“CNY”），并将其存储在accountBookServer中。该配置对象包含了用户 ID、配置类型、创建时间等信息。此设计实现了一个简单的消息处理机制，能够在接收到特定消息时更新系统配置。 -
最后我们在
Programe类中设置在项目启动时开启监听//开启监听主币种 SetMainCurrency.Start(app.Services);
三、总结
这篇文章我们实现了在注册时设置主币种的功能。我们之所以使用消息队列实现是因为注册功能和设置主币种属于两个业务，因此我们需要将它们分离出来，同时即使设置主币种操作失败了也不影响注册功能。
这里只列出了核心的类和方法，其他的方法以及和Config相关的操作请大家自己动手来实现一下，完成后和我的代码对比一下看看有什么不同。
