Asp.Net Core使用SignalR进行服务间调用方法示例
更新时间：2018年12月21日 16:16:56 作者：饭勺oO
这篇文章主要介绍了Asp.Net Core使用SignalR进行服务间调用方法示例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
网上查询过很多关于ASP.NET core使用SignalR的简单例子，但是大部分都是简易聊天功能，今天心血来潮就搞了个使用SignalR进行服务间调用的简单DEMO。
至于SignalR是什么我就不多说了，微软官方文档也不少。
第一步新建项目
所有VS开发第一步都是新建一个解决方案哈，这里我就不多介绍如何新建项目啦~~
开发环境，VS2017,.NET CORE 2.1
新建两个asp.net core项目
如此简单的操作大家都懂的
注入SignalR
在被调用的服务端的Startup.cs中注入SignalR 在asp.net core2.1中已经默认包含了SignalR的库，直接在 ConfigureServices 方法中添加如下代码：
services.AddSignalR().AddMessagePackProtocol()
AddMessagePackProtocol() 表示启用 MessagePack 支持在服务器上
新建一个继承Hub类的类
public class ServerHub : Hub
{
}
里面可以实现需要被客户端执行的方法。
配置Hub连接URL
在 Startup.cs 的 Configure 添加下面代码
app.UseSignalR(routes =>
{
routes.MapHub<ServerHub>(“/myserver”);
});
添加服务
新建一个Services文件夹，添加我们的服务接口和接口实现类。
public interface IMyService
{
Task<string> SayHello();
Task Sleep();
}
public class MyService : IMyService
{
public async Task<string> SayHello()
{
return await Task.Factory.StartNew(() => “Hello”);
}
public async Task Sleep()
{
await Task.Delay(3000);
}
}
在Startup.cs中的 ConfigureServices 方法中进行依赖注入，注意需要在 AddSignalR() 之前注入。
services.AddScoped<IMyService, MyService>();
在ServerHub添加依赖注入
在ServerHub中添加如下代码
private readonly IServiceProvider _serviceProvider;
public ServerHub(IServiceProvider serviceProvider)
{
_serviceProvider = serviceProvider;
}
因为我们需要使用到依赖注入获取指定Service，所以只注入 IServiceProvider ，使用 IServiceProvider 动态获取服务接口。
使用反射动态获取服务接口并执行指定方法
为了可以动态的选择服务并且执行服务相应的方法，我们使用反射来动态获取。 这里我们添加两个方法，一个有返回值，一个没有返回值
public async Task<dynamic> Excute(string serverName,string functionName,object[] parameters)
{
return await Task.Factory.StartNew(() =>
{
var type = Type.GetType(serverName);
var service = _serviceProvider.GetRequiredService(type);
var method = type.GetMethod(functionName);
var resultTask = method.Invoke(service, new object[] { }) as Task;
dynamic result = resultTask.GetType().GetProperty(“Result”).GetValue(resultTask, null);
return result;
});
}
public async Task ExcuteWithoutResult(string serverName, string functionName, object[] parameters)
{
var type = Type.GetType(serverName);
var service = _serviceProvider.GetRequiredService(type);
var method = type.GetMethod(functionName);
var resultTask = method.Invoke(service, new object[] { }) as Task;
await resultTask;
var msg = “task done”;
await Clients.Caller.SendAsync(“callback”,msg);
}
方法中传入三个参数
serverName：服务接口名称（完整的命名空间）
functionName：方法的名称
parameters: 方法所需的参数
1.使用Type.GetType(serverName)获取服务接口的Type。
2.使用_serviceProvider.GetRequiredService(type)从依赖注入中获取对应服务。
3.使用type.GetMethod(functionName)获取需要执行的方法。
4.执行方法method.Invoke(service, new object[] { })
由于我们的服务是异步方法， method.Invoke() 返回的是一个 object 对象，所以在将 method.Invoke() 返回类型转为 Task 类型。
resultTask.GetType().GetProperty(“Result”).GetValue(resultTask, null) 是通过反射获取 Task 的 Result 属性来回去相应的返回结果。
因为我们不知道方法返回的 Task 中返回的结果类型是什么，所以我们依旧使用反射来获取 Task 的结果并使用 dynamic 接收。
无返回值的我们使用 Clients.Caller.SendAsync() 在任务处理结束后给调用方返回一条消息。
在调用方添加一个SingalRClient类
public class SignalRClient
{
private readonly HubConnection connection;
public SignalRClient()
{
connection = new HubConnectionBuilder()
.WithUrl(“localhost:5000/myserver”)
.AddMessagePackProtocol()
.Build();
connection.Closed += async (error) =>
{
await Task.Delay(new Random().Next(0, 5) * 1000);
await connection.StartAsync();
};
InitOnMethod();
connection.StartAsync().ConfigureAwait(false).GetAwaiter().GetResult();
}
}
在构造函数中初始化SignalR连接
WithUrl(“localhost:5000/myserver”) 是连接被调用方的URL
AddMessagePackProtocol() 是使用快速和精简的二进制序列化格式进行传输。 在 connection.Closed 加入连接关闭事件，关闭后自动重新连接。 InitOnMethod 初始化服务方回调的监听事件
private void InitOnMethod()
{
connection.On<string>(“callback”,(msg)=> {
Console.WriteLine($”————{msg}———-“);
});
}
connection.StartAsync() 启动连接。
添加两个请求服务端的方法
一个有返回值，一个无返回值。
public async Task<dynamic> RequestServer1()
{
var result = await connection.InvokeAsync<dynamic>(“Excute”, “SignalRServer1.Services.IMyService”, “SayHello”,new object[] { });
return result;
}
public async Task RequestWithoutResult()
{
await connection.SendAsync(“ExcuteWithoutResult”, “SignalRServer1.Services.IMyService”, “Sleep”, new object[] { });
}
需要返回值的我们使用 connection.InvokeAsync() 方法
不需要返回值的我们使用 connection.SendAsync() 方法
将SignalRClient以单例形式注册依赖注入
在 Startup.cs 中的 ConfigureServices 方法中添加 services.AddSingleton<SignalRClient>() 。
使用SignalRClient请求服务
在控制器中将SignalRClient注入
private readonly SignalRClient _signalRClient;
public ValuesController(SignalRClient signalRClient)
{
_signalRClient = signalRClient;
}
// GET api/values
[HttpGet]
public async Task<ActionResult<IEnumerable<string>>> Get()
{
var str = await _signalRClient.RequestServer1().ConfigureAwait(false);
await _signalRClient.RequestWithoutResult().ConfigureAwait(false);
return new string[] { str };
}
在请求中同时调用一个有返回值，一个无返回值的方法。无返回值的方法在任务执行完后执行一个回调。
启动服务
可以看到服务调用已经成功 task done是我们无返回值调用那个方法中接收到回调时的输出.
connection.On<string>(“callback”,(msg)=> {
Console.WriteLine($”————{msg}———-“);
});
以上就是我简单做的一个DEMO。希望对大家的学习有所帮助，也希望大家多多支持华域联盟。
您可能感兴趣的文章:ASP.NET Core SignalR中的流式传输深入讲解asp.net core 2.0 webapi集成signalr(实例讲解)详解在ASP.NET Core下使用SignalR技术
Asp.Net
Core
SignalR
服务间调用
相关文章
实例讲解.NET中资源文件的创建与使用资源文件顾名思义就是存放资源的文件。资源文件在程序设计中有着自身独特的优势，他独立于源程序，这样资源文件就可以被多个程序使用 2011-12-12
Global.asax取物理路径/取绝对路径具体方法本文章来给大家简单介绍利用Global.asax取物理路径和取绝对路径代码，有需要了解的朋友可参考参考 2013-08-08
完美解决Could not load file or assembly AjaxPro.2 or one of Could not load file or assembly AjaxPro.2，经排查原来是mcafee限制了 2007-08-08
ASP.NET XmlDocument类详解这篇文章主要介绍了ASP.NET XmlDocument类详解,本文讲解了XmlDocument的属性、XmlDocument的方法、XmlDocument的事件、XmlDocument的使用实例等内容,需要的朋友可以参考下 2015-05-05
asp.net(c#)判断远程图片是否存在不错的应用，大家可以拓展到，判断远程文件是否存在等功能 2008-09-09
ASP.NET中repeater嵌套实现代码(附源码)repeater嵌套经常会在一些特殊效果显示下会用到，新手朋友们可以详细看下本文，希望对你有所帮助，代码很整洁同时附有源码 2013-03-03
.Net Core Api 使用版本控制详解Api的版本控制是Api开发中经常遇到的问题, 在大部分中大型项目都需要使用到Api的版本控制，这篇文章主要介绍了.Net Core Api 使用版本控制详解，感兴趣的小伙伴们可以参考一下 2018-10-10
MVC4 基础 枚举生成 DropDownList 实用技巧本篇文章小编为大家介绍，MVC4 基础 枚举生成 DropDownList 实用技巧。需要的朋友参考下 2013-04-04
.net socket客户端实例代码分享这篇文章主要介绍了.net写的socket客户端，下面有使用方法，大家参考使用吧 2013-12-12
.Net Core自定义配置源从配置中心读取配置的方法这篇文章主要给大家介绍了关于.Net Core自定义配置源从配置中心读取配置的相关资料，文中通过示例代码以及图文介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧 2019-03-03
最新评论
评论(0)