翁帆会舔杨振宁哪里呢_基于.NET CORE微服务框架 -谈谈surging 的messagepack、protobuffer、json.net 序列化

1、前言

surging内部使用的是高性能RPC远程服务调用，如果用json.net序列化肯定性能上达不到最优，所以后面扩展了protobuf,messagepack序列化组件，以支持RPC二进制传输.

在这里需要感谢白纸无字Zonciu，新增了messagepack序列化，让surging 性能上跨了一大步。此篇文章我们来谈谈messagepack、protobuffer、json.net ，并且性能做下对比

开源地址：https://github.com/dotnetcore/surging

　2.1 surging 使用的是以下序列化组件:

json.net：surging 使用的是Newtonsoft.Json， 它是基于json格式的序列化和反序列化的组件.官方网站:

protobuf：surging 使用的是protobuf-net， 它是基于二进制格式的序列化和反序列化的组件.官方网站:https://github.com/mgravell/protobuf-net

messagepack：surging 使用的是MessagePack-CSharp， 它是基于二进制格式的序列化和反序列化的组件.官方网站:https://github.com/neuecc/MessagePack-CSharp

2.2 各个组件的优点

json.net 有以下优点：

侵入性：可以不添加attribute,就能进行序列化操作

灵活性：可以灵活性配置，比如允许被序列化的成员自定义名字，屏蔽的非序列化属性成员

可读性： 数据格式比较简单, 易于读写

依赖性：可以序列化成JObject，无需依赖对象进行序列化和泛型化。

　　protobuf 有以下优点：

　 性能高 序列化后体积相比Json和XML很小，适合RPC二进制传输
　　 跨语言：支持跨平台多语言
兼容性：消息格式升级和兼容性还不错
速度快 ：序列化反序列化速度很快，快于Json的处理速速

messagepack有以下优点：

　 性能高 序列化后体积相比Json和XML很小，适合RPC二进制传输
　　 跨语言：支持跨平台多语言
兼容性：消息格式升级和兼容性还不错
速度快 ：序列化反序列化速度很快，快于Json的处理速度

针对于protobuf和messagepack都是基于二进制格式的序列化和反序列化，优点都一样，但是基于messagepack的MessagePack-CSharp组件侵入性更小，可以不需要加attribute,而且性能上更优.下一节来看看组件在surging 中的表现

服务端：

（注：如果不加UseProtoBufferCodec和UseMessagePackCodec就是json.net序列化）

var host = new ServiceHostBuilder() .RegisterServices(option=> { option.Initialize(); //初始化服务 option.RegisterServices();//依赖注入领域服务 option.RegisterRepositories();//依赖注入仓储 option.RegisterModules();//依赖注入第三方模块 option.RegisterServiceBus();//依赖注入ServiceBus }) .RegisterServices(builder => { builder.AddMicroService(option => { option.AddServiceRuntime();// 盐城乐虎资讯网-- // option.UseZooKeeperManager(new ConfigInfo("127.0.0.1:2181")); //使用Zookeeper管理 option.UseConsulManager(new ConfigInfo("127.0.0.1:8500"));//使用Consul管理 option.UseDotNettyTransport();//使用Netty传输 option.UseRabbitMQTransport();//使用rabbitmq 传输 option.AddRabbitMQAdapt();//基于rabbitmq的消费的服务适配 // option.UseProtoBufferCodec();//基于protobuf序列化传输 option.UseMessagePackCodec();//基于MessagePack序列化传输 builder.Register(p => new CPlatformContainer(ServiceLocator.Current));//初始化注入容器 }); }) .SubscribeAt() //消息订阅 .UseServer("127.0.0.1", 98) //.UseServer("127.0.0.1", 98，“true”) //自动生成Token //.UseServer("127.0.0.1", 98，“123456789”) //固定密码Token .UseStartup<Startup>() .Build(); using (host.Run()) { Console.WriteLine($"服务端启动成功，{DateTime.Now}。"); }

客户端：

var host = new ServiceHostBuilder() .RegisterServices(option => { option.Initialize(); option.RegisterServices(); option.RegisterRepositories(); option.RegisterModules(); }) .RegisterServices(builder => { builder.AddMicroService(option => { option.AddClient(); option.AddClientIntercepted(typeof(CacheProviderInterceptor)); //option.UseZooKeeperManager(new ConfigInfo("127.0.0.1:2181")); option.UseConsulManager()); option.UseDotNettyTransport(); option.UseRabbitMQTransport(); 浙江乐虎资讯网--(); //option.UseMessagePackCodec(); builder.Register(p => new CPlatformContainer(ServiceLocator.Current)); }); }) .UseClient() .UseStartup<Startup>() .Build(); using (host.Run()) { Startup.Test(ServiceLocator.GetService<IServiceProxyFactory>()); Startup.TestRabbitMq(); }

测试 0 object(注：测试无参数)

/// <summary> /// 测试 /// </summary> /// <param></param> public static void Test(IServiceProxyFactory serviceProxyFactory) { Task.Run(async () => { var userP襄阳乐虎资讯网-- = serviceProxyFactory.CreateProxy<IUserService>("User"); await userProxy.GetUserId("user"); do { Console.WriteLine("正在循环 1w次调用 GetUser....."); //1w次调用 var watch = Stopwatch.StartNew(); for (var i = 0; i < 10000; i++) { var a =userProxy.GetDictionary().Result; } watch.Stop(); Console.WriteLine($"1w次调用结束，执行时间：{watch.ElapsedMilliseconds}ms"); Console.ReadLine(); } while (true); }).Wait(); }

测试 1 object(注：测试参数传对象)