net core ΢·þÎñ¿ò¼Ü Viper µ÷ÓÃÁ´Â·×·×Ù
1¡¢ViperÊÇʲô£¿
¡¡¡¡Viper ÊÇ.NETƽ̨ϵÄAnno΢·þÎñ¿ò¼ÜµÄÒ»¸öʾÀýÏîÄ¿¡£ÈëÃżòµ¥¡¢°²È«¡¢Îȶ¨¡¢¸ß¿ÉÓá¢È«Æ½Ì¨¿É¼à¿Ø¡£µ×²ãͨѶ¿ÉÒÔËæÒâÇл»thrift grpc¡£ ×Ô´ø·þÎñ·¢ÏÖ¡¢µ÷ÓÃÁ´×·×Ù¡¢Cron µ÷¶È¡¢ÏÞÁ÷¡¢Ê¼þ×ÜÏß¡¢CQRS ¡¢DDD¡¢ÀàËÆMVCµÄ¿ª·¢ÌåÑ飬²å¼þ»¯¿ª·¢
¡¡¡¡Ò»¸ö²»¿É¼à¿ØµÄ΢·þÎñƽ̨ÊÇ¿Éŵģ¬³öÁËÎÊÌâ ÄÑÒÔ׼ȷ¶¨Î»ÎÊÌâµÄ¸ùÔ´£¬ AnnoÔòÌṩÁËÒ»Ì×ÍêÕûµÄ¼à¿ØÌåϵ£¬°üÀ¨Á´Â·×·×Ù¡¢·þÎñÕ¼ÓõÄϵͳ×ÊÔ´¡¢ÏµÍ³×ÔÉí CPU¡¢ÄÚ´æ¡¢Ó²ÅÌʹÓÃÂÊʵʱ¿É¼à¿ØµÈµÈ¡£
github:
https://github.com/duyanming/Viper
ÎĵµµØÖ·:
https://duyanming.github.io/
ÌåÑéµØÖ·:£¨ÌåÑéÓû§Îªanno ÃÜÂë123456 ͬһʱ¼äÒ»¸öÓû§Ö»ÄÜÔÚÒ»¸öÖն˵ǼÓû§¶àµÄʱºò¿ÉÄÜ·¢ÉúÇ¿ÖÆÍ˳öµÄÇé¿ö£¬ÉÔºóµÇ¼ÌåÑ飩
http://140.143.207.244/
Èç¹û¶ÔViper²»Á˽â¿ÉÒÔ¿´£º
¡¡¡¡1¡¢ net core ΢·þÎñ ¿ìËÙ¿ª·¢¿ò¼Ü Viper ³õÌåÑé
¡¡¡¡2¡¢´ò²»ËÀµÄСǿ .net core ΢·þÎñ ¿ìËÙ¿ª·¢¿ò¼Ü Viper ÏÞÁ÷
2¡¢Viperµ÷ÓÃÁ´×·×Ù¡¡
¡¡¡¡ViperΪ·þÎñÖ®¼äµ÷ÓÃÌṩÁËÒ»Ì×ÍêÉƵÄÁ´Â·×·×ÙÌåϵ¡£Í¨¹ýViper¿ÉÒÔÇåÎúµÄ¿´µ½Ò»¸öµ÷ÓÃÁ´£¨Ò»´365betÌåÓýÔÚÏßµÎñ²Ù×÷£©¾¹ýÁËÄÄЩ΢·þÎñ¡¢365ÌåÓýͶע·þÎñÏûºÄ¶àÉÙʱ¼ä¡¢ÊÇ·ñ³öÏÖÒì³£¡¢´¦Àí½á¹ûÈçºÎµÈµÈ¡£Í¨¹ýÁ´Â·×·×ÙÌåϵ¿ÉÒÔ·ÖÎöÕû¸öÒµÎñµÄ״̬£¬±ÈÈçÄǸö·þÎñ»òÕßÒµÎñ²Ù×÷ºÄʱÒì³£ÐèÒªÓÅ»¯£¬¿ìËÙ¶¨Î»ÎÊÌâ½â¾öÎÊÌâ¡£´Ó¶ø¸üºÃµÄΪÕû¸ö΢·þÎñÌåϵ·þÎñ¡£
¡¡¡¡²»½öÈç´Ë»¹¿ÉÒÔ°ïÖú¹«Ë¾ÐÂÈëÖ°Ô±¹¤ÊáÀíÊáÀíÒµÎñÂöÂ磬Ã÷°××Ô¼ºËù´¦ÔÚµÄÒµÎñ»·½Ú¡¢Ô¤²âϵͳ¿ÉÄÜ·¢ÉúµÄÒþ»¼£¬Ôç·¢ÏÖÔç½â¾ö£¬·À»¼ÓÚδȻ¡£
Á´Â·×·×ÙÁÐ±í£º
µ¥¸öÁ´Â·×·×ÙʾÀý£º
¡¡¡¡ÏÂÃæÕâ¸öµ÷ÓÃÁ´Â·Îª£º
¡¡¡¡¡¡
¡¡¡¡Õû¸öµ÷ÓÃÁ´Â·»¨·Ñ22ºÁÃ룬×îºóÁ½¸öµ÷ÓÃΪ²¢ÐС£
3¡¢Viper&Anno Ô¶³Ì¹ý³Ìµ÷Óã¨RPC£©
¡¡¡¡Anno ¿ò¼Üµ×²ãRpc²ÉÓÃÁ˳ÉÊìµÄ thrift(Ê×Ñ¡ÍƼö)¡¢grpc£¬ËûÃǶ¼ÓÐןßÐÔÄÜ¡¢¿çÓïÑÔµÄÌص㣬Òò´ËAnno¿ò¼ÜÒ²ÊÇÒ»¸ö¿çÓïÑԵģ¬¿ÉÒÔÇáËÉʵÏÖ»ìºÏ±à³ÌµÄ¿ò¼Ü¡£Ä¿Ç°Ö§³Ö.net core¡¢.net framework¡¢java£¬¸ü¶àµÄʵÏÖÆÚ´ý´ó¼Ò¹²Í¬Å¬Á¦Ò»Æð¹±Ïס£
¡¡¡¡ThriftÊÇ365ÌåÓýͶע½Ó¿ÚÃèÊöÓïÑԺͶþ½øÖÆͨѶÐÒ飬Ëü±»ÓÃÀ´¶¨ÒåºÍ´´½¨¿çÓïÑԵķþÎñ¡£Ëü±»µ±×÷Ò»¸öÔ¶³Ì¹ý³Ìµ÷Óã¨RPC£©¿ò¼ÜÀ´Ê¹Óã¬ÊÇÓÉFacebookΪ¡°´ó¹æÄ£¿çÓïÑÔ·þÎñ¿ª·¢¡±¶ø¿ª·¢µÄ¡£Ä¿Ç°ÍйÜÔÚApache£¬¸ü¶àÏêϸ¿É·ÔÄÍøÉÏ×ÊÁÏ¡£
¡¡¡¡
¡¡¡¡grpc ÊÇÒ»¸ö¸ßÐÔÄÜ¡¢¿ªÔ´ºÍͨÓÃµÄ RPC ¿ò¼Ü£¬ÃæÏòÒƶ¯ºÍ HTTP/2 Éè¼Æ¡£Ä¿Ç°Ìṩ C¡¢Java ºÍ Go ÓïÑÔ°æ±¾£¬·Ö±ðÊÇ£ºgrpc, grpc-java, grpc-go. ÆäÖÐ C °æ±¾Ö§³Ö C, C++, Node.js, Python, Ruby, Objective-C, PHP ºÍ C# Ö§³Ö.
¡¡¡¡gRPC »ùÓÚ HTTP/2 ±ê×¼Éè¼Æ£¬´øÀ´ÖîÈçË«ÏòÁ÷¡¢Á÷¿Ø¡¢Í·²¿Ñ¹Ëõ¡¢µ¥ TCP Á¬½ÓÉϵĶิÓÃÇëÇóµÈÌØ¡£ÕâЩÌØÐÔʹµÃÆäÔÚÒƶ¯É豸ÉϱíÏÖ¸üºÃ£¬¸üÊ¡µçºÍ½ÚÊ¡¿Õ¼äÕ¼Óá£
ÒÔThriftΪÀýÀ´Á˽âAnno¿ò¼Ü
¡¡¡¡Anno¿ò¼ÜµÄ Thrift½Ó¿ÚÃèÊöÎļþ£º
namespace csharp Anno.Rpc # ÃüÃû¿Õ¼ä struct Micro { # ·þÎñÐÅÏ¢ 1: string ip 2: i32 port 3: i32 timeout 4: string name 5: string nickname 6: i32 weight } service BrokerService { # Provider·þÎñ string broker(1:map<string,string> input) } service BrokerCenter { # ×¢²áÖÐÐÄ bool add_broker(1:map<string,string> input) list<Micro> GetMicro(1:string channel) string Invoke(1:map<string,string> input) }
·þÎñÖ®¼äͨѶµÄ½Ó¿ÚΪ string broker(1:map<string,string> input)£¬·þÎñÖ®¼äͨѶ²ÉÓõÄÊÇ ThriftµÄ ¶þ½øÖÆ´«Êä¡£
/// <summary> /// Engine ³£Á¿ /// </summary> public static class Eng { /// <summary> /// ÃüÃû¿Õ¼ä /// </summary> public const string NAMESPACE = "channel"; /// <summary> /// Àà /// </summary> public const string CLASS = "router"; /// <summary> /// ·½·¨ /// </summary> public const string METHOD = "method"; }
channel¡¢router¡¢method´ËÈý¸ö²ÎÊýÊÇÔ¶³Ì¹ý³Ìµ÷Óùý³ÌÖеıØÐë²ÎÊý¡£
ÒÔ²å¼þ Anno.Plugs.LogicServiceΪÀý
namespace Anno.Plugs.LogicService { using Anno.CommandBus; public class PlatformModule : BaseModule { --------------Ê¡ÂÔ------------------- /// <summary> /// »ñÈ¡Óû§¹¦ÄÜ /// </summary> /// <returns></returns> [AnnoInfo(Desc = "»ñÈ¡Óû§¹¦ÄÜ")] public ActionResult GetFunc() { return _platformQuery.GetFunc(Profile); } } }
channel ¶ÔÓ¦£ºAnno.Plugs.Logic
router ¶ÔÓ¦£ºPlatform
method ¶ÔÓ¦£ºGetFunc
±£Áô¹Ø¼ü×Ö£ºTraceId,PreTraceId,AppName,AppNameTarget,GlobalTraceId,TTL,X-Original-For
TraceId£ºÒ»´ÎRpcµ÷ÓóÉΪһ¸öspan£¬Õâ¸öµ÷ÓõÄΨһ±êʶΪTraceId
PreTraceId£º·þÎñÖ®¼äÏ໥µ÷ÓõÄʱºòPreTraceIdÓÃÀ´±êʶ¸¸×Ó¹ØϵµÄ¸¸TraceId
AppName£ºµ±Ç°·þÎñÃû³Æ
AppNameTarget£ºÄ¿±ê·þÎñÃû³Æ
GlobalTraceId£ºÒ»´ÎÓû§²Ù×÷»òÕßÊÇϵͳÈËÎï³ÉΪһ¸öµ÷ÓÃÁ´£¬Õâ¸öµ÷ÓÃÁ´µÄΨһ±êʶΪGlobalTraceId
TTL£º¿çÔ½µÄ·þÎñ´ÎÊý
X-Original-For£ºwebµ÷ÓõÄʱºòµÄÓû§IP
2¡¢Viperµ÷ÓÃÁ´×·×ÙÌåϵ½âÎö
¡¡¡¡ViperµÄµ÷ÓÃÁ´Ê½ÄÚǶÔÚ Anno.Rpc.ClientÖеģ¬Rpcµ÷ÓÃ֮ǰ´´½¨×·×Ù¶ÔÏósys_trace¼Ç¼Request²ÎÊý£¬µ÷ÓÃÍê³ÉÖ®ºóÍêÉÆÏìÓ¦Response½á¹û²¢ÇÒ°Ñ×·×Ù¶ÔÏósys_traceдÈëÄÚ´æ¶ÓÁÐÖС£È»ºó¶¨Ê±¶¨Á¿·¢Ë͵½×·×Ù·þÎñÆ÷¡£
α´úÂëÈçÏ£º
¡¡¡¡/// <summary> /// ×·×Ù¶ÓÁÐ³Ø /// </summary> public static class TracePool {
¡¡¡¡¡¡¡¡¡¡//ÄÚ´æ¶ÓÁÐ private static ConcurrentQueue<sys_trace> TraceQueue { get; set; } = new ConcurrentQueue<sys_trace>(); ¡¡¡¡¡¡¡¡¡¡//ÒµÎñ´¦ÀíºóÍÆËÍ×·×Ù¶ÔÏóµ½ÄÚ´æ¶ÓÁÐ TraceQueue public static void EnQueue(sys_trace trace, string result) { if (trace != null) { trace.UseTimeMs = (DateTime.Now - trace.Timespan).TotalMilliseconds; trace.Response = result; TraceQueue.Enqueue(trace); } }
¡¡¡¡¡¡¡¡¡¡//´´½¨×·×Ù¶ÔÏó public static sys_trace CreateTrance(Dictionary<string, string> input) { return new sys_trace() { Timespan = DateTime.Now, InputDictionary = input }; } /// <summary> /// ÅúÁ¿·¢Ë͵÷ÓÃÁ´µ½ ×·×Ù·þÎñÆ÷£¨¶¨Ê±ÈÎÎñ»á¶¨Ê±µ÷ÓÃTryDequeue£© /// </summary> internal static void TryDequeue() { if (TraceQueue.IsEmpty) { return; } List<sys_trace> traces = new List<sys_trace>(); ReTryDequeue: while (!TraceQueue.IsEmpty && traces.Count < 100) { TraceQueue.TryDequeue(out sys_trace trace);
¡¡¡¡ ------------ת»»×·×Ù¶ÔÏó--------------if (trace.Rlt) { trace.Response = null; } traces.Add(trace); } if (traces.Count <= 0) { return; } Dictionary<string, string> inputTrace = new Dictionary<string, string> { {Const.Enum.Eng.NAMESPACE, "Anno.Plugs.Trace"}, {Const.Enum.Eng.CLASS, "Trace"}, {Const.Enum.Eng.METHOD, "TraceBatch"}, {"traces", Newtonsoft.Json.JsonConvert.SerializeObject(traces)} };
¡¡¡¡¡¡¡¡¡¡¡¡¡¡//·¢ËÍ×·×ÙÊý¾Ý Connector.BrokerDns(inputTrace); if (!TraceQueue.IsEmpty) { traces.Clear(); goto ReTryDequeue; } } }
Viper
github:
https://github.com/duyanming/Viper
ÎĵµµØÖ·:
https://duyanming.github.io/
ÌåÑéµØÖ·:£¨ÌåÑéÓû§Îªanno ÃÜÂë123456 ͬһʱ¼äÒ»¸öÓû§Ö»ÄÜÔÚÒ»¸öÖն˵ǼÓû§¶àµÄʱºò¿ÉÄÜ·¢ÉúÇ¿ÖÆÍ˳öµÄÇé¿ö£¬ÉÔºóµÇ¼ÌåÑ飩
http://140.143.207.244/
¹ØÓÚViperµÄ¸ü¶àÄÚÈÝ£¬Ëæºó¸üС£¾´Çë¹Ø×¢¡£¿ªÔ´²»Ò×£¬¸ÐлStar¡£