17. 【.NET 8 实战--孢子记账--从单体到微服务】--记账模块--主币种设置

🕗 发布于 2024-11-27 20:28 .net 微服务 ruby

记账模块是我们项目的核心模块，也是用户使用最多的模块，因此这个模块的东西比较多，我们要分为多个部分编写代码。

一、需求

币种设置的需求涉及到了我们前面编写的代码，我们来具体看一下需求。

编号	需求	说明
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 的连接与消息处理管理。

接下来我们在Register Action 中添加发布设置主币种消息的代码，更新后的代码如下：

/// <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相关的操作请大家自己动手来实现一下，完成后和我的代码对比一下看看有什么不同。

原文地址：https://blog.csdn.net/gangzhucoll/article/details/143996385

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：VScode 连不上远程云服务器
下一篇：第五章 if语句优化之工厂策略模式+Supplier接口（四）

基于spring boot的医院挂号就诊系统论文
第二点：设计有效的导航，这个包括每个页面上都有导航条的显示，有时也可以在页面的底部设计导航条，当用户进入具体页面时，要设计相应的位置提示，在页面中比较特殊的位置，需要设计返回链接，可以返回上个页面，也
阅读更多2024-11-28
【Unity踩坑】Unity中父对象是非均匀缩放时出现倾斜或剪切现象
本文解决了Unity中父对象是非均匀缩放时出现倾斜或剪切的问题
阅读更多2024-11-28
「Mac玩转仓颉内测版29」基础篇9 - 数组类型详解
本篇将介绍 Cangjie 中的数组类型，包括数组的定义、创建、访问、常见操作以及在数据管理中的应用，帮助开发者熟练掌握数组的使用。
阅读更多2024-11-28
创建mapreduce项目使用maven
创建mapreduce项目使用maven
阅读更多2024-11-28
Python开源项目周排行 2024年第16周
注:当前文章会不定期进行更新。标签： ERP PDF OCR。
阅读更多2024-11-28
使用EFK收集k8s日志
首先我们使用EFK收集Kubernetes集群中的日志，本次实验讲解的是在Kubernetes集群中启动一个Elasticsearch集群，如果企业内已经有了Elasticsearch集群，可以直接将
阅读更多2024-11-28
C#基础41-45
求n以内（不包括n）同时能被3和7整数的所有自然数之和的平方根s，并作为函数值返回，最后结果s输出到控制台。44.数组x中有n个数，求出奇数的个数cn1和偶数的个数cn2以及数组x下标为奇数的元素值的
阅读更多2024-11-28
JavaScript：遍历一个对象数组，获取每个对象中 mainKeyId 对应的值，并以这个值作为新属性的键名，给该对象添加一个新属性。
假设我们有一个对象数组，每个对象包含一个mainKeyId字段，以mainKeyId的值作为新的键名，并给它添加一个新的属性。
阅读更多2024-11-28
【AI系统】谷歌 TPU v4 与光路交换
TPU v4 通过采用 7nm 工艺，翻倍的 MXU 数量，以及显著增加的内存容量和带宽，实现了性能的大幅提升。特别引人注目的是 Sparse Core 的引入，它专门针对稀疏计算进行了优化，使得 T
阅读更多2024-11-28
SpringBoot文件上传之秒传、断点续传、分片上传
比如，在线教育平台上的视频资源上传，社交平台上的图片分享，以及企业内部的知识文档管理等。这些场景对文件上传的要求也各不相同，有的追求速度，有的注重稳定性，还有的需要考虑文件大小和安全性。这对于大文件上
阅读更多2024-11-28