.NET 开源项目 Anet 介绍

一时失言乱红尘 2021-12-16 03:35 333阅读 0赞

使用 Anet 有一段时间了，已经在我的个人网站（如 [bookist.cc][]）投入使用，目前没有发现什么大问题，所以才敢写篇文章向大家介绍。

GitHub 地址：**[https://github.com/anet-team/anet][https_github.com_anet-team_anet]**

Anet 是一个 .NET Core 通用框架，特点是简单易用。它的目标是：

> A .NET Core Common Lib, Framework and Boilerplate.

它的取名正是来自于这个定义的前面四个字母：ANET。Anet 的宗旨是使 .NET 项目开发变得简单和快速。它适用于面向微服务开发 WebAPI、服务程序和网站。

Anet 说是框架，其实特别简单，几乎没有学习成本。

## 为什么选择 Anet ##

很多传统的 .NET 开源框架模板（比如 ABP）都比较重，学习成本高，使用起来条条框框，比较麻烦。而 Anet 就简单易用得多，尤其适合面向微服务快速开发。

和其它模板框架一样，Anet 封装了一些实用工具类，集成了轻量 ORM 框架 Dapper。但 Anet 对 Dapper 做了一些改进，使得事务可以放在业务层独立处理，数据访问层则不需要关心事务（下文有示例）。

## Anet 的使用 ##

下面贴一些 Anet 的使用示例，这些示例代码都可以在 Anet 的 GitHub 仓库中找到。

使用前先安装 Nuget 包：

Install-Package Anet
    # 或者
    dotnet add package Anet

### 1. 查询操作 ###

public class UserRepository : RepositoryBase<AnetUser>
    {
         
    public UserRepository(Database db) : base(db)
    {
         
        }
    
    public Task<IEnumerable<UserResponseDto>> GetAllAsync()
        {
         
    var sql = "SELECT * FROM AnetUser;";
    return Db.QueryAsync<UserResponseDto>(sql);
        }
    
    public Task<UserResponseDto> GetByIdAsync(long id)
    {
         
    var sql = Sql.Select("AnetUser", new { Id = id });
    return Db.QueryFirstOrDefaultAsync<UserResponseDto>(sql);
        }
    }

### 2. 新增操作 ###

public class UserService
    {
         
    private readonly UserRepository userRepository;
    public UserService(UserRepository userRepository)
    {
         
    this.userRepository = userRepository;
        }
    
    public async Task CreateUserAsync(UserRequestDto dto)
    {
         
    var newUser = new AnetUser { UserName = dto.UserName };
    
    using (var tran = userRepository.BeginTransaction())
            {
         
    await userRepository.InsertAsync(newUser);
    
    // Other business logic code.
    
                tran.Commit();
            }
        }
    
    // ...（其它代码）
    }

### 3. 更新操作 ###

public class UserService
    {
         
    private readonly UserRepository userRepository;
    public UserService(UserRepository userRepository)
    {
         
    this.userRepository = userRepository;
        }
    
    public async Task UpdateUserAsync(long userId, UserRequestDto dto)
    {
         
    var user = await userRepository.FindAsync(userId);
    if (user == null)
    throw new NotFoundException();
    
    using(var tran = userRepository.BeginTransaction())
            {
         
    await userRepository.UpdateAsync(
                    update: new { dto.UserName },
                    clause: new { Id = userId });
    
                tran.Commit();
            }
        }
    
    // ...（其它代码）
    }

### 4. 删除操作 ###

### 5. 定时任务 ###

Anet 封装了一个 JobScheduler，它可以满足大部分任务调度的需求。下面演示如何通过 Anet 来实现一个简单任务轮循程序，模拟一个发送消息的任务调度服务。这个示例也可以在 GitHub 仓库中找到源代码。

首先创建一个 Console（.NET Core）应用，需要先安装 Anet 的两个包：

Install-Package Anet
    Install-Package Anet.Job

要添加一个定时任务就添加一个 IJob 接口的实现。这里添加一个 MessageJob 类，使它实现 IJob 接口，代码如下：

public class MessageJob : IJob
    {
         
    private readonly ILogger<MessageJob> _logger;
    public MessageJob(ILogger<MessageJob> logger)
    {
         
            _logger = logger;
        }
    
    public Task ExecuteAsync()
    {
         
    // 模拟异步发送消息
    return Task.Run(() =>
            {
         
                _logger.LogInformation("正在发送消息...");
                Thread.Sleep(3000);
                _logger.LogInformation("消息发送成功。");
            });
        }
    
    public Task OnExceptionAsync(Exception ex)
    {
         
            _logger.LogError(ex,"发送消息出错。");
    return Task.FromResult(0);
        }
    }

你要关心的就是 `ExecuteAsync` 方法，把你的执行代码放在此方法中。

然后只需在 Program.cs 的入口 Main 方法中进行初始化和配置即可，例如：

// 初始化应用
    App.Init((config, services) =>
    {
         
    // 绑定配置
        Settings = new SettingsModel();
        config.Bind(Settings);
    
    // 注册服务
        services.AddTransient<MessageJob>();
    });
    
    var logger = App.ServiceProvider.GetRequiredService<ILogger<Program>>();
    
    logger.LogInformation("程序已启动。");
    
    // 启动定时轮循任务
    Scheduler.StartNew<MessageJob>(Settings.JobIntervalSeconds);
    
    logger.LogInformation("已启动消息发送任务处理程序。");
    
    // 等待程序关闭
    Scheduler.WaitForShutdown();

一个简单的消息发送服务就做好了，每隔指定秒数就会执行发送任务。运行后在控制台看到的效果是：

![plVdQD2.png][]

这个示例包含了记录日志，控制台上的信息都是临时的，你也可以查看运行目录下的 logs 文件夹中的日志文件。完整代码请前往 GitHub 查看。

## Anet 的目前状态 ##

Anet 才刚起步，处在最小可用状态。它目前只是一个通用库，封装了一些常用的类（比如基于 Snowflake 算法的 Id 生成器、用户密码加密等），还算不上框架，还有很多事情要做，连 Wiki 文档都没有，后面再慢慢补吧。

但一个人的力量终究是有限的，特别希望大家能加入到这个项目中和我一起开发。

转载于:https://www.cnblogs.com/willick/p/anet-introduction.html

[bookist.cc]: https://bookist.cc
[https_github.com_anet-team_anet]: https://github.com/anet-team/anet
[plVdQD2.png]: https://i.imgur.com/plVdQD2.png