?開發(fā)多年，一直在從社區(qū)獲取開源的便利，也深感社區(qū)力量的重要性，今天開源一個應(yīng)用基礎(chǔ)框架AA.FrameWork,也算是回饋社區(qū)，做出一點點貢獻(xiàn)，希望能夠幫助類似當(dāng)年入行的我。

?

?AA.FrameWork 是基于.NET core流行的開源類庫創(chuàng)建的基礎(chǔ)應(yīng)用框架。

?框架代碼圖如：

源代碼github地址：https://github.com/ChengLab/AAFrameWork

nuget管理中，搜索前綴名稱 AA 即可如圖

Nuget Packages

Packagedescription

AA.Dapper	基于dapper，Dapper-FluentMap 開發(fā) ， 支持工作單元、倉儲模式和原生dapper的操作
AA.Log4Net	基于Log4net開發(fā)，提供常用的日志操作類
AA.FrameWork	基礎(chǔ)框架
AA.Redis	基于StackExchange.Redis開發(fā)，提供各種redis操作和基于redis的分布式鎖
AA.AutoMapper	基于AutoMapper開發(fā)，對象映射
AA.ServiceBus	基于MassTransit開發(fā)的服務(wù)總線 ；很方便的應(yīng)用在event bus 和 publish/subscribe 場景
AA.AspNetCore	aspnetcore常用類集合

實體映射配置AA.Dapper用法

使用DommelEntityMap<TEntity>類映射屬性名稱。創(chuàng)建一個派生類，在構(gòu)造函數(shù)中設(shè)置Map方法，可指定某個屬性映射到數(shù)據(jù)庫列名

public class UserInfoMap : DommelEntityMap<UserInfo>{public UserInfoMap(){ToTable("Sys_UserInfo");//映射具體的表名Map(p => p.SysNo).IsKey();//指定主鍵 ,IsIdentity是否自增Map(p=>p.GmtCreate).ToColumn("GmtCreateDate"); //屬性名和數(shù)據(jù)庫列名 可以不同Map(p=>p.LastLoginDate).Ignore();//一些計算屬性，可以忽略不需要跟數(shù)據(jù)庫列進(jìn)行映射}}

使用MapConfiguration.Init方法，把映射類初始化，后續(xù)就可以使用了

public static void InitMapCfgs(){var fluentMapconfig = new List<Action<FluentMapConfiguration>>();fluentMapconfig.Add(cfg =>{cfg.AddMap(new UserInfoMap());});MapConfiguration.Init(fluentMapconfig);}

開始使用AA.Dapper

使用DapperContext設(shè)置數(shù)據(jù)庫連接和數(shù)據(jù)庫類型是sqlserver還是mysql

public class AADapperContext : DapperContext{public AADapperContext() : base(new NameValueCollection(){["aa.dataSource.AaCenter.connectionString"] = "Data Source =.; Initial Catalog = AaCenter;User ID = sa; Password = 123;",["aa.dataSource.AaCenter.provider"] = "SqlServer"}){ }}

倉儲包含了大部分的操作，同時支持Async操作

IDapperRepository<UserInfo> userInfoRepository = new DapperRepository<UserInfo>();

插入實體

var user = new UserInfo(){UserName = "chengTian",RealName = "成天",GmtCreate = DateTime.Now,GmtModified = DateTime.Now};var result = userInfoRepository.Insert(user);

修改實體

var user = userInfoRepository.Get(1);user.GmtModified = DateTime.Now;var result = userInfoRepository.Update(user);

獲取實體

var user = userInfoRepository.Get(1);//By 主鍵var users = userInfoRepository.GetAll();//所有var users = userInfoRepository.Select(p => p.UserName == "chengTian");//謂詞

刪除實體

var user = userInfoRepository.Get(1);var result = userInfoRepository.Delete(user);

支持Dapper原生操作

操作基本的封裝都是單表的操作，可以滿足一部分業(yè)務(wù)開發(fā)，有些業(yè)務(wù)場景編寫sql還是比較合適的比如報表和一些復(fù)雜的查詢，推薦使用原生dapper的操作

public class UserInfoRepository : DapperRepository<UserInfo>, IUserInfoRepository{private readonly IDapperContext _dapperContext;public UserInfoRepository(IDapperContext context){_dapperContext = context;}public IEnumerable<UserInfo> QueryAll(){var result = _dapperContext.DataBase.Query<UserInfo>("SELECT * from [Sys_UserInfo]");//實例return result;}}

AA.Log4Net 用法

log4net.config 配置，并將log4net.config的屬性->復(fù)制到輸出目錄->設(shè)置為->始終復(fù)制

Log4NetLogger.Use("配置文件名或者路徑+配置文件名"); 例如：log4net.config文件在根目錄下，Log4NetLogger.Use("log4net.config");如果在自定義文件中；例如config/log4net.config 則Log4NetLogger.Use("config/log4net.config")

ILog log= Logger.Get(typeof(類)); log.Debug("example");

AA.ServiceBus 用法

生產(chǎn)者（事件和命令兩種類型）

實例化bus

//事件IBusControl busControl = ServiceBusManager.Instance.UseRabbitMq(rabbitMqUri, rabbitMqUserName, rabbitMqPassword).BuildEventProducer();//命令I(lǐng)SendEndpoint busControl = ServiceBusManager.Instance.UseRabbitMq(rabbitMqUri, rabbitMqUserName, rabbitMqPassword).BuildCommandProducer(queueName);

實例化bus之后可以使用發(fā)送和發(fā)布兩個方法

//命令TaskUtil.Await(busControl.Send<SubmitOrder>(new{Id = 10}));//事件 TaskUtil.Await(busControl.Publish<OrderSubmitted>(new{Id = 1}));

消費者

[Fact]public void TestConsumer(){Log4NetLogger.Use("Log4Net/log4net.config");string rabbitMqUri = "rabbitmq://localhost:5672";string rabbitMqUserName = "";string rabbitMqPassword = "";string queueName = "order.queue";var busControl = ServiceBusManager.Instance.UseRabbitMq(rabbitMqUri, rabbitMqUserName, rabbitMqPassword).RegisterConsumer<SubmitOrderCommandConsumer>(queueName)//注冊命令消費者.RegisterConsumer<OrderSubmittedEventConsumer>(null)//注冊事件消費者.Build();busControl.Start();}

定義消費者需要實現(xiàn)接口IConsumer

public class OrderSubmittedEventConsumer : IConsumer<OrderSubmitted>{public async Task Consume(ConsumeContext<OrderSubmitted> context){var @event = context.Message;var result = $"OrderSubmittedEvent {@event.Id.ToString()}";ILog log = Logger.Get(typeof(OrderSubmittedEventConsumer));log.Debug(result);//do somethings...}}public class SubmitOrderCommandConsumer : IConsumer<SubmitOrder>{public async Task Consume(ConsumeContext<SubmitOrder> context){var command = context.Message;var result = $"CreateFooCommand {command.Id.ToString()}";ILog log = Logger.Get(typeof(SubmitOrderCommandConsumer));log.Debug(result);//do somethings...}}

AA.AutoMapper用法

實現(xiàn)IMapperConfiguration接口，創(chuàng)建映射規(guī)則配置

public class WebMapperConfigurations : IMapperConfiguration{public int Order { get { return 0; } }public Action<IMapperConfigurationExpression> GetConfiguration(){Action<IMapperConfigurationExpression> action = cfg =>{cfg.CreateMap<UserVm, UserInput>();};return action;}}

在程序startup調(diào)用配置

var mapperConfig = new WebMapperConfigurations();AutoMapperConfiguration.Init(new List<Action<IMapperConfigurationExpression>> { mapperConfig.GetConfiguration() });ObjectMapping.ObjectMapManager.ObjectMapper = new AutoMapperObjectMapper();

利用擴(kuò)展方法MapTo執(zhí)行映射

[Fact]public void TestMap(){//initInit();UserVm userVm = new UserVm { Id = 1, Name = "成天" ,Remark="微信公眾號:dotNet知音"};var userDto = userVm.MapTo<UserInput>();//var userDto2 = userVm.MapTo<UserVm,UserInput>();}

后面也會提供基于AA框架的應(yīng)用實例，有問題可以聯(lián)系我，一起交流和成長。

總結(jié)

以上是生活随笔為你收集整理的.Net Core AA.FrameWork应用框架介绍的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。