一个能够在Asp.Net和Asp.NetCore之间能够互相通讯的Rpc

管河英 發表於 2018-5-17 14:24:00

一个能够在Asp.Net和Asp.NetCore之间能够互相通讯的Rpc

<h2>一、特性</h2>
1、跨平台
2、提供负载均衡算法
3、支持ZK服务协调
4、提供了JSON、BinarySerializer、还有自定义的序列化方式
5、客户端提供Socket连接池，以便于快速交互，防止类似大文件上传时会阻塞
6、支持异步方法
7、支持.net与.netcore之间通信
8、支持采用MongoDb收集请求信息（采用双缓冲队列，极限的不影响传输速度）
9、提供请求日志监控后台（还未全部完善）
<h2>二、项目结构</h2>
<img src="https://images2018.cnblogs.com/blog/712425/201805/712425-20180517135054003-952116695.png" alt="">
编译器采用vs2017.
NRpcItem 是Framework下的NRpc源代码。NetCoreRpcItem是.NetCore下的源代码。NRpcSerializer是自己写的一个序列化方法，速度和json序列化对比稍慢一点，但是速度可以接收。
值得注意的是NRpcItem 里面采用Autofac来作为IOC容器，服务端的代码都必须要基于Autofac来实现依赖注入。
NRpc.AdminManage是日志监控后台，目前只有.netCore版本。
<h2>三、自定义序列化方法性能测试</h2>
<img src="https://images2018.cnblogs.com/blog/712425/201805/712425-20180517140106001-271326222.png" alt="">
虽然在执行速度上比json稍慢，但是支持对byte[]类型的序列化，而且客户端不需要任何的标记，方便使用。实现过程中参考csharp-hessian的序列化实现方式，支持跨平台。
<h2>四、如何使用Rpc</h2>
1、服务端：
　　a、参考NetCoreRpc.Application项目，先定义好IStudentApplication以及他的实现类StudentApplication
　　b、参考NetCoreRpc.ServerTest项目中Program，先绑定好依赖注入信息，如果要使用zk，则加上.UseZK();扩展方法，不然不采用ZK的服务发现
<div class="cnblogs_code"><img id="code_img_closed_2c976867-a496-4159-98b6-ac7816f932aa" class="code_img_closed" src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" alt=""><img id="code_img_opened_2c976867-a496-4159-98b6-ac7816f932aa" class="code_img_opened" style="display: none" src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" alt="">
<div id="cnblogs_code_open_2c976867-a496-4159-98b6-ac7816f932aa" class="cnblogs_code_hide">
<pre>private static IServiceProvider BuildDi()
 {
 IServiceCollection services = new ServiceCollection();

 services.AddSingleton<ILoggerFactory, LoggerFactory>();
 services.AddSingleton(typeof(ILogger<>), typeof(Logger<>));
 services.AddSingleton<IStudentApplication, StudentApplication>();
 var str = Configuration.GetValue<string>("MongoDB:Str");
 var dbName = Configuration.GetValue<string>("MongoDB:DatabaseName");
 services.UseRpc()
 .UseMongoDBMonitor(() =>
 {

 return new MonogoDbConfig(str, dbName);
 });//.UseZK();
 var serviceProvider = services.BuildServiceProvider();

 var loggerFactory = serviceProvider.GetRequiredService<ILoggerFactory>();

 loggerFactory.AddNLog(new NLogProviderOptions { CaptureMessageTemplates = true, CaptureMessageProperties = true });
 loggerFactory.ConfigureNLog("NLog.config");

 return serviceProvider;
 }</pre>
</div>
绑定依赖注入信息</div>
　　c、配置文件信息，配置ZK和MongoDb链接配置信息
<div class="cnblogs_code">
<pre>{
"NetCoreRpc": {
"Zookeeper": {
 "Connection": "192.168.100.34:2181",
 "ParentName": "/NetCoreRpc/ClientTest"
}
},
"MongoDB": {
"Str": "mongodb://root:root@192.168.100.125:27017",
"DatabaseName": "Rpc_Monitor"
}
}</pre>
</div>
　　d、开启监听
<div class="cnblogs_code"><img id="code_img_closed_4fede46a-5767-4d69-b317-f968cf73aca4" class="code_img_closed" src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" alt=""><img id="code_img_opened_4fede46a-5767-4d69-b317-f968cf73aca4" class="code_img_opened" style="display: none" src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" alt="">
<div id="cnblogs_code_open_4fede46a-5767-4d69-b317-f968cf73aca4" class="cnblogs_code_hide">
<pre> private static void Main(string[] args)
 {
 Console.WriteLine("请输入监听端口:");
 var strPort = Console.ReadLine();
 var builder = new ConfigurationBuilder()
 .SetBasePath(Path.Combine(AppContext.BaseDirectory)).AddJsonFile("NetCoreRpc.json", optional: true);
 Configuration = builder.Build();
 var servicesProvider = BuildDi();
 DependencyManage.SetServiceProvider(servicesProvider, Configuration);
 NRpcServer nrpcServer = new NRpcServer(int.Parse(strPort));
 nrpcServer.Start("NetCoreRpc.Application");
 Console.WriteLine("Welcome to use NetCoreRpc!");
 Console.WriteLine("Input exit to exit");
 var str = Console.ReadLine();
 while (!string.Equals(str, "exit", StringComparison.OrdinalIgnoreCase))
 {
 str = Console.ReadLine();
 }
 nrpcServer.ShutDown();
 }</pre>
</div>
开启监听</div>
2、客户端如何调用
　　a、参考NetCoreRpc.ClientTest项目先配置一些基础的依赖信息
<div class="cnblogs_code"><img id="code_img_closed_718f7bae-6da6-4b3e-ba08-720a72e1403a" class="code_img_closed" src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" alt=""><img id="code_img_opened_718f7bae-6da6-4b3e-ba08-720a72e1403a" class="code_img_opened" style="display: none" src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" alt="">
<div id="cnblogs_code_open_718f7bae-6da6-4b3e-ba08-720a72e1403a" class="cnblogs_code_hide">
<pre>private static IServiceProvider BuildDi()
 {
 IServiceCollection services = new ServiceCollection();
 services.AddOptions();
 services.Configure<RpcConfig>(Configuration.GetSection("NetCoreRpc"));
 services.AddSingleton<ILoggerFactory, LoggerFactory>();
 services.AddSingleton(typeof(ILogger<>), typeof(Logger<>));
 services.UseRpc().UseMongoDBMonitor(() =>
 {
 var str = Configuration.GetValue<string>("MongoDB:Str");
 var dbName = Configuration.GetValue<string>("MongoDB:DatabaseName");
 return new MonogoDbConfig(str, dbName);
 });//.UseZK();
 var serviceProvider = services.BuildServiceProvider();

 var loggerFactory = serviceProvider.GetRequiredService<ILoggerFactory>();

 //configure NLog
 loggerFactory.AddNLog(new NLogProviderOptions { CaptureMessageTemplates = true, CaptureMessageProperties = true });
 loggerFactory.ConfigureNLog("NLog.config");

 return serviceProvider;
 }</pre>
</div>
配置依赖</div>
　　b、配置文件内容
<div class="cnblogs_code"><img id="code_img_closed_5593ff2e-9949-4cc0-8b22-cb91d8cbc54f" class="code_img_closed" src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" alt=""><img id="code_img_opened_5593ff2e-9949-4cc0-8b22-cb91d8cbc54f" class="code_img_opened" style="display: none" src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" alt="">
<div id="cnblogs_code_open_5593ff2e-9949-4cc0-8b22-cb91d8cbc54f" class="cnblogs_code_hide">
<pre>{
"NetCoreRpc": {
"RequestTimeouMillis": 10000,
"Default": "192.168.129.117:12345",
//"Group": [
//{
// "NameSpace": "",
// "Address": "127.0.0.1:12345"
//}
//],
"Zookeeper": {
 "Connection": "192.168.100.34:2181",
 "ParentName": "/NetCoreRpc/ClientTest"
}
},
"MongoDB": {
"Str": "mongodb://root:root@192.168.100.125:27017",
"DatabaseName": "Rpc_Monitor"
}
}</pre>
</div>
配置文件</div>
配置服务端地址，也可以根据类的名字来配置服务端地址，因为一个客户端在业务多的时候可能调用了多个服务端，所以提供了根据类型的名字来配置服务端地址
　　c、如何开始调用
　　首先接口类和Model类的命名控件必须要与服务端一致，比如例子中的IStudentApplication与TestModel这两个。
　　然后通过代理类来实例化接口类，然后调用对应的方法即可。
<div class="cnblogs_code"><img id="code_img_closed_13d34a62-c17a-4ecc-8231-72f46a7a276b" class="code_img_closed" src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" alt=""><img id="code_img_opened_13d34a62-c17a-4ecc-8231-72f46a7a276b" class="code_img_opened" style="display: none" src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" alt="">
<div id="cnblogs_code_open_13d34a62-c17a-4ecc-8231-72f46a7a276b" class="cnblogs_code_hide">
<pre> private static void Send()
 {
 var studentApplication = ProxyFactory.Create<IStudentApplication>();
 Console.WriteLine(studentApplication.Age());
 Console.WriteLine(studentApplication.IsYongPeople(15));
 var runTask = studentApplication.RunAsync(111);
 studentApplication.Say("Hello world");
 studentApplication.Say(Encoding.UTF8.GetBytes("Hi!"));
 Console.WriteLine(Encoding.UTF8.GetString(studentApplication.Say()));
 var test = studentApplication.Test();
 Console.WriteLine(test.ToString());
 studentApplication.Sleep();
 Console.WriteLine(runTask.Result);
 }</pre>
</div>
客户端调用</div>
framework版本与.netcore版本大同小异，具体的实际使用请参考下各个项目的Test文件。
<h2>五、调用案例结果</h2>
<img src="https://images2018.cnblogs.com/blog/712425/201805/712425-20180517141559335-996621972.png" alt="">
<h2>六、服务端监控</h2>
<img src="https://images2018.cnblogs.com/blog/712425/201805/712425-20180517141659702-987373046.png" alt="">
 
 监控应用还没有完善好，后续会完善的，对了监控应用必须基于MongoDB。
<h2>七、项目开源地址</h2>
https://github.com/yjqGitHub/NetCoreRpc 欢迎大家来吐槽，提建议，如果有兴趣一起来完善的就更好了。
还有Nuget上的版本还暂未发布，原先发布的还不是最新代码 
来源：https://www.cnblogs.com/yjq-code/p/Rpc.html

頁: [1]

琼殿技术论坛's Archiver

一个能够在Asp.Net和Asp.NetCore之间能够互相通讯的Rpc