怎么在Asp.Net Core中利用SignalR实现服务间调用

本篇文章为大家展示了怎么在Asp.Net Core中利用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("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<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}----------");     });

上述内容就是怎么在Asp.Net Core中利用SignalR实现服务间调用，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注亿速云行业资讯频道。