?2016-2026 Matools All rights reserved,
粵ICP備17059708號(hào)
簡(jiǎn)介
surging 經(jīng)過兩年多的研發(fā)，微服務(wù)引擎已經(jīng)略有雛形，也承蒙各位的厚愛， GitHub上收獲了將近2800星，fork
811,付費(fèi)用戶企業(yè)也有十幾家，還有咨詢培訓(xùn)，
在2020年，我們將依靠社區(qū)的力量，去完善社區(qū)版本，更會(huì)花更多的精力去維護(hù)好付費(fèi)用戶，大家一起把surging
的社區(qū)建設(shè)好，還有十幾天就要過年，大家可以加入surging唯一官方群:615562965, 過年的時(shí)候會(huì)和往常一樣發(fā)紅包，而且不少哦。讓我們過年狂歡起來。
?surging 將會(huì)有自己的官方站，作者正在用VuePress進(jìn)行研發(fā)，在不久的日子將會(huì)和大家見面
新功能簡(jiǎn)述
1.GRPC協(xié)議支持：
添加接口，將ServerCallContext參數(shù)的默認(rèn)值設(shè)置為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 { } }
?添加業(yè)務(wù)代碼，代碼如下：
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調(diào)用，代碼如下
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后臺(tái)托管守護(hù)程序
引擎支持WorkService后臺(tái)服務(wù)，可以支持RPC遠(yuǎn)程調(diào)用開啟，關(guān)閉，添加任務(wù)處理，代碼如下：
添加接口代碼如下：
[ServiceBundle("Background/{Service}")] public interface IWorkService :
IServiceKey { Task<bool> AddWork(Message message); Task StartAsync(); Task
StopAsync(); }
然后需要繼承BackgroundServiceBehavior，而且服務(wù)的生命周期設(shè)置為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.支持特性驗(yàn)證
支持接口特性驗(yàn)證，代碼如下
[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">用戶編號(hào)</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); }
支持模型特性驗(yàn)證，接口方法一定要添加?[Validate]特性，要不然不會(huì)進(jìn)行驗(yàn)證，代碼如下
[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; } }
總結(jié)
開源不易，請(qǐng)大家多多支持
?
熱門工具 換一換