怎么在Asp.Net Core中利用SignalR實(shí)現(xiàn)服務(wù)間調(diào)用

本篇文章為大家展示了怎么在Asp.Net Core中利用SignalR實(shí)現(xiàn)服務(wù)間調(diào)用，內(nèi)容簡(jiǎn)明扼要并且容易理解，絕對(duì)能使你眼前一亮，通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。

第一步新建項(xiàng)目

所有VS開(kāi)發(fā)第一步都是新建一個(gè)解決方案哈，這里我就不多介紹如何新建項(xiàng)目啦~~

• 開(kāi)發(fā)環(huán)境，VS2017,.NET CORE 2.1

• 新建兩個(gè)asp.net core項(xiàng)目 

如此簡(jiǎn)單的操作大家都懂的

注入SignalR

在被調(diào)用的服務(wù)端的Startup.cs中注入SignalR 在asp.net core2.1中已經(jīng)默認(rèn)包含了SignalR的庫(kù)，直接在 ConfigureServices 方法中添加如下代碼：

services.AddSignalR().AddMessagePackProtocol()

AddMessagePackProtocol() 表示啟用 MessagePack 支持在服務(wù)器上

新建一個(gè)繼承Hub類的類

public class ServerHub : Hub
{
 }

里面可以實(shí)現(xiàn)需要被客戶端執(zhí)行的方法。

配置Hub連接URL

在 Startup.cs 的 Configure 添加下面代碼

app.UseSignalR(routes =>
{

  routes.MapHub<ServerHub>("/myserver");

});

添加服務(wù)

新建一個(gè)Services文件夾，添加我們的服務(wù)接口和接口實(shí)現(xiàn)類。

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 方法中進(jìn)行依賴注入，注意需要在 AddSignalR() 之前注入。

services.AddScoped<IMyService, MyService>();

在ServerHub添加依賴注入

在ServerHub中添加如下代碼

private readonly IServiceProvider _serviceProvider;

 public ServerHub(IServiceProvider serviceProvider)

 {

   _serviceProvider = serviceProvider;

 }

因?yàn)槲覀冃枰褂玫揭蕾囎⑷氆@取指定Service，所以只注入 IServiceProvider ，使用 IServiceProvider 動(dòng)態(tài)獲取服務(wù)接口。

使用反射動(dòng)態(tài)獲取服務(wù)接口并執(zhí)行指定方法

為了可以動(dòng)態(tài)的選擇服務(wù)并且執(zhí)行服務(wù)相應(yīng)的方法，我們使用反射來(lái)動(dòng)態(tài)獲取。 這里我們添加兩個(gè)方法，一個(gè)有返回值，一個(gè)沒(méi)有返回值

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);

}

方法中傳入三個(gè)參數(shù)

• serverName：服務(wù)接口名稱（完整的命名空間）

• functionName：方法的名稱

• parameters: 方法所需的參數(shù)

1.使用Type.GetType(serverName)獲取服務(wù)接口的Type。
2.使用_serviceProvider.GetRequiredService(type)從依賴注入中獲取對(duì)應(yīng)服務(wù)。
3.使用type.GetMethod(functionName)獲取需要執(zhí)行的方法。
4.執(zhí)行方法method.Invoke(service, new object[] { })

由于我們的服務(wù)是異步方法， method.Invoke() 返回的是一個(gè) object 對(duì)象，所以在將 method.Invoke() 返回類型轉(zhuǎn)為 Task 類型。

resultTask.GetType().GetProperty("Result").GetValue(resultTask, null) 是通過(guò)反射獲取 Task 的 Result 屬性來(lái)回去相應(yīng)的返回結(jié)果。

因?yàn)槲覀儾恢婪椒ǚ祷氐?Task 中返回的結(jié)果類型是什么，所以我們依舊使用反射來(lái)獲取 Task 的結(jié)果并使用 dynamic 接收。

無(wú)返回值的我們使用 Clients.Caller.SendAsync() 在任務(wù)處理結(jié)束后給調(diào)用方返回一條消息。

在調(diào)用方添加一個(gè)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();

  }

}

在構(gòu)造函數(shù)中初始化SignalR連接

WithUrl("http://localhost:5000/myserver") 是連接被調(diào)用方的URL

AddMessagePackProtocol() 是使用快速和精簡(jiǎn)的二進(jìn)制序列化格式進(jìn)行傳輸。 在 connection.Closed 加入連接關(guān)閉事件，關(guān)閉后自動(dòng)重新連接。 InitOnMethod 初始化服務(wù)方回調(diào)的監(jiān)聽(tīng)事件

private void InitOnMethod()

{

  connection.On<string>("callback",(msg)=> {

    Console.WriteLine($"------------{msg}----------");

  });

}

connection.StartAsync() 啟動(dòng)連接。

添加兩個(gè)請(qǐng)求服務(wù)端的方法

一個(gè)有返回值，一個(gè)無(wú)返回值。

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以單例形式注冊(cè)依賴注入

在 Startup.cs 中的 ConfigureServices 方法中添加 services.AddSingleton<SignalRClient>() 。

使用SignalRClient請(qǐng)求服務(wù)

在控制器中將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 };

}

在請(qǐng)求中同時(shí)調(diào)用一個(gè)有返回值，一個(gè)無(wú)返回值的方法。無(wú)返回值的方法在任務(wù)執(zhí)行完后執(zhí)行一個(gè)回調(diào)。

啟動(dòng)服務(wù)

可以看到服務(wù)調(diào)用已經(jīng)成功 task done是我們無(wú)返回值調(diào)用那個(gè)方法中接收到回調(diào)時(shí)的輸出.

connection.On<string>("callback",(msg)=> {

      Console.WriteLine($"------------{msg}----------");

    });

上述內(nèi)容就是怎么在Asp.Net Core中利用SignalR實(shí)現(xiàn)服務(wù)間調(diào)用，你們學(xué)到知識(shí)或技能了嗎？如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備，歡迎關(guān)注億速云行業(yè)資訊頻道。