1. 项目简介

2. 功能概要

3. 项目中如何使用

3.1 分布式锁

Install-Package Hummingbird.Extensions.DistributedLock -Version 1.17.14

publicclassStartup{publicvoidConfigureServices(IServiceCollectionservices){services.AddHummingbird(hb=>{hb.AddDistributedLock(option=>{option.WithDb(0);option.WithKeyPrefix("");option.WithPassword("123456");option.WithServerList("127.0.0.1:6379");option.WithSsl(false);});});}}

usingMicrosoft.AspNetCore.Mvc;usingSystem;usingSystem.Threading.Tasks;[Route("api/[controller]")]publicclassDistributedLockController:Controller{privatereadonlyIDistributedLockdistributedLock;publicDistributedLockController(IDistributedLockdistributedLock){this.distributedLock=distributedLock;}[HttpGet][Route("Test")]publicasyncTask<string>Test(){varlockName="name";varlockToken=Guid.NewGuid().ToString("N");try{if(distributedLock.Enter(lockName,lockToken,TimeSpan.FromSeconds(30))){// do somethingreturn"ok";}else{return"error";}}finally{distributedLock.Exit(lockName,lockToken);}}}

3.2 分布式缓存

Install-Package Hummingbird.Extensions.Cacheing -Version 1.17.14

publicclassStartup{publicvoidConfigureServices(IServiceCollectionservices){services.AddHummingbird(hb=>{hb.AddCacheing(option=>{option.WithDb(0);option.WithKeyPrefix("");option.WithPassword("123456");option.WithReadServerList("192.168.109.44:6379");option.WithWriteServerList("192.168.109.44:6379");option.WithSsl(false);})});}}

usingHummingbird.Extensions.Cacheing;usingMicrosoft.AspNetCore.Mvc;usingSystem.Threading.Tasks;[Route("api/[controller]")]publicclassCacheingController:Controller{privatereadonlyICacheManagercacheManager;publicCacheingController(ICacheManagercacheManager){this.cacheManager=cacheManager;}[HttpGet][Route("Test")]publicasyncTask<string>Test(){varcacheKey="cacheKey";varcacheValue=cacheManager.StringGet<string>(cacheKey);if(cacheValue==null){cacheValue="value";cacheManager.StringSet(cacheKey,cacheValue);}returncacheValue;}

3.3 分布式Id

  Install-Package Hummingbird.Extensions.UidGenerator -Version 1.17.14  Install-Package Hummingbird.Extensions.UidGenerator.ConsulWorkIdStrategy -Version 1.17.14

publicclassStartup{publicvoidConfigureServices(IServiceCollectionservices){services.AddHummingbird(hb=>{hb.AddSnowflakeUniqueIdGenerator(workIdBuilder=>{workIdBuilder.CenterId=0;// 设置CenterIdworkIdBuilder.AddConsulWorkIdCreateStrategy("Example");//设置使用Consul创建WorkId})});}}

usingHummingbird.Extensions.UidGenerator;usingMicrosoft.AspNetCore.Mvc;usingSystem.Threading.Tasks;[Route("api/[controller]")]publicclassUniqueIdController:Controller{privatereadonlyIUniqueIdGeneratoruniqueIdGenerator;publicUniqueIdController(IUniqueIdGeneratoruniqueIdGenerator){this.uniqueIdGenerator=uniqueIdGenerator;}[HttpGet][Route("Test")]publicasyncTask<long>Test(){returnuniqueIdGenerator.NewId();}}

3.4 分布式追踪

Install-Package Hummingbird.Extensions.OpenTracing -Version 1.17.14Install-Package Hummingbird.Extensions.OpenTracking.Jaeger -Version 1.17.14

 {"Tracing": {"Open":false,"SerivceName":"SERVICE_EXAMPLE","FlushIntervalSeconds":15,"SamplerType":"const","LogSpans":true,"AgentPort":"5775",//代理端口"AgentHost":"dev.jaeger-agent.service.consul",//代理地址"EndPoint":"http://dev.jaeger-collector.service.consul:14268/api/traces"  }}

publicclassProgram{publicstaticvoidMain(string[]args){BuildWebHost(args).Run();}publicstaticIWebHostBuildWebHost(string[]args)=>WebHost.CreateDefaultBuilder(args).UseStartup<Startup>().ConfigureAppConfiguration((builderContext,config)=>{config.SetBasePath(Directory.GetCurrentDirectory());config.AddJsonFile("tracing.json");config.AddEnvironmentVariables();}).ConfigureLogging((hostingContext,logging)=>{logging.ClearProviders();}).Build();}

publicclassStartup{publicvoidConfigureServices(IServiceCollectionservices){services.AddHummingbird(hb=>{hb.AddOpenTracing(builder=>{builder.AddJaeger(Configuration.GetSection("Tracing"));})});}}

usingMicrosoft.AspNetCore.Mvc;usingSystem.Threading.Tasks;[Route("api/[controller]")]publicclassOpenTracingController:Controller{[HttpGet][Route("Test")]publicasyncTaskTest(){using(Hummingbird.Extensions.Tracing.Tracertracer=newHummingbird.Extensions.Tracing.Tracer("Test")){tracer.SetTag("tag1","value1");tracer.SetError();tracer.Log("key1","value1");}}}

3.5 消息总线

Install-Package Hummingbird.Extensions.EventBus -Version 1.17.14Install-Package Hummingbird.Extensions.EventBus.RabbitMQ -Version 1.15.3Install-Package Hummingbird.Extensions.EventBus.MySqlLogging -Version 1.15.3

usingHummingbird.Extensions.EventBus.Abstractions;usingSystem.Collections.Generic;usingSystem.Threading;usingSystem.Threading.Tasks;publicclassTestEvent{publicstringEventType{get;set;}}publicclassTestEventHandler1:IEventHandler<TestEvent>{publicTask<bool>Handle(TestEvent@event,Dictionary<string,object>headers,CancellationTokencancellationToken){//执行业务操作1并返回操作结果returnTask.FromResult(true);}}publicclassTestEventHandler2:IEventHandler<TestEvent>{publicTask<bool>Handle(TestEvent@event,Dictionary<string,object>headers,CancellationTokencancellationToken){//执行业务操作2并返回操作结果returnTask.FromResult(true);}}

usingHummingbird.Extensions.EventBus.Abstractions;usingHummingbird.Extensions.EventBus.Models;usingMicrosoft.AspNetCore.Mvc;usingMySql.Data.MySqlClient;usingSystem.Collections.Generic;usingSystem.Threading.Tasks;usingDapper;usingSystem.Linq;usingSystem.Threading;[Route("api/[controller]")]publicclassMQPublisherTestController:Controller{privatereadonlyIEventLoggereventLogger;privatereadonlyIEventBuseventBus;publicMQPublisherTestController(IEventLoggereventLogger,IEventBuseventBus){this.eventLogger=eventLogger;this.eventBus=eventBus;}/// <summary>///  无本地事务发布消息，消息直接写入队列/// </summary>[HttpGet][Route("Test1")]publicasyncTask<string>Test1(){varevents=newList<EventLogEntry>(){newEventLogEntry("TestEvent",newEvents.TestEvent(){EventType="Test1"}),newEventLogEntry("TestEvent",new{EventType="Test1"}),};varret=awaiteventBus.PublishAsync(events);returnret.ToString();}/// <summary>/// 有本地事务发布消息，消息落盘到数据库确保事务完整性/// </summary>/// <returns></returns>[HttpGet][Route("Test2")]publicasyncTask<string>Test2(){varconnectionString="Server=localhost;Port=63307;Database=test; User=root;Password=123456;pooling=True;minpoolsize=1;maxpoolsize=100;connectiontimeout=180";using(varsqlConnection=newMySqlConnection(connectionString)){awaitsqlConnection.OpenAsync();varsqlTran=awaitsqlConnection.BeginTransactionAsync();varevents=newList<EventLogEntry>(){newEventLogEntry("TestEvent",newEvents.TestEvent(){EventType="Test2"}),newEventLogEntry("TestEvent",new{EventType="Test2"}),};//保存消息至业务数据库，保证写消息和业务操作在一个事务awaiteventLogger.SaveEventAsync(events,sqlTran);varret=awaitsqlConnection.ExecuteAsync("you sql code");returnret.ToString();}}/// <summary>/// 有本地事务发布消息，消息落盘到数据库，从数据库重新取出消息发送到队列/// </summary>/// <returns></returns>[HttpGet][Route("Test3")]publicasyncTaskTest3(){//获取1000条没有发布的事件varunPublishedEventList=eventLogger.GetUnPublishedEventList(1000);//通过消息总线发布消息varret=awaiteventBus.PublishAsync(unPublishedEventList);if(ret){awaiteventLogger.MarkEventAsPublishedAsync(unPublishedEventList.Select(a=>a.EventId).ToList(),CancellationToken.None);}else{awaiteventLogger.MarkEventAsPublishedFailedAsync(unPublishedEventList.Select(a=>a.EventId).ToList(),CancellationToken.None);}}}

publicclassStartup{publicvoidConfigureServices(IServiceCollectionservices){services.AddHummingbird(hb=>{hb.AddEventBus((builder)=>{//使用Rabbitmq 消息队列builder.AddRabbitmq(factory=>{factory.WithEndPoint("192.168.109.2,192.168.109.3","5672"));factory.WithAuth("guest","guest");factory.WithExchange("/");factory.WithReceiver(PreFetch:10,ReceiverMaxConnections:1,ReveiverMaxDegreeOfParallelism:1);factory.WithSender(10);});//使用Kafka 消息队列//builder.AddKafka(option =>//{//    option.WithSenderConfig(new Confluent.Kafka.ProducerConfig()//    {//        EnableDeliveryReports = true,//        BootstrapServers = "192.168.78.29:9092,192.168.78.30:9092,192.168.78.31:9092",//        // Debug = "msg" //  Debug = "broker,topic,msg"//    });//    option.WithReceiverConfig(new Confluent.Kafka.ConsumerConfig()//    {//        // Debug= "consumer,cgrp,topic,fetch",//        GroupId = "test-consumer-group",//        BootstrapServers = "192.168.78.29:9092,192.168.78.30:9092,192.168.78.31:9092",//    });//    option.WithReceiver(1, 1);//    option.WithSender(10, 3, 1000 * 5, 50);//});// 基于MySql 数据库 进行消息持久化，当存在分布式事务问题时builder.AddMySqlEventLogging(o=>{o.WithEndpoint("Server=localhost;Port=63307;Database=test; User=root;Password=123456;pooling=True;minpoolsize=1;maxpoolsize=100;connectiontimeout=180");});// 基于SqlServer 数据库 进行消息持久化，当存在分布式事务问题时//builder.AddSqlServerEventLogging(a =>//{//     a.WithEndpoint("Data Source=localhost,63341;Initial Catalog=test;User Id=sa;Password=123456");//});})});}// This method gets called by the runtime. Use this method to configure the HTTP request pipeline.publicvoidConfigure(IApplicationBuilderapp,IHostingEnvironmentenv){vareventBus=app.ApplicationServices.GetRequiredService<IEventBus>();varlogger=app.ApplicationServices.GetRequiredService<ILogger<IEventLogger>>();app.UseHummingbird(humming=>{humming.UseEventBus(sp=>{sp.UseSubscriber(eventbus=>{eventbus.Register<TestEvent,TestEventHandler1>("TestEventHandler1","TestEvent");eventbus.Register<TestEvent,TestEventHandler2>("TestEventHandler2","TestEvent");//订阅消息eventbus.Subscribe((Messages)=>{foreach(varmessageinMessages){logger.LogDebug($"ACK: queue{message.QueueName} route={message.RouteKey} messageId:{message.MessageId}");}},async(obj)=>{foreach(varmessageinobj.Messages){logger.LogError($"NAck: queue{message.QueueName} route={message.RouteKey} messageId:{message.MessageId}");}//消息消费失败执行以下代码if(obj.Exception!=null){logger.LogError(obj.Exception,obj.Exception.Message);}// 消息等待5秒后重试，最大重试次数3次varevents=obj.Messages.Select(message=>message.WaitAndRetry(a=>5,3)).ToList();// 消息写到重试队列varret=!(awaiteventBus.PublishAsync(events));returnret;});});});});}}

3.6 健康检查

Install-Package Hummingbird.Extensions.HealthChecks -Version 1.17.14Install-Package Hummingbird.Extensions.HealthChecks.Redis -Version 1.17.14Install-Package Hummingbird.Extensions.HealthChecks.Rabbitmq -Version 1.17.14Install-Package Hummingbird.Extensions.HealthChecks.MySql -Version 1.17.14Install-Package Hummingbird.Extensions.HealthChecks.SqlServer -Version 1.17.14

publicclassProgram{publicstaticvoidMain(string[]args){BuildWebHost(args).Run();}publicstaticIWebHostBuildWebHost(string[]args)=>WebHost.CreateDefaultBuilder(args).UseStartup<Startup>().UseHealthChecks("/healthcheck").ConfigureAppConfiguration((builderContext,config)=>{config.SetBasePath(Directory.GetCurrentDirectory());config.AddEnvironmentVariables();}).ConfigureLogging((hostingContext,logging)=>{logging.ClearProviders();}).Build();}

publicclassStartup{publicIConfigurationConfiguration{get;}// This method gets called by the runtime. Use this method to add services to the container.publicvoidConfigureServices(IServiceCollectionservices){services.AddHealthChecks(checks=>{checks.WithDefaultCacheDuration(TimeSpan.FromSeconds(5));checks.AddMySqlCheck("mysql","Server=localhost;Port=63307;Database=test; User=root;Password=123456;pooling=True;minpoolsize=1;maxpoolsize=100;connectiontimeout=180;SslMode=None");checks.AddSqlCheck("sqlserver","Data Source=localhost,63341;Initial Catalog=test;User Id=sa;Password=123456");checks.AddRedisCheck("redis","localhost:6379,password=123456,allowAdmin=true,ssl=false,abortConnect=false,connectTimeout=5000");checks.AddRabbitMQCheck("rabbitmq", factory=>{factory.WithEndPoint("192.168.109.2,192.168.109.3","5672"));factory.WithAuth("guest","guest");factory.WithExchange("/");});});}}

3.7 服务注册 + 服务发现 + 服务HTTP调用

3.7.1 基于Consul

Install-Package Hummingbird.DynamicRoute -Version 1.17.14Install-Package Hummingbird.LoadBalancers -Version 1.17.14Install-Package Hummingbird.Extensions.DynamicRoute.Consul -Version 1.17.14Install-Package Hummingbird.Extensions.Resilience.Http -Version 1.17.14

{"SERVICE_REGISTRY_ADDRESS":"localhost",// 注册中心地址"SERVICE_REGISTRY_PORT":"8500",//注册中心端口"SERVICE_SELF_REGISTER":true,//自注册开关打开"SERVICE_NAME":"SERVICE_EXAMPLE",//服务名称"SERVICE_ADDRESS":"","SERVICE_PORT":"80","SERVICE_TAGS":"test","SERVICE_REGION":"DC1","SERVICE_80_CHECK_HTTP":"/healthcheck","SERVICE_80_CHECK_INTERVAL":"15","SERVICE_80_CHECK_TIMEOUT":"15","SERVICE_CHECK_TCP":null,"SERVICE_CHECK_SCRIPT":null,"SERVICE_CHECK_TTL":"15","SERVICE_CHECK_INTERVAL":"5","SERVICE_CHECK_TIMEOUT":"5"}

publicclassProgram{publicstaticvoidMain(string[]args){BuildWebHost(args).Run();}publicstaticIWebHostBuildWebHost(string[]args)=>WebHost.CreateDefaultBuilder(args).UseStartup<Startup>().ConfigureAppConfiguration((builderContext,config)=>{config.SetBasePath(Directory.GetCurrentDirectory());config.AddJsonFile("appsettings.json");config.AddEnvironmentVariables();}).ConfigureLogging((hostingContext,logging)=>{logging.ClearProviders();}).Build();}

publicclassStartup{// This method gets called by the runtime. Use this method to add services to the container.publicvoidConfigureServices(IServiceCollectionservices){services.AddHummingbird(hummingbird=>{hummingbird// 服务注册到Consul.AddConsulDynamicRoute(Configuration, s=>{s.AddTags("version=v1");})// 设置弹性HTTP客户端（服务发现、超时、重试、熔断）.AddResilientHttpClient((orign,option)=>{varsetting=Configuration.GetSection("HttpClient");if(!string.IsNullOrEmpty(orign)){varorginSetting=Configuration.GetSection($"HttpClient:{orign.ToUpper()}");if(orginSetting.Exists()){setting=orginSetting;}}option.DurationSecondsOfBreak=int.Parse(setting["DurationSecondsOfBreak"]);option.ExceptionsAllowedBeforeBreaking=int.Parse(setting["ExceptionsAllowedBeforeBreaking"]);option.RetryCount=int.Parse(setting["RetryCount"]);option.TimeoutMillseconds=int.Parse(setting["TimeoutMillseconds"]);});});}}

usingHummingbird.Extensions.Resilience.Http;usingMicrosoft.AspNetCore.Mvc;usingSystem.Threading;usingSystem.Threading.Tasks;[Route("api/[controller]")]publicclassHttpClientTestController:Controller{privatereadonlyIHttpClienthttpClient;publicHttpClientTestController(IHttpClienthttpClient){this.httpClient=httpClient;}[HttpGet][Route("Test1")]publicasyncTask<string>Test1(){returnawaithttpClient.GetStringAsync("http://localhost:5001/healthcheck");}[HttpGet][Route("Test2")]publicasyncTask<string>Test2(){returnawait(awaithttpClient.PostAsync(uri:"http://{example}/healthcheck",item:new{},authorizationMethod:null,authorizationToken:null,dictionary:null,cancellationToken:CancellationToken.None)).Content.ReadAsStringAsync();}}

3.7.2 基于Nacos

Install-Package Hummingbird.DynamicRoute -Version 1.17.14Install-Package Hummingbird.LoadBalancers -Version 1.17.14Install-Package Hummingbird.Extensions.DynamicRoute.Nacos -Version 1.17.14Install-Package Hummingbird.Extensions.Resilience.Http -Version 1.17.14

{"Nacos": {"EndPoint":"","ServerAddresses": ["http://localhost:8848" ],"DefaultTimeOut":15000,"Namespace":"public","ListenInterval":1000,"ServiceName":"example","GroupName":"DEFAULT_GROUP","ClusterName":"DEFAULT","Ip":"","PreferredNetworks":"","Port":0,"Weight":100,"RegisterEnabled":true,"InstanceEnabled":true,"Ephemeral":true,"Secure":false,"AccessKey":"","SecretKey":"","UserName":"","Password":"","ConfigUseRpc":true,"NamingUseRpc":true,"NamingLoadCacheAtStart":"","LBStrategy":"WeightRandom",//WeightRandom WeightRoundRobin"Metadata": {"debug":"true","dev":""    }  }}

publicclassProgram{publicstaticvoidMain(string[]args){BuildWebHost(args).Run();}publicstaticIWebHostBuildWebHost(string[]args)=>WebHost.CreateDefaultBuilder(args).UseStartup<Startup>().ConfigureAppConfiguration((builderContext,config)=>{config.SetBasePath(Directory.GetCurrentDirectory());config.AddJsonFile("appsettings.json");config.AddEnvironmentVariables();}).ConfigureLogging((hostingContext,logging)=>{logging.ClearProviders();}).Build();}

publicclassStartup{// This method gets called by the runtime. Use this method to add services to the container.publicvoidConfigureServices(IServiceCollectionservices){services.AddHummingbird(hummingbird=>{hummingbird// 服务注册到Nacos.AddNacosDynamicRoute(Configuration, s=>{s.AddTags("version=v1");})// 设置弹性HTTP客户端（服务发现、超时、重试、熔断）.AddResilientHttpClient((orign,option)=>{varsetting=Configuration.GetSection("HttpClient");if(!string.IsNullOrEmpty(orign)){varorginSetting=Configuration.GetSection($"HttpClient:{orign.ToUpper()}");if(orginSetting.Exists()){setting=orginSetting;}}option.DurationSecondsOfBreak=int.Parse(setting["DurationSecondsOfBreak"]);option.ExceptionsAllowedBeforeBreaking=int.Parse(setting["ExceptionsAllowedBeforeBreaking"]);option.RetryCount=int.Parse(setting["RetryCount"]);option.TimeoutMillseconds=int.Parse(setting["TimeoutMillseconds"]);});});}}

usingHummingbird.Extensions.Resilience.Http;usingMicrosoft.AspNetCore.Mvc;usingSystem.Threading;usingSystem.Threading.Tasks;[Route("api/[controller]")]publicclassHttpClientTestController:Controller{privatereadonlyIHttpClienthttpClient;publicHttpClientTestController(IHttpClienthttpClient){this.httpClient=httpClient;}[HttpGet][Route("Test1")]publicasyncTask<string>Test1(){returnawaithttpClient.GetStringAsync("http://localhost:5001/healthcheck");}[HttpGet][Route("Test2")]publicasyncTask<string>Test2(){returnawait(awaithttpClient.PostAsync(uri:"http://{example}/healthcheck",item:new{},authorizationMethod:null,authorizationToken:null,dictionary:null,cancellationToken:CancellationToken.None)).Content.ReadAsStringAsync();}}

3.8 Canal 数据集成

Install-Package Hummingbird.Extensions.Canal -Version 1.17.14

{"Canal": {"Subscribes": [      {"Filter":".*\\..*","BatchSize":1024,"Format":"Hummingbird.Extensions.Canal.Formatters.CanalJson.Formatter,Hummingbird.Extensions.Canal",//MaxwellJsonFormatter,CanalJsonFormatter"Connector":"Hummingbird.Extensions.Canal.Connectors.ConsoleConnector,Hummingbird.Extensions.Canal","ConnectionInfo": {"Address":"localhost","Port":11111,"Destination":"test1","UserName":"","Passsword":""        }      }    ]  }}

publicclassProgram{publicstaticvoidMain(string[]args){BuildWebHost(args).Run();}publicstaticIWebHostBuildWebHost(string[]args)=>WebHost.CreateDefaultBuilder(args).UseStartup<Startup>().ConfigureAppConfiguration((builderContext,config)=>{config.SetBasePath(Directory.GetCurrentDirectory());config.AddJsonFile("canal.json");config.AddEnvironmentVariables();}).Build();}

publicclassConsoleSubscripter:ISubscripter{publicboolProcess(CanalEventEntry[]entrys){foreach(varentryinentrys){Console.WriteLine(Newtonsoft.Json.JsonConvert.SerializeObject(entry));}//ackreturntrue;}}

3.文件系统

Install-Package Hummingbird.Extensions.FileSystem -Version 1.0.0Install-Package Hummingbird.Extensions.FileSystem.Oss -Version 1.0.0Install-Package Hummingbird.Extensions.FileSystem.Physical -Version 1.0.0

{"FileSystem":{//本地文件系统"Physical":     {"DataPath":"/opt/data"      },//阿里云OSS"Oss":{//缓存 Oss 文件元数据"CacheOssFileMetaEnable":true,//元数据缓存过期时间(秒)"CacheOssFileMetaAbsoluteExpirationSeconds":600,//缓存本地目录("CacheLocalPath":"/opt/data",//文件缓存(开关)"CacheLocalFileEnabled":true,//文件缓存(大文件不进行缓存)"CacheLocalFileSizeLimit":20971520,// 文件缓存(通过命中次数计算是否热点)"CacheLocalFileIfHits":5,"EndpointName":"demo","Endpoints":{"demo": {"Endpoint":"oss-cn-shenzhen.aliyuncs.com","AccessKeyId":"xxxx","AccessKeySecret":"xxx","BucketName":"demo","ObjectPrefix":"/"        }      }    }  }}

publicclassStartup{publicvoidConfigureServices(IServiceCollectionservices){services.AddHummingbird(hb=>{//添加 OSS 文件系统hb.AddOssFileSystem(Configuration.GetSection("FileSystem:Oss"));});}publicvoidConfigure(IApplicationBuilderapp,IWebHostEnvironmentenv){app.UseMvc();varcontentTypeProvider=app.ApplicationServices.GetRequiredService<IContentTypeProvider>();varfileProvider=app.ApplicationServices.GetRequiredService<IFileProvider>();varstaticFileOptions=newStaticFileOptions{FileProvider=fileProvider,RequestPath="",ContentTypeProvider=contentTypeProvider};//使用静态文件app.UseStaticFiles(staticFileOptions);//使用 OSS 静态文件app.UseOssStaticFiles(staticFileOptions);}}

4. 如何快速部署开发环境

4.1Consul

4.2Apollo

4.3Mysql

4.4Redis

4.5Elasticsearch

4.6Kafka

4.7Rabbitmq

4.8Grafana

4.9Influxdb

4.10Jaeger

4.11Canal

4.12Nacos

5. 相关项目

5.1项目模板

6.联系方式