簡介 surging 經過兩年多的研發，微服務引擎已經略有雛形，也承蒙各位的厚愛， GitHub上收穫了將近2800星，fork 811,付費用戶企業也有十幾家，還有咨詢培訓， 在2020年，我們將依靠社區的力量，去完善社區版本，更會花更多的精力去維護好付費用戶，大家一起把surging 的社區建設 ...
簡介
surging 經過兩年多的研發，微服務引擎已經略有雛形，也承蒙各位的厚愛， GitHub上收穫了將近2800星，fork 811,付費用戶企業也有十幾家，還有咨詢培訓，
在2020年，我們將依靠社區的力量，去完善社區版本，更會花更多的精力去維護好付費用戶，大家一起把surging 的社區建設好，還有十幾天就要過年，大家可以加入surging唯一官方群:615562965, 過年的時候會和往常一樣發紅包，而且不少哦。讓我們過年狂歡起來。
surging 將會有自己的官方站，作者正在用VuePress進行研發，在不久的日子將會和大家見面
新功能簡述
1.GRPC協議支持：
添加介面，將ServerCallContext參數的預設值設置為null。 代碼如下：
using Greet; using Grpc.Core; using Surging.Core.CPlatform.Ioc; using Surging.Core.CPlatform.Runtime.Server.Implementation.ServiceDiscovery.Attributes; using System.Threading.Tasks; namespace Surging.IModuleServices.Common { [ServiceBundle("api/{Service}/{Method}")] public interface IGreeterService : IServiceKey { Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context=null); } }
添加GreeterBehavior，代碼如下
using Greet;
using Surging.Core.CPlatform.Ioc;
namespace Surging.Modules.Common.GreeterServices
{
public partial class GreeterBehavior : Greeter.GreeterBase,IServiceBehavior
{
}
}
添加業務代碼，代碼如下：
using Greet; using Grpc.Core; using Surging.IModuleServices.Common; using Surging.Modules.Common.GreeterServices; using System.Threading.Tasks; namespace Surging.Modules.Common.Domain { public class GreeterService: GreeterBehavior, IGreeterService { public override Task<HelloReply> SayHello(HelloRequest request, ServerCallContext context) { return Task.FromResult(new HelloReply { Message = "Hello " + request.Name }); } } }
客戶端GRPC調用，代碼如下
using Greet; using Grpc.Core; using System; namespace GrpcService1 { public class Program { public static void Main(string[] args) { var channel = new Channel("127.0.0.1", 95, ChannelCredentials.Insecure); var client = new Greeter.GreeterClient(channel); var result = client.SayHello(new HelloRequest { Name = "fanly" }); Console.WriteLine("grpc Client Call SayHello():" + result); Console.ReadKey(); } } }
2.支持WorkService後臺托管守護程式
引擎支持WorkService後臺服務，可以支持RPC遠程調用開啟，關閉，添加任務處理，代碼如下：
添加介面代碼如下：
[ServiceBundle("Background/{Service}")] public interface IWorkService : IServiceKey { Task<bool> AddWork(Message message); Task StartAsync(); Task StopAsync(); }
然後需要繼承BackgroundServiceBehavior，而且服務的生命周期設置為ISingleInstance
public class WorkService : BackgroundServiceBehavior, IWorkService, ISingleInstance { private readonly ILogger<WorkService> _logger; private readonly Queue<Message> _queue = new Queue<Message>(); private readonly IServiceProxyProvider _serviceProxyProvider; private CancellationToken _token; public WorkService(ILogger<WorkService> logger, IServiceProxyProvider serviceProxyProvider) { _logger = logger; _serviceProxyProvider = serviceProxyProvider; } public Task<bool> AddWork(Message message) { _queue.Enqueue(message); return Task.FromResult(true); } protected override async Task ExecuteAsync(CancellationToken stoppingToken) { try { _token = stoppingToken; _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now); _queue.TryDequeue(out Message message); if (message != null) { var result = await _serviceProxyProvider.Invoke<object>(message.Parameters, message.RoutePath, message.ServiceKey); _logger.LogInformation("Invoke Service at: {time},Invoke result:{result}", DateTimeOffset.Now, result); } if (!_token.IsCancellationRequested) await Task.Delay(1000, stoppingToken); } catch (Exception ex){ _logger.LogError("WorkService execute error, message：{message} ,trace info:{trace} ", ex.Message, ex.StackTrace); } } public async Task StartAsync() { if (_token.IsCancellationRequested) { await base.StartAsync(_token); } } public async Task StopAsync() { if (!_token.IsCancellationRequested) { await base.StopAsync(_token); } } }
3.支持特性驗證
支持介面特性驗證，代碼如下
[ServiceBundle("api/{Service}/{Method}")] //[ServiceBundle("api/{Service}")] //[ServiceBundle("api/{Service}/{Method}/test")] //[ServiceBundle("api/{Service}/{Method}/test",false)] public interface IUserService: IServiceKey { /// <summary> /// 獲取用戶姓名 /// </summary> /// <param name="id">用戶編號</param> /// <returns></returns> [ServiceRoute("{id}")] Task<string> GetUserName([Validate] [Range(1, 10, ErrorMessage = "只能為1到10")] int id); /// <summary> /// 獲取用戶 /// </summary> /// <param name="user">用戶模型</param> /// <returns></returns> [Command(Strategy = StrategyType.Injection, Injection = @"return new Surging.IModuleServices.Common.Models.UserModel { Name=""fanly"", Age=19 };", RequestCacheEnabled = true, InjectionNamespaces = new string[] { "Surging.IModuleServices.Common" })] [InterceptMethod(CachingMethod.Get, Key = "GetUser_id_{0}", CacheSectionType = SectionType.ddlCache, Mode = CacheTargetType.Redis, Time = 480)] [Validate] Task<UserModel> GetUser(UserModel user); }
支持模型特性驗證，介面方法一定要添加 [Validate]特性，要不然不會進行驗證，代碼如下
[ProtoContract] public class UserModel { [ProtoMember(1)] [CacheKey(1)] public int UserId { get; set; } [ProtoMember(2)] public string Name { get; set; } [ProtoMember(3)] [Range(0, 150, ErrorMessage = "年齡只能在0到150歲之間")] public int Age { get; set; } [ProtoMember(4)] [Range(0, 1, ErrorMessage = "性別隻能選男或女")] public Sex Sex { get; set; } }
總結
開源不易，請大家多多支持
