本文共 5410 字，大约阅读时间需要 18 分钟。
网上查询过很多关于ASP.NET core使用SignalR的简单例子，但是大部分都是简易聊天功能，今天心血来潮就搞了个使用SignalR进行服务间调用的简单DEMO。
至于SignalR是什么我就不多说了，微软官方文档也不少。
所有VS开发第一步都是新建一个解决方案哈，这里我就不多介绍如何新建项目啦~~
如此简单的操作大家都懂的
在被调用的服务端的Startup.cs中注入SignalR core2.1中已经默认包含了SignalR的库，直接在ConfigureServices方法中添加如下代码：
services.AddSignalR().AddMessagePackProtocol()
AddMessagePackProtocol()表示启用 MessagePack 支持在服务器上
public class ServerHub : Hub{ } 里面可以实现需要被客户端执行的方法。
在Startup.cs的Configure添加下面代码
app.UseSignalR(routes => { routes.MapHub ("/myserver"); }); 新建一个Services文件夹，添加我们的服务接口和接口实现类。
public interface IMyService{ Task SayHello(); Task Sleep();}public class MyService : IMyService{ public async Task SayHello() { return await Task.Factory.StartNew(() => "Hello"); } public async Task Sleep() { await Task.Delay(3000); }} 在Startup.cs中的ConfigureServices方法中进行依赖注入，注意需要在AddSignalR()之前注入。
services.AddScoped<IMyService, MyService>();
在ServerHub中添加如下代码
private readonly IServiceProvider _serviceProvider; public ServerHub(IServiceProvider serviceProvider) { _serviceProvider = serviceProvider; } 因为我们需要使用到依赖注入获取指定Service，所以只注入IServiceProvider，使用IServiceProvider动态获取服务接口。
为了可以动态的选择服务并且执行服务相应的方法，我们使用反射来动态获取。 这里我们添加两个方法，一个有返回值，一个没有返回值
public async TaskExcute(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); }
方法中传入三个参数
Type.GetType(serverName)获取服务接口的Type。_serviceProvider.GetRequiredService(type)从依赖注入中获取对应服务。type.GetMethod(functionName)获取需要执行的方法。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()在任务处理结束后给调用方返回一条消息。
public class SignalRClient { private readonly HubConnection connection; public SignalRClient() { connection = new HubConnectionBuilder() .WithUrl("http://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("http://localhost:5000/myserver")是连接被调用方的URL
AddMessagePackProtocol()是使用快速和精简的二进制序列化格式进行传输。 在connection.Closed加入连接关闭事件，关闭后自动重新连接。 InitOnMethod初始化服务方回调的监听事件
private void InitOnMethod() { connection.On ("callback",(msg)=> { Console.WriteLine($"------------{msg}----------"); }); } connection.StartAsync()启动连接。
一个有返回值，一个无返回值。
public async TaskRequestServer1() { var result = await connection.InvokeAsync ("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()方法
在Startup.cs中的ConfigureServices方法中添加services.AddSingleton<SignalRClient>()。
在控制器中将SignalRClient注入
private readonly SignalRClient _signalRClient; public ValuesController(SignalRClient signalRClient) { _signalRClient = signalRClient; } // GET api/values [HttpGet] public async Task >> Get() { var str = await _signalRClient.RequestServer1().ConfigureAwait(false); await _signalRClient.RequestWithoutResult().ConfigureAwait(false); return new string[] { str }; } 在请求中同时调用一个有返回值，一个无返回值的方法。无返回值的方法在任务执行完后执行一个回调。
启动服务
可以看到服务调用已经成功 task done是我们无返回值调用那个方法中接收到回调时的输出.
connection.On("callback",(msg)=> { Console.WriteLine($"------------{msg}----------"); });
以上就是我简单做的一个DEMO。如有不足之处，请多多指点。基本没写过文章，写的不好请谅解哈哈~~~
转载地址：http://nscuz.baihongyu.com/