網上查詢過很多關於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類的類

1

2

3

4

public class ServerHub : Hub

{

}

裡面可以實現需要被客戶端執行的方法。

配置Hub連接URL

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

1

2

3

4

app.UseSignalR(routes =>

{

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

});

添加服務

新建一個Services文件夾，添加我們的服務介面和介面實現類。

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

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中添加如下代碼

1

2

3

4

5

private readonly IServiceProvider _serviceProvider;

public ServerHub(IServiceProvider serviceProvider)

{

_serviceProvider = serviceProvider;

}

因為我們需要使用到依賴注入獲取指定Service，所以只注入IServiceProvider，使用IServiceProvider動態獲取服務介面。

使用反射動態獲取服務介面並執行指定方法

為了可以動態的選擇服務並且執行服務相應的方法，我們使用反射來動態獲取。 這裡我們添加兩個方法，一個有返回值，一個沒有返回值

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

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類

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

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初始化服務方回調的監聽事件

1

2

3

4

5

6

private void InitOnMethod()

{

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

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

});

}

connection.StartAsync()啟動連接。

添加兩個請求服務端的方法

一個有返回值，一個無返回值。

1

2

3

4

5

6

7

8

9

10

11

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注入

1

2

3

4

5

6

7

8

9

10

11

12

13

14

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是我們無返回值調用那個方法中接收到回調時的輸出.

1

2

3

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

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

});

結束啦~

以上就是我簡單做的一個DEMO。如有不足之處，請多多指點。基本沒寫過文章，寫的不好請諒解哈哈~~~

作者：飯勺oO

原文：https://www.cnblogs.com/fanshaoO/p/10155735.html

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！