微服务全家桶FamilyBucket应用框架

FamilyBucket 是一个集合多个组件应用形成的微服务一体化的全套应用框架。

各组件源码： https://github.com/q315523275/FamilyBucket
UI源码： https://github.com/q315523275/FamilyBucket-UI
部分服务源码： https://github.com/q315523275/FamilyBucket-Server
博客园地址： https://www.cnblogs.com/tianxiangzhe/p/10212337.html
Nuget： Bucket.XXX

---

特性

• 没啥特性

各组件矩阵

组件	状态	说明
微服务网关	维护中	使用ocelot服务网关，扩展配置存储方式、子服务dotnetty通信
认证授权组件	维护中	jwt无状态认证方式，动态权限控制
缓存组件	维护中	多种缓存方式实现，本地缓存、redis缓存
配置中心	维护中	提供系统组件、业务等配置信息获取
错误码	维护中	提供系统错误、业务错误等错误码对外的描述信息获取
事件总线	维护中	使用RabbitMQ实现，可用于分布式事务
分布式调度任务	使用中	使用Hangfire分布式调度系统
命令监听	维护中	使用Redis、Zookeeper实现命令监听，用于组件命令接收，如缓存更新清除
日志收集	维护中	对原生日志组件实现扩展，支持Log4Net、NLog、自定义日志 MQ传输(扩展告警系统)
ORM	维护中	基于SqlSugar实现多库读写分离、数据仓储
RPC	升级中	基于DotNetty实现Rpc应用(网关通信扩展)，gRpc连接管理
服务发现	维护中	基于Consul实现服务发现、自动注册注销，服务负载计算
链路追踪	维护中	请求链路追踪，由于资源关系对SkyAPM net客户端进行部分修改
工具组件	维护中	常用工具类、验证码、拼音、分词
WebSocket	维护中	原生WebSocket扩展实现，易于扩展与自定义
告警系统	未开放	应用异常实时告警系统，多大屏展示、多种通知方式
应用监控	开发中	应用对应cup、内存、gc、http、并发、异常等数据监控与上报
AspNetCode应用组件	升级中	应用程序组件，用户上下文、健康检查接口、Controller基类、 批量注册、全局异常拦截、ip白名单访问、模型验证、 限速限流、熔断降级等持续开发中...
框架后台管理	升级中	管理框架信息，网关监控路由配置、应用监控与查询管理、 配置中心管理、错误码管理、链路监控与管理、日志管理、通用后台功能管理等

---

各组件使用

webapi与控制台使用示例，源码： https://github.com/q315523275/FamilyBucket/tree/master/src/Sample

        /// <summary>
        /// 配置服务
        /// </summary>
        public void ConfigureServices(IServiceCollection services)
        {
            // 添加全家桶服务
            services.AddFamilyBucket(familyBucket =>
            {
                // 添加AspNetCore基础服务
                familyBucket.AddAspNetCore();
                // 添加授权认证
                familyBucket.AddApiJwtAuthorize().UseAuthoriser(builder => { builder.UseMySqlAuthorize(); });
                // 添加数据ORM、数据仓储
                familyBucket.AddSqlSugarDbContext().AddSqlSugarDbRepository();
                // 添加错误码服务
                familyBucket.AddErrorCodeServer();
                // 添加配置服务
                familyBucket.AddConfigServer();
                // 添加事件驱动
                familyBucket.AddEventBus(builder => { builder.UseRabbitMQ(); });
                // 添加服务发现
                familyBucket.AddServiceDiscovery(builder => { builder.UseConsul(); });
                // 添加负载算法
                familyBucket.AddLoadBalancer();
                // 添加事件队列日志和告警信息
                familyBucket.AddLogEventTransport();
                // 添加链路追踪
                familyBucket.AddBucketSkyApmCore().UseEventBusTransport();
                // 添加缓存组件
                familyBucket.AddCaching(build =>
                {
                    build.UseInMemory("default");
                    build.UseStackExchangeRedis(new Caching.StackExchangeRedis.Abstractions.StackExchangeRedisOption
                    {
                        Configuration = "10.10.188.136:6379,allowadmin=true",
                        DbProviderName = "redis"
                    });
                });
                // 添加工具组件
                familyBucket.AddUtil();
                // 添加组件定时任务
                familyBucket.AddAspNetCoreHostedService(builder => { builder.AddConfig().AddErrorCode().AddAuthorize(); });
                // 添加组件任务订阅
                familyBucket.AddListener(builder => { builder.UseRedis().AddAuthorize().AddConfig().AddErrorCode(); }); // builder.UseZookeeper();
                // 添加应用批量注册
                familyBucket.BatchRegisterService(Assembly.Load("Bucket.Demo.Repository"), "Repository", ServiceLifetime.Scoped);
                // 添加DotNetty_Rpc使用
                familyBucket.AddRpcCore().UseDotNettyTransport().UseMessagePackCodec().AddClientRuntime().AddServiceProxy(); //.UseProtoBufferCodec()
            });
            // 添加过滤器
            services.AddMvc(option => { option.Filters.Add(typeof(WebApiActionFilterAttribute)); }).AddJsonOptions(options =>
            {
                options.SerializerSettings.ContractResolver = new DefaultContractResolver();
                options.SerializerSettings.DateFormatString = "yyyy-MM-dd HH:mm:ss.fff";
            }).SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
            // 添加接口文档
            services.AddSwaggerGen(c =>
            {
                c.SwaggerDoc("v1", new Info { Title = "微服务全家桶接口服务", Version = "v1" });
                c.IncludeXmlComments(Path.Combine(AppContext.BaseDirectory, "Bucket.WebApi.xml"));
                c.CustomSchemaIds(x => x.FullName);
                // Swagger验证部分
                c.AddSecurityDefinition("Bearer", new ApiKeyScheme { In = "header", Description = "请输入带有Bearer的Token", Name = "Authorization", Type = "apiKey" });
                c.AddSecurityRequirement(new Dictionary<string, IEnumerable<string>> { { "Bearer", Enumerable.Empty<string>() } });
            });
            // 添加HttpClient管理
            services.AddHttpClient();
            // 添加业务组件注册

            // 添加事件消息
            RegisterEventBus(services);
            // 注册调度任务
            RegisterScheduler(services);
        }

---

性能与稳定

• 追求极限性能其实不应该使用微服务框架，独立应用对外提供服务最好
• 网关ocelot虽然有很多功能，但是尽量只当作路由来用不要把过多功能放在网关应用，目前平均一个请求2ms左右延时
• 提供一个高可用的服务涉及到很多很多，一定要预防好级联雪崩情况
• 太多了

---

VNext

• 灰度发布方案