自行實現 dotnet core rpc
前言
小李：「胖子，上頭叫你對接個人數據好了沒有？」html
胖子：「那是你的事，你都不提供數據源，我咋接？」linux
小李：「你想要什麼樣的數據源？」git
胖子：「我想要一個調用簡單點的！」github
小李：「我這個數據源是在linux平臺使用docker封裝發佈的，webapi的怎麼樣？」web
胖子：「也行，這項目工期快用完了，你得提供api封裝sdk，另外我這邊對性能有要求的！」docker
小李：「webapi多好，基於json各個平臺都能對接，性能還不錯的！」json
胖子：「我只關心個人業務，不是個人業務代碼，多一行我都不想碼，否則沒按時完成算你的！另外用webapi到時候請求量一大，到時候端口用完了，鏈接不了這鍋也得你背！」api
小李：「我@##￥%*#￥@#&##@……」數組
面對胖子這些說辭，小李內心面雖然一萬隻草泥馬在奔騰，可是項目仍是要完成是不？另外胖子說的也不無道理！小李做爲一個在C#下侵淫多年老鳥，很快想出一個辦法——rpc！首先固然是選wcf，這個巨硬的企業級產品在快速開發上除了配置上坑爹了一點，針對客戶端的對接真的很是快。小李仔細一研究wcf service 發現目前在linux下玩不了，內心面又是了一陣@##￥%*#￥@#&##@……緩存
胖子：「小李糾結啥，要不就弄個三方的搞一下算了，就算出事了，你說不定都已經離職了，怕啥……」
看着胖子一臉猥瑣的表情，小李那是一個氣啊，就怪自已平時牛逼吹上天，這時候怎麼好慫呢，一咬牙：「你放心，誤不了你的事！」。小李一邊回覆，內心面開始盤算着自行實現一個功能簡易，性能高效，使用簡單的rpc了。
上面小李與胖子的場景，在開發的時候也是經典案例，回到正題來：本人認爲rpc主要是：調用方法及參數序列化、socket傳輸、調用方法及參數反序列化、映射到本地並採用與請求相同流程迴應客戶端的一套方案。其中關鍵點簡單分析主要有：序列化與反序列化、高性能tcp、遠程方法反轉、客戶端代碼生成四個方面；tcp仍是使用iocp好了，其餘接着一一分析。
序列化與反序列化
序列化與反序列化這個選二進制通常比json的好，ms版的BinaryFormatter 通用性強，可是他的性能、model的標記寫法等估計又要被噴了；找到Expression序列化，結果仍是走的相似於soap xml這一套，想一想算了：本地方法調用都是納秒級的，io都是毫秒級別的，socket的一次就傳這麼傳這麼大一堆，就算局域網也傷不起呀，想輕量化提高性能都難，自行實現一個簡單的好了。
1 /**************************************************************************** 2 *Copyright (c) 2018 Microsoft All Rights Reserved. 3 *CLR版本： 4.0.30319.42000 4 *機器名稱：WENLI-PC 5 *公司名稱：Microsoft 6 *命名空間：SAEA.RPC.Serialize 7 *文件名： SerializeUtil 8 *版本號： V1.0.0.0 9 *惟一標識：9e919430-465d-49a3-91be-b36ac682e283 10 *當前的用戶域：WENLI-PC 11 *建立人： yswenli 12 *電子郵箱：wenguoli_520@qq.com 13 *建立時間：2018/5/22 13:17:36 14 *描述： 15 * 16 *===================================================================== 17 *修改標記 18 *修改時間：2018/5/22 13:17:36 19 *修改人： yswenli 20 *版本號： V1.0.0.0 21 *描述： 22 * 23 *****************************************************************************/ 24 using SAEA.RPC.Model; 25 using System; 26 using System.Collections.Generic; 27 using System.Text; 28 29 namespace SAEA.RPC.Serialize 30 { 31 /// <summary> 32 /// rpc參數序列化處理 33 /// </summary> 34 public class ParamsSerializeUtil 35 { 36 /// <summary> 37 /// len+data 38 /// </summary> 39 /// <param name="param"></param> 40 /// <returns></returns> 41 public static byte[] Serialize(object param) 42 { 43 List<byte> datas = new List<byte>(); 44 45 var len = 0; 46 byte[] data = null; 47 48 if (param == null) 49 { 50 len = 0; 51 } 52 else 53 { 54 if (param is string) 55 { 56 data = Encoding.UTF8.GetBytes((string)param); 57 } 58 else if (param is byte) 59 { 60 data = new byte[] { (byte)param }; 61 } 62 else if (param is bool) 63 { 64 data = BitConverter.GetBytes((bool)param); 65 } 66 else if (param is short) 67 { 68 data = BitConverter.GetBytes((short)param); 69 } 70 else if (param is int) 71 { 72 data = BitConverter.GetBytes((int)param); 73 } 74 else if (param is long) 75 { 76 data = BitConverter.GetBytes((long)param); 77 } 78 else if (param is float) 79 { 80 data = BitConverter.GetBytes((float)param); 81 } 82 else if (param is double) 83 { 84 data = BitConverter.GetBytes((double)param); 85 } 86 else if (param is DateTime) 87 { 88 var str = "wl" + ((DateTime)param).Ticks; 89 data = Encoding.UTF8.GetBytes(str); 90 } 91 else if (param is byte[]) 92 { 93 data = (byte[])param; 94 } 95 else 96 { 97 var type = param.GetType(); 98 99 if (type.IsGenericType || type.IsArray) 100 { 101 data = SerializeList((System.Collections.IEnumerable)param); 102 } 103 else if (type.IsGenericTypeDefinition) 104 { 105 data = SerializeDic((System.Collections.IDictionary)param); 106 } 107 else if (type.IsClass) 108 { 109 var ps = type.GetProperties(); 110 111 if (ps != null && ps.Length > 0) 112 { 113 List<object> clist = new List<object>(); 114 115 foreach (var p in ps) 116 { 117 clist.Add(p.GetValue(param)); 118 } 119 data = Serialize(clist.ToArray()); 120 } 121 } 122 } 123 len = data.Length; 124 } 125 datas.AddRange(BitConverter.GetBytes(len)); 126 if (len > 0) 127 { 128 datas.AddRange(data); 129 } 130 return datas.Count == 0 ? null : datas.ToArray(); 131 } 132 133 134 private static byte[] SerializeList(System.Collections.IEnumerable param) 135 { 136 List<byte> list = new List<byte>(); 137 138 if (param != null) 139 { 140 List<byte> slist = new List<byte>(); 141 142 foreach (var item in param) 143 { 144 var type = item.GetType(); 145 146 var ps = type.GetProperties(); 147 if (ps != null && ps.Length > 0) 148 { 149 List<object> clist = new List<object>(); 150 foreach (var p in ps) 151 { 152 clist.Add(p.GetValue(item)); 153 } 154 155 var clen = 0; 156 157 var cdata = Serialize(clist.ToArray()); 158 159 if (cdata != null) 160 { 161 clen = cdata.Length; 162 } 163 164 slist.AddRange(BitConverter.GetBytes(clen)); 165 slist.AddRange(cdata); 166 } 167 } 168 169 var len = 0; 170 171 if (slist.Count > 0) 172 { 173 len = slist.Count; 174 } 175 list.AddRange(BitConverter.GetBytes(len)); 176 list.AddRange(slist.ToArray()); 177 } 178 return list.ToArray(); 179 } 180 181 private static byte[] SerializeDic(System.Collections.IDictionary param) 182 { 183 List<byte> list = new List<byte>(); 184 185 if (param != null && param.Count > 0) 186 { 187 foreach (KeyValuePair item in param) 188 { 189 var type = item.GetType(); 190 var ps = type.GetProperties(); 191 if (ps != null && ps.Length > 0) 192 { 193 List<object> clist = new List<object>(); 194 foreach (var p in ps) 195 { 196 clist.Add(p.GetValue(item)); 197 } 198 var clen = 0; 199 200 var cdata = Serialize(clist.ToArray()); 201 202 if (cdata != null) 203 { 204 clen = cdata.Length; 205 } 206 207 list.AddRange(BitConverter.GetBytes(clen)); 208 list.AddRange(cdata); 209 } 210 } 211 } 212 return list.ToArray(); 213 } 214 215 /// <summary> 216 /// len+data 217 /// </summary> 218 /// <param name="params"></param> 219 /// <returns></returns> 220 public static byte[] Serialize(params object[] @params) 221 { 222 List<byte> datas = new List<byte>(); 223 224 if (@params != null) 225 { 226 foreach (var param in @params) 227 { 228 datas.AddRange(Serialize(param)); 229 } 230 } 231 232 return datas.Count == 0 ? null : datas.ToArray(); 233 } 234 235 /// <summary> 236 /// 反序列化 237 /// </summary> 238 /// <param name="types"></param> 239 /// <param name="datas"></param> 240 /// <returns></returns> 241 public static object[] Deserialize(Type[] types, byte[] datas) 242 { 243 List<object> list = new List<object>(); 244 245 var len = 0; 246 247 byte[] data = null; 248 249 int offset = 0; 250 251 for (int i = 0; i < types.Length; i++) 252 { 253 list.Add(Deserialize(types[i], datas, ref offset)); 254 } 255 256 return list.ToArray(); 257 } 258 259 /// <summary> 260 /// 反序列化 261 /// </summary> 262 /// <param name="type"></param> 263 /// <param name="datas"></param> 264 /// <param name="offset"></param> 265 /// <returns></returns> 266 public static object Deserialize(Type type, byte[] datas, ref int offset) 267 { 268 dynamic obj = null; 269 270 var len = 0; 271 272 byte[] data = null; 273 274 len = BitConverter.ToInt32(datas, offset); 275 offset += 4; 276 if (len > 0) 277 { 278 data = new byte[len]; 279 Buffer.BlockCopy(datas, offset, data, 0, len); 280 offset += len; 281 282 if (type == typeof(string)) 283 { 284 obj = Encoding.UTF8.GetString(data); 285 } 286 else if (type == typeof(byte)) 287 { 288 obj = (data); 289 } 290 else if (type == typeof(bool)) 291 { 292 obj = (BitConverter.ToBoolean(data, 0)); 293 } 294 else if (type == typeof(short)) 295 { 296 obj = (BitConverter.ToInt16(data, 0)); 297 } 298 else if (type == typeof(int)) 299 { 300 obj = (BitConverter.ToInt32(data, 0)); 301 } 302 else if (type == typeof(long)) 303 { 304 obj = (BitConverter.ToInt64(data, 0)); 305 } 306 else if (type == typeof(float)) 307 { 308 obj = (BitConverter.ToSingle(data, 0)); 309 } 310 else if (type == typeof(double)) 311 { 312 obj = (BitConverter.ToDouble(data, 0)); 313 } 314 else if (type == typeof(decimal)) 315 { 316 obj = (BitConverter.ToDouble(data, 0)); 317 } 318 else if (type == typeof(DateTime)) 319 { 320 var dstr = Encoding.UTF8.GetString(data); 321 var ticks = long.Parse(dstr.Substring(2)); 322 obj = (new DateTime(ticks)); 323 } 324 else if (type == typeof(byte[])) 325 { 326 obj = (byte[])data; 327 } 328 else if (type.IsGenericType) 329 { 330 obj = DeserializeList(type, data); 331 } 332 else if (type.IsArray) 333 { 334 obj = DeserializeArray(type, data); 335 } 336 else if (type.IsGenericTypeDefinition) 337 { 338 obj = DeserializeDic(type, data); 339 } 340 else if (type.IsClass) 341 { 342 var instance = Activator.CreateInstance(type); 343 344 var ts = new List<Type>(); 345 346 var ps = type.GetProperties(); 347 348 if (ps != null) 349 { 350 foreach (var p in ps) 351 { 352 ts.Add(p.PropertyType); 353 } 354 var vas = Deserialize(ts.ToArray(), data); 355 356 for (int j = 0; j < ps.Length; j++) 357 { 358 try 359 { 360 if (!ps[j].PropertyType.IsGenericType) 361 { 362 ps[j].SetValue(instance, Convert.ChangeType(vas[j], ps[j].PropertyType), null); 363 } 364 else 365 { 366 Type genericTypeDefinition = ps[j].PropertyType.GetGenericTypeDefinition(); 367 if (genericTypeDefinition == typeof(Nullable<>)) 368 { 369 ps[j].SetValue(instance, Convert.ChangeType(vas[j], Nullable.GetUnderlyingType(ps[j].PropertyType)), null); 370 } 371 else 372 { 373 //List<T>問題 374 ps[j].SetValue(instance, Convert.ChangeType(vas[j], ps[j].PropertyType), null); 375 } 376 } 377 } 378 catch (Exception ex) 379 { 380 Console.WriteLine("反序列化不支持的類型：" + ex.Message); 381 } 382 } 383 } 384 obj = (instance); 385 } 386 else 387 { 388 throw new RPCPamarsException("ParamsSerializeUtil.Deserialize 未定義的類型：" + type.ToString()); 389 } 390 391 } 392 return obj; 393 } 394 395 396 private static object DeserializeList(Type type, byte[] datas) 397 { 398 List<object> result = new List<object>(); 399 var stype = type.GenericTypeArguments[0]; 400 401 var len = 0; 402 var offset = 0; 403 //容器大小 404 len = BitConverter.ToInt32(datas, offset); 405 offset += 4; 406 byte[] cdata = new byte[len]; 407 Buffer.BlockCopy(datas, offset, cdata, 0, len); 408 offset += len; 409 410 //子項內容 411 var slen = 0; 412 var soffset = 0; 413 while (soffset < len) 414 { 415 slen = BitConverter.ToInt32(cdata, soffset); 416 var sdata = new byte[slen + 4]; 417 Buffer.BlockCopy(cdata, soffset, sdata, 0, slen + 4); 418 soffset += slen + 4; 419 420 if (slen > 0) 421 { 422 int lloffset = 0; 423 var sobj = Deserialize(stype, sdata, ref lloffset); 424 if (sobj != null) 425 result.Add(sobj); 426 } 427 else 428 { 429 result.Add(null); 430 } 431 } 432 return result; 433 } 434 435 private static object DeserializeArray(Type type, byte[] datas) 436 { 437 var obj = DeserializeList(type, datas); 438 439 if (obj == null) return null; 440 441 var list = (obj as List<object>); 442 443 return list.ToArray(); 444 } 445 446 private static object DeserializeDic(Type type, byte[] datas) 447 { 448 dynamic obj = null; 449 450 451 452 return obj; 453 } 454 } 455 }
實現的過程當中，通常結構、類都還比較順利，可是數組、List、Dictionary仍是遇到了一些麻煩，暫時先放着，找到辦法再說。真要是傳這些，目前先用其餘序列化成byte[]來作……
遠程方法反轉
遠程方法反轉便是將接收到的數據定位到本地的對象方法上，若是代碼生成、參數使用使用泛型反序列化，理論上是能夠提高一些性能的；可是一邊寫服務業務，一邊編寫定義結構文件、還一邊生成服務代碼，本地方法都是納秒級、相對io的速度來說，若是爲了這點性能提高，在使用的時候估計又是一陣@##￥%*#￥@#&##@……，因此仍是使用反射、拆箱吧。
1 /**************************************************************************** 2 *Copyright (c) 2018 Microsoft All Rights Reserved. 3 *CLR版本： 4.0.30319.42000 4 *機器名稱：WENLI-PC 5 *公司名稱：Microsoft 6 *命名空間：SAEA.RPC.Common 7 *文件名： RPCInovker 8 *版本號： V1.0.0.0 9 *惟一標識：289c03b9-3910-4e15-8072-93243507689c 10 *當前的用戶域：WENLI-PC 11 *建立人： yswenli 12 *電子郵箱：wenguoli_520@qq.com 13 *建立時間：2018/5/17 14:11:30 14 *描述： 15 * 16 *===================================================================== 17 *修改標記 18 *修改時間：2018/5/17 14:11:30 19 *修改人： yswenli 20 *版本號： V1.0.0.0 21 *描述： 22 * 23 *****************************************************************************/ 24 using SAEA.RPC.Model; 25 using SAEA.RPC.Net; 26 using SAEA.RPC.Serialize; 27 using SAEA.Sockets.Interface; 28 using System; 29 using System.Linq; 30 using System.Reflection; 31 32 namespace SAEA.RPC.Common 33 { 34 /// <summary> 35 /// RPC將遠程調用反轉到本地服務 36 /// </summary> 37 public class RPCReversal 38 { 39 static object _locker = new object(); 40 41 42 /// <summary> 43 /// 執行方法 44 /// </summary> 45 /// <param name="action"></param> 46 /// <param name="obj"></param> 47 /// <param name="args"></param> 48 /// <returns></returns> 49 private static object ReversalMethod(MethodInfo action, object obj, object[] args) 50 { 51 object result = null; 52 try 53 { 54 var @params = action.GetParameters(); 55 56 if (@params != null && @params.Length > 0) 57 { 58 result = action.Invoke(obj, args); 59 } 60 else 61 { 62 result = action.Invoke(obj, null); 63 } 64 } 65 catch (Exception ex) 66 { 67 throw new RPCPamarsException($"{obj}/{action.Name},出現異常：{ex.Message}", ex); 68 } 69 return result; 70 } 71 72 73 public static object Reversal(IUserToken userToken, string serviceName, string methodName, object[] inputs) 74 { 75 lock (_locker) 76 { 77 try 78 { 79 var serviceInfo = RPCMapping.Get(serviceName, methodName); 80 81 if (serviceInfo == null) 82 { 83 throw new RPCNotFundException($"當前請求找不到:{serviceName}/{methodName}", null); 84 } 85 86 var nargs = new object[] { userToken, serviceName, methodName, inputs }; 87 88 if (serviceInfo.FilterAtrrs != null && serviceInfo.FilterAtrrs.Count > 0) 89 { 90 foreach (var arr in serviceInfo.FilterAtrrs) 91 { 92 var goOn = (bool)arr.GetType().GetMethod("OnActionExecuting").Invoke(arr, nargs.ToArray()); 93 94 if (!goOn) 95 { 96 return new RPCNotFundException("當前邏輯已被攔截！", null); 97 } 98 } 99 } 100 101 if (serviceInfo.ActionFilterAtrrs != null && serviceInfo.ActionFilterAtrrs.Count > 0) 102 { 103 foreach (var arr in serviceInfo.ActionFilterAtrrs) 104 { 105 var goOn = (bool)arr.GetType().GetMethod("OnActionExecuting").Invoke(arr, nargs.ToArray()); 106 107 if (!goOn) 108 { 109 return new RPCNotFundException("當前邏輯已被攔截！", null); 110 } 111 } 112 } 113 114 var result = ReversalMethod(serviceInfo.Mothd, serviceInfo.Instance, inputs); 115 116 nargs = new object[] { userToken, serviceName, methodName, inputs, result }; 117 118 if (serviceInfo.FilterAtrrs != null && serviceInfo.FilterAtrrs.Count > 0) 119 { 120 foreach (var arr in serviceInfo.FilterAtrrs) 121 { 122 arr.GetType().GetMethod("OnActionExecuted").Invoke(arr, nargs); 123 } 124 } 125 126 if (serviceInfo.ActionFilterAtrrs != null && serviceInfo.ActionFilterAtrrs.Count > 0) 127 { 128 foreach (var arr in serviceInfo.FilterAtrrs) 129 { 130 arr.GetType().GetMethod("OnActionExecuted").Invoke(arr, nargs); 131 } 132 } 133 return result; 134 } 135 catch (Exception ex) 136 { 137 if (ex.Message.Contains("找不到此rpc方法")) 138 { 139 return new RPCNotFundException("找不到此rpc方法", ex); 140 } 141 else 142 { 143 return new RPCNotFundException("找不到此rpc方法", ex); 144 } 145 } 146 } 147 } 148 149 /// <summary> 150 /// 反轉到具體的方法上 151 /// </summary> 152 /// <param name="userToken"></param> 153 /// <param name="msg"></param> 154 /// <returns></returns> 155 public static byte[] Reversal(IUserToken userToken, RSocketMsg msg) 156 { 157 byte[] result = null; 158 try 159 { 160 object[] inputs = null; 161 162 if (msg.Data != null) 163 { 164 var ptypes = RPCMapping.Get(msg.ServiceName, msg.MethodName).Pamars.Values.ToArray(); 165 166 inputs = ParamsSerializeUtil.Deserialize(ptypes, msg.Data); 167 } 168 169 var r = Reversal(userToken, msg.ServiceName, msg.MethodName, inputs); 170 171 if (r != null) 172 { 173 return ParamsSerializeUtil.Serialize(r); 174 } 175 } 176 catch (Exception ex) 177 { 178 throw new RPCPamarsException("RPCInovker.Invoke error:" + ex.Message, ex); 179 } 180 return result; 181 182 } 183 } 184 }
客戶端代碼生成
爲了方便客戶使用rpc，因此有rpc相關的代碼在客戶端那確定是越少越好，若是光服務端方便，客戶端估計又要@##￥%*#￥@#&##@……，因此將一些rpc相關代碼生成好，客戶端透明調用是必須的。
1 /**************************************************************************** 2 *Copyright (c) 2018 Microsoft All Rights Reserved. 3 *CLR版本： 4.0.30319.42000 4 *機器名稱：WENLI-PC 5 *公司名稱：Microsoft 6 *命名空間：SAEA.RPC.Generater 7 *文件名： CodeGnerater 8 *版本號： V1.0.0.0 9 *惟一標識：59ba5e2a-2fd0-444b-a260-ab68c726d7ee 10 *當前的用戶域：WENLI-PC 11 *建立人： yswenli 12 *電子郵箱：wenguoli_520@qq.com 13 *建立時間：2018/5/17 18:30:57 14 *描述： 15 * 16 *===================================================================== 17 *修改標記 18 *修改時間：2018/5/17 18:30:57 19 *修改人： yswenli 20 *版本號： V1.0.0.0 21 *描述： 22 * 23 *****************************************************************************/ 24 using SAEA.RPC.Common; 25 using SAEA.RPC.Model; 26 using System; 27 using System.Collections.Generic; 28 using System.IO; 29 using System.Linq; 30 using System.Reflection; 31 using System.Text; 32 33 namespace SAEA.RPC.Generater 34 { 35 /// <summary> 36 /// 代碼生成器 37 /// </summary> 38 public static class CodeGnerater 39 { 40 static string space4 = " "; 41 42 /// <summary> 43 /// 獲取指定數量的空格 44 /// </summary> 45 /// <param name="num"></param> 46 /// <returns></returns> 47 static string GetSpace(int num = 1) 48 { 49 var sb = new StringBuilder(); 50 51 for (int i = 0; i < num; i++) 52 { 53 sb.Append(space4); 54 } 55 56 return sb.ToString(); 57 } 58 59 /// <summary> 60 /// 獲取變量名 61 /// </summary> 62 /// <param name="str"></param> 63 /// <returns></returns> 64 static string GetSuffixStr(string str) 65 { 66 return "_" + str.Substring(0, 1).ToLower() + str.Substring(1); 67 } 68 69 /// <summary> 70 /// 生成代碼頭部 71 /// </summary> 72 /// <returns></returns> 73 static string Header(params string[] usings) 74 { 75 var sb = new StringBuilder(); 76 sb.AppendLine("/*******"); 77 sb.AppendLine($"*此代碼爲SAEA.RPCGenerater生成 {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}"); 78 sb.AppendLine("*******/" + Environment.NewLine); 79 sb.AppendLine("using System;"); 80 if (usings != null) 81 { 82 foreach (var u in usings) 83 { 84 sb.AppendLine(u); 85 } 86 } 87 return sb.ToString(); 88 } 89 90 static string _proxyStr; 91 92 static List<string> _serviceStrs = new List<string>(); 93 94 static Dictionary<string, string> _modelStrs = new Dictionary<string, string>(); 95 96 /// <summary> 97 /// 生成代理代碼 98 /// </summary> 99 /// <param name="spaceName"></param> 100 internal static void GenerateProxy(string spaceName) 101 { 102 StringBuilder csStr = new StringBuilder(); 103 csStr.AppendLine(Header("using SAEA.RPC.Consumer;", $"using {spaceName}.Consumer.Model;", $"using {spaceName}.Consumer.Service;")); 104 csStr.AppendLine($"namespace {spaceName}.Consumer"); 105 csStr.AppendLine("{"); 106 csStr.AppendLine($"{GetSpace(1)}public class RPCServiceProxy"); 107 csStr.AppendLine(GetSpace(1) + "{"); 108 109 csStr.AppendLine(GetSpace(2) + "ServiceConsumer _serviceConsumer;"); 110 csStr.AppendLine(GetSpace(2) + "public RPCServiceProxy(string uri = \"rpc://127.0.0.1:39654\") : this(new Uri(uri)){}"); 111 csStr.AppendLine(GetSpace(2) + "public RPCServiceProxy(Uri uri)"); 112 csStr.AppendLine(GetSpace(2) + "{"); 113 114 csStr.AppendLine(GetSpace(3) + "_serviceConsumer = new ServiceConsumer(uri);"); 115 116 var names = RPCMapping.GetServiceNames(); 117 118 if (names != null) 119 { 120 foreach (var name in names) 121 { 122 csStr.AppendLine(GetSpace(3) + GetSuffixStr(name) + $" = new {name}(_serviceConsumer);"); 123 } 124 } 125 csStr.AppendLine(GetSpace(2) + "}"); 126 127 if (names != null) 128 { 129 foreach (var name in names) 130 { 131 var suffixStr = GetSuffixStr(name); 132 133 csStr.AppendLine(GetSpace(2) + $"{name} {suffixStr};"); 134 csStr.AppendLine(GetSpace(2) + $"public {name} {name}"); 135 csStr.AppendLine(GetSpace(2) + "{"); 136 csStr.AppendLine($"{GetSpace(3)} get{{ return {suffixStr}; }}"); 137 csStr.AppendLine(GetSpace(2) + "}"); 138 139 var list = RPCMapping.GetAll(name); 140 if (list != null) 141 { 142 GenerateService(spaceName, name, list); 143 } 144 } 145 } 146 147 csStr.AppendLine(GetSpace(1) + "}"); 148 csStr.AppendLine("}"); 149 _proxyStr = csStr.ToString(); 150 } 151 /// <summary> 152 /// 生成調用服務代碼 153 /// </summary> 154 /// <param name="spaceName"></param> 155 /// <param name="serviceName"></param> 156 /// <param name="methods"></param> 157 internal static void GenerateService(string spaceName, string serviceName, Dictionary<string, ServiceInfo> methods) 158 { 159 StringBuilder csStr = new StringBuilder(); 160 csStr.AppendLine($"namespace {spaceName}.Consumer.Service"); 161 csStr.AppendLine("{"); 162 csStr.AppendLine($"{GetSpace(1)}public class {serviceName}"); 163 csStr.AppendLine(GetSpace(1) + "{"); 164 csStr.AppendLine(GetSpace(2) + "ServiceConsumer _serviceConsumer;"); 165 csStr.AppendLine(GetSpace(2) + $"public {serviceName}(ServiceConsumer serviceConsumer)"); 166 csStr.AppendLine(GetSpace(2) + "{"); 167 csStr.AppendLine(GetSpace(3) + "_serviceConsumer = serviceConsumer;"); 168 csStr.AppendLine(GetSpace(2) + "}"); 169 170 foreach (var item in methods) 171 { 172 var rtype = item.Value.Mothd.ReturnType; 173 174 if (rtype != null) 175 { 176 if (!_modelStrs.ContainsKey($"{spaceName}.Consumer.Model.{rtype.Name}")) 177 { 178 GenerateModel(spaceName, rtype); 179 } 180 } 181 182 var argsStr = new StringBuilder(); 183 184 var argsInput = new StringBuilder(); 185 186 if (item.Value.Pamars != null) 187 { 188 int i = 0; 189 foreach (var arg in item.Value.Pamars) 190 { 191 i++; 192 argsStr.Append(arg.Value.Name); 193 argsStr.Append(" "); 194 argsStr.Append(arg.Key); 195 if (i < item.Value.Pamars.Count) 196 argsStr.Append(", "); 197 198 if (arg.Value != null && arg.Value.IsClass) 199 { 200 if (!_modelStrs.ContainsKey($"{spaceName}.Consumer.Model.{arg.Value.Name}")) 201 { 202 GenerateModel(spaceName, arg.Value); 203 } 204 } 205 206 argsInput.Append(", "); 207 argsInput.Append(arg.Key); 208 } 209 } 210 211 csStr.AppendLine(GetSpace(2) + $"public {rtype.Name} {item.Key}({argsStr.ToString()})"); 212 csStr.AppendLine(GetSpace(2) + "{"); 213 csStr.AppendLine(GetSpace(3) + $"return _serviceConsumer.RemoteCall<{rtype.Name}>(\"{serviceName}\", \"{item.Key}\"{argsInput.ToString()});"); 214 csStr.AppendLine(GetSpace(2) + "}"); 215 216 217 } 218 219 csStr.AppendLine(GetSpace(1) + "}"); 220 csStr.AppendLine("}"); 221 _serviceStrs.Add(csStr.ToString()); 222 } 223 224 /// <summary> 225 /// 生成實體代碼 226 /// </summary> 227 /// <typeparam name="T"></typeparam> 228 /// <param name="t"></param> 229 /// <returns></returns> 230 internal static void GenerateModel(string spaceName, Type type) 231 { 232 if (!IsModel(type)) return; 233 StringBuilder csStr = new StringBuilder(); 234 csStr.AppendLine($"namespace {spaceName}.Consumer.Model"); 235 csStr.AppendLine("{"); 236 csStr.AppendLine($"{GetSpace(1)}public class {type.Name}"); 237 csStr.AppendLine(GetSpace(1) + "{"); 238 var ps = type.GetProperties(); 239 foreach (var p in ps) 240 { 241 csStr.AppendLine($"{GetSpace(2)}public {p.PropertyType.Name} {p.Name}"); 242 csStr.AppendLine(GetSpace(2) + "{"); 243 csStr.AppendLine(GetSpace(3) + "get;set;"); 244 csStr.AppendLine(GetSpace(2) + "}"); 245 } 246 csStr.AppendLine(GetSpace(1) + "}"); 247 csStr.AppendLine("}"); 248 _modelStrs.Add($"{spaceName}.Consumer.Model.{type.Name}", csStr.ToString()); 249 } 250 251 /// <summary> 252 /// 是不是實體 253 /// </summary> 254 /// <param name="type"></param> 255 /// <returns></returns> 256 internal static bool IsModel(Type type) 257 { 258 if (type.IsArray || type.IsSealed || !type.IsClass) 259 { 260 return false; 261 } 262 return true; 263 } 264 265 /// <summary> 266 /// 生成客戶端C#代碼文件 267 /// </summary> 268 /// <param name="folder"></param> 269 /// <param name="spaceName"></param> 270 public static void Generate(string folder, string spaceName) 271 { 272 RPCMapping.RegistAll(); 273 274 GenerateProxy(spaceName); 275 276 var filePath = Path.Combine(folder, "RPCServiceProxy.cs"); 277 278 StringBuilder sb = new StringBuilder(); 279 280 sb.AppendLine(_proxyStr); 281 282 if (_serviceStrs != null && _serviceStrs.Count > 0) 283 { 284 foreach (var serviceStr in _serviceStrs) 285 { 286 sb.AppendLine(serviceStr); 287 } 288 } 289 290 if (_modelStrs != null && _modelStrs.Count > 0) 291 { 292 foreach (var entry in _modelStrs) 293 { 294 sb.AppendLine(entry.Value); 295 } 296 } 297 298 if (File.Exists(filePath)) 299 File.Delete(filePath); 300 301 File.WriteAllText(filePath, sb.ToString(), Encoding.UTF8); 302 } 303 304 305 } 306 }
不管在服務端根據數據將遠程調用反轉本地方法、仍是生成客戶端代碼的過程都離不開服務結構的問題。若是是根據結構文件來處理，則先要編寫結構文件；服務端碼農活不重事很少啊？文檔沒發你啊？啥鍋都往這邊甩……此處省略一萬字。另一種方式就是相似web mvc採用約定方式，寫完服務業務代碼後，再自動生成結構並緩存在內存裏。
1 /**************************************************************************** 2 *Copyright (c) 2018 Microsoft All Rights Reserved. 3 *CLR版本： 4.0.30319.42000 4 *機器名稱：WENLI-PC 5 *公司名稱：Microsoft 6 *命名空間：SAEA.RPC.Provider 7 *文件名： ServiceTable 8 *版本號： V1.0.0.0 9 *惟一標識：e95f1d0b-f172-49c7-b75f-67f333504260 10 *當前的用戶域：WENLI-PC 11 *建立人： yswenli 12 *電子郵箱：wenguoli_520@qq.com 13 *建立時間：2018/5/16 17:46:34 14 *描述： 15 * 16 *===================================================================== 17 *修改標記 18 *修改時間：2018/5/16 17:46:34 19 *修改人： yswenli 20 *版本號： V1.0.0.0 21 *描述： 22 * 23 *****************************************************************************/ 24 using SAEA.Commom; 25 using SAEA.RPC.Model; 26 using System; 27 using System.Collections.Concurrent; 28 using System.Collections.Generic; 29 using System.Diagnostics; 30 using System.Linq; 31 using System.Reflection; 32 33 namespace SAEA.RPC.Common 34 { 35 /// <summary> 36 /// 服務類緩存表 37 /// md5+ServiceInfo反射結果 38 /// </summary> 39 internal static class RPCMapping 40 { 41 static object _locker = new object(); 42 43 static HashMap<string, string, ServiceInfo> _serviceMap = new HashMap<string, string, ServiceInfo>(); 44 45 /// <summary> 46 /// 本地註冊RPC服務緩存 47 /// </summary> 48 public static HashMap<string, string, ServiceInfo> ServiceMap 49 { 50 get 51 { 52 return _serviceMap; 53 } 54 } 55 56 /// <summary> 57 /// 本地註冊RPC服務 58 /// </summary> 59 /// <param name="type"></param> 60 public static void Regist(Type type) 61 { 62 lock (_locker) 63 { 64 var serviceName = type.Name; 65 66 if (IsRPCService(type)) 67 { 68 var methods = type.GetMethods(); 69 70 var rms = GetRPCMehod(methods); 71 72 if (rms.Count > 0) 73 { 74 foreach (var m in rms) 75 { 76 var serviceInfo = new ServiceInfo() 77 { 78 Type = type, 79 Instance = Activator.CreateInstance(type), 80 Mothd = m, 81 Pamars = m.GetParameters().ToDic() 82 }; 83 84 List<object> iAttrs = null; 85 86 //類上面的過濾 87 var attrs = type.GetCustomAttributes(true); 88 89 if (attrs != null && attrs.Length > 0) 90 { 91 var classAttrs = attrs.Where(b => b.GetType().BaseType.Name == "ActionFilterAttribute").ToList(); 92 93 if (classAttrs != null && classAttrs.Count > 0) 94 95 iAttrs = classAttrs; 96 97 } 98 99 serviceInfo.FilterAtrrs = iAttrs; 100 101 //action上面的過濾 102 var actionAttrs = m.GetCustomAttributes(true); 103 104 if (actionAttrs != null) 105 { 106 var filterAttrs = attrs.Where(b => b.GetType().BaseType.Name == "ActionFilterAttribute").ToList(); 107 108 if (filterAttrs != null && filterAttrs.Count > 0) 109 110 serviceInfo.ActionFilterAtrrs = filterAttrs; 111 } 112 113 _serviceMap.Set(serviceName, m.Name, serviceInfo); 114 } 115 } 116 } 117 } 118 } 119 120 /// <summary> 121 /// 本地註冊RPC服務 122 /// 若爲空，則默認所有註冊帶有ServiceAttribute的服務 123 /// </summary> 124 /// <param name="types"></param> 125 public static void Regists(params Type[] types) 126 { 127 if (types != null) 128 foreach (var type in types) 129 { 130 Regist(type); 131 } 132 else 133 RegistAll(); 134 } 135 /// <summary> 136 /// 所有註冊帶有ServiceAttribute的服務 137 /// </summary> 138 public static void RegistAll() 139 { 140 StackTrace ss = new StackTrace(true); 141 MethodBase mb = ss.GetFrame(2).GetMethod(); 142 var space = mb.DeclaringType.Namespace; 143 var tt = mb.DeclaringType.Assembly.GetTypes(); 144 Regists(tt); 145 } 146 147 /// <summary> 148 /// 判斷類是不是RPCService 149 /// </summary> 150 /// <param name="type"></param> 151 /// <returns></returns> 152 public static bool IsRPCService(Type type) 153 { 154 var isService = false; 155 var cAttrs = type.GetCustomAttributes(true); 156 if (cAttrs != null) 157 { 158 foreach (var cAttr in cAttrs) 159 { 160 if (cAttr is RPCServiceAttribute) 161 { 162 isService = true; 163 break; 164 } 165 } 166 } 167 return isService; 168 } 169 170 /// <summary> 171 /// 獲取RPC方法集合 172 /// </summary> 173 /// <param name="mInfos"></param> 174 /// <returns></returns> 175 public static List<MethodInfo> GetRPCMehod(MethodInfo[] mInfos) 176 { 177 List<MethodInfo> result = new List<MethodInfo>(); 178 if (mInfos != null) 179 { 180 var isRPC = false; 181 foreach (var method in mInfos) 182 { 183 if (method.IsAbstract || method.IsConstructor || method.IsFamily || method.IsPrivate || method.IsStatic || method.IsVirtual) 184 { 185 break; 186 } 187 188 isRPC = true; 189 var attrs = method.GetCustomAttributes(true); 190 if (attrs != null) 191 { 192 foreach (var attr in attrs) 193 { 194 if (attr is NoRpcAttribute) 195 { 196 isRPC = false; 197 break; 198 } 199 } 200 } 201 if (isRPC) 202 { 203 result.Add(method); 204 } 205 } 206 } 207 return result; 208 } 209 210 /// <summary> 211 /// 轉換成字典 212 /// </summary> 213 /// <param name="parameterInfos"></param> 214 /// <returns></returns> 215 public static Dictionary<string, Type> ToDic(this ParameterInfo[] parameterInfos) 216 { 217 if (parameterInfos == null) return null; 218 219 Dictionary<string, Type> dic = new Dictionary<string, Type>(); 220 221 foreach (var p in parameterInfos) 222 { 223 dic.Add(p.Name, p.ParameterType); 224 } 225 226 return dic; 227 } 228 229 230 /// <summary> 231 /// 獲取緩存內容 232 /// </summary> 233 /// <param name="serviceName"></param> 234 /// <param name="methodName"></param> 235 /// <returns></returns> 236 public static ServiceInfo Get(string serviceName, string methodName) 237 { 238 lock (_locker) 239 { 240 return _serviceMap.Get(serviceName, methodName); 241 } 242 } 243 244 /// <summary> 245 /// 獲取緩存內容 246 /// </summary> 247 /// <returns></returns> 248 public static List<string> GetServiceNames() 249 { 250 lock (_locker) 251 { 252 return _serviceMap.GetHashIDs(); 253 } 254 } 255 /// <summary> 256 /// 獲取服務的所有信息 257 /// </summary> 258 /// <param name="serviceName"></param> 259 /// <returns></returns> 260 public static Dictionary<string, ServiceInfo> GetAll(string serviceName) 261 { 262 lock (_locker) 263 { 264 return _serviceMap.GetAll(serviceName); 265 } 266 } 267 268 269 270 } 271 }
測試
至此幾個關鍵點都完成了，下面是vs2017的代碼結構：
SAEA.RPCTest是測試項目，Provider爲模擬服務端代碼、RPCServiceProxy爲生成器根據服務端生成的客戶端代碼，Program.cs中是使用SAEA.RPC使用、測試代碼：
1 using SAEA.Commom; 2 using SAEA.RPC.Provider; 3 using SAEA.RPCTest.Consumer; 4 //using SAEA.RPCTest.Consumer; 5 using System; 6 using System.Diagnostics; 7 using System.Threading; 8 using System.Threading.Tasks; 9 10 namespace SAEA.RPCTest 11 { 12 class Program 13 { 14 static void Main(string[] args) 15 { 16 ConsoleHelper.WriteLine($"SAEA.RPC功能測試： {Environment.NewLine} p 啓動rpc provider{Environment.NewLine} c 啓動rpc consumer{Environment.NewLine} g 啓動rpc consumer代碼生成器"); 17 18 var inputStr = ConsoleHelper.ReadLine(); 19 20 if (string.IsNullOrEmpty(inputStr)) 21 { 22 inputStr = "p"; 23 } 24 25 if (inputStr == "c") 26 { 27 ConsoleHelper.WriteLine("開始Consumer測試！"); 28 ConsumerInit(); 29 ConsoleHelper.WriteLine("回車結束！"); 30 ConsoleHelper.ReadLine(); 31 } 32 else if (inputStr == "a") 33 { 34 ProviderInit(); 35 ConsoleHelper.WriteLine("回車開始Consumer測試！"); 36 ConsoleHelper.ReadLine(); 37 ConsumerInit(); 38 ConsoleHelper.WriteLine("回車結束！"); 39 ConsoleHelper.ReadLine(); 40 } 41 else if (inputStr == "g") 42 { 43 ConsoleHelper.WriteLine("正在代碼生成中..."); 44 Generate(); 45 ConsoleHelper.WriteLine("代碼生成完畢，回車結束！"); 46 ConsoleHelper.ReadLine(); 47 } 48 else 49 { 50 ProviderInit(); 51 ConsoleHelper.WriteLine("回車結束！"); 52 ConsoleHelper.ReadLine(); 53 } 54 } 55 56 57 static void ProviderInit() 58 { 59 ConsoleHelper.Title = "SAEA.RPC.Provider"; 60 ConsoleHelper.WriteLine("Provider正在啓動HelloService。。。"); 61 var sp = new ServiceProvider(new Type[] { typeof(Provider.HelloService) }); 62 sp.Start(); 63 ConsoleHelper.WriteLine("Provider就緒！"); 64 } 65 66 static void Generate() 67 { 68 RPC.Generater.CodeGnerater.Generate(PathHelper.Current, "SAEA.RPCTest"); 69 } 70 71 static void ConsumerInit() 72 { 73 ConsoleHelper.Title = "SAEA.RPC.Consumer"; 74 75 var url = "rpc://127.0.0.1:39654"; 76 77 ConsoleHelper.WriteLine($"Consumer正在鏈接到{url}..."); 78 79 RPCServiceProxy cp = new RPCServiceProxy(url); 80 81 ConsoleHelper.WriteLine("Consumer鏈接成功"); 82 83 ConsoleHelper.WriteLine("HelloService/Hello:" + cp.HelloService.Hello()); 84 ConsoleHelper.WriteLine("HelloService/Plus:" + cp.HelloService.Plus(1, 9)); 85 ConsoleHelper.WriteLine("HelloService/Update/UserName:" + cp.HelloService.Update(new Consumer.Model.UserInfo() { ID = 1, UserName = "yswenli" }).UserName); 86 ConsoleHelper.WriteLine("HelloService/GetGroupInfo/Creator.UserName:" + cp.HelloService.GetGroupInfo(1).Creator.UserName); 87 ConsoleHelper.WriteLine("HelloService/SendData:" + System.Text.Encoding.UTF8.GetString(cp.HelloService.SendData(System.Text.Encoding.UTF8.GetBytes("Hello Data")))); 88 ConsoleHelper.WriteLine("回車啓動性能測試！"); 89 90 ConsoleHelper.ReadLine(); 91 92 #region 性能測試 93 94 Stopwatch sw = new Stopwatch(); 95 96 int count = 1000000; 97 98 ConsoleHelper.WriteLine($"{count} 次實體傳輸調用測試中..."); 99 100 var ui = new Consumer.Model.UserInfo() { ID = 1, UserName = "yswenli" }; 101 102 sw.Start(); 103 104 for (int i = 0; i < count; i++) 105 { 106 cp.HelloService.Update(ui); 107 } 108 ConsoleHelper.WriteLine($"實體傳輸：{count * 1000 / sw.ElapsedMilliseconds} 次/秒"); 109 110 sw.Stop(); 111 112 #endregion 113 114 115 116 } 117 } 118 }
在命令行中將SAEA.RPCTest發佈輸入dotnet pulish -r win7-x64後運行exe以下：
至此一個使用方便、高性能rpc就初步完成了。
轉載請標明本文來源：http://www.javashuo.com/article/p-efqqaizb-cr.html
更多內容歡迎star/fork做者的github：https://github.com/yswenli/SAEA若是發現本文有什麼問題和任何建議，也隨時歡迎交流~
相關文章
- 1. 自行實現 dotnet core rpc
- 2. dotnet core 之 gRPC
- 3. DotNet Core 2.0使用MySql實現Code First
- 4. Dotnet Core Windows Service
- 5. DOTNET Core 命令
- 6. DotNet/Asp.Net/EF Core
- 7. dotnet core各rpc組件的性能測試
- 8. windows jenkins dotnet core 自動化構建webapi
- 9. 自實現RPC調用
- 10. dotnet core 在ubuntu 上運行 F#
- 更多相關文章...
- • 現實生活中的 XML - XML 教程
- • Hibernate實現增刪改查 - Hibernate教程
- • ☆基於Java Instrument的Agent實現
- • Spring Cloud 微服務實戰(三) - 服務註冊與發現
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
