FamilyBucket

集合.net core、ocelot、consul、netty、rpc、eventbus、configserver、tracing、sqlsugar、vue-admin、基础管理平台等构建的微服务一条龙应用

Generate Convert Improve

Install / Use

/learn @q315523275/FamilyBucket

About this skill

Quality Score

0/100

README

微服务全家桶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、自定义日志<br />MQ传输(扩展告警系统) | | ORM | 维护中 | 基于SqlSugar实现多库读写分离、数据仓储 | | RPC | 升级中 | 基于DotNetty实现Rpc应用(网关通信扩展)，gRpc连接管理 | | 服务发现 | 维护中 | 基于Consul实现服务发现、自动注册注销，服务负载计算 | | 链路追踪 | 维护中 | 请求链路追踪，由于资源关系对SkyAPM net客户端进行部分修改 | | 工具组件 | 维护中 | 常用工具类、验证码、拼音、分词 | | WebSocket | 维护中 | 原生WebSocket扩展实现，易于扩展与自定义 | | 告警系统 |未开放| 应用异常实时告警系统，多大屏展示、多种通知方式 | | 应用监控 | 开发中 | 应用对应cup、内存、gc、http、并发、异常等数据监控与上报 | | AspNetCode应用组件 |升级中|应用程序组件，用户上下文、健康检查接口、Controller基类、<br />批量注册、全局异常拦截、ip白名单访问、模型验证、<br />限速限流、熔断降级等持续开发中...| | 框架后台管理|升级中|管理框架信息，网关监控路由配置、应用监控与查询管理、<br />配置中心管理、错误码管理、链路监控与管理、日志管理、通用后台功能管理等|

各组件使用

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);
        }