Asp.Net Core使用SignalR進行服務間調用方法示例
網上查詢過很多關于ASP.NET core使用SignalR的簡單例子，但是大部分都是簡易聊天功能，今天心血來潮就搞了個使用SignalR進行服務間調用的簡單DEMO。
至于SignalR是什么我就不多說了，微軟官方文檔也不少。
第一步新建項目
所有VS開發(fā)第一步都是新建一個解決方案哈，這里我就不多介紹如何新建項目啦~~
- 開發(fā)環(huán)境，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
{
}
里面可以實現(xiàn)需要被客戶端執(zhí)行的方法。
配置Hub連接URL
在 Startup.cs 的 Configure 添加下面代碼
app.UseSignalR(routes =>
{
routes.MapHub<ServerHub>("/myserver");
});
添加服務
新建一個Services文件夾，添加我們的服務接口和接口實現(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 方法中進行依賴注入，注意需要在 AddSignalR() 之前注入。
services.AddScoped<IMyService, MyService>();
在ServerHub添加依賴注入
在ServerHub中添加如下代碼
private readonly IServiceProvider _serviceProvider;
public ServerHub(IServiceProvider serviceProvider)
{
_serviceProvider = serviceProvider;
}
因為我們需要使用到依賴注入獲取指定Service，所以只注入 IServiceProvider ，使用 IServiceProvider 動態(tài)獲取服務接口。
使用反射動態(tài)獲取服務接口并執(zhí)行指定方法
為了可以動態(tài)的選擇服務并且執(zhí)行服務相應的方法，我們使用反射來動態(tà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);
}
方法中傳入三個參數(shù)
- serverName：服務接口名稱（完整的命名空間）
- functionName：方法的名稱
- parameters: 方法所需的參數(shù)
1.使用Type.GetType(serverName)獲取服務接口的Type。
2.使用_serviceProvider.GetRequiredService(type)從依賴注入中獲取對應服務。
3.使用type.GetMethod(functionName)獲取需要執(zhí)行的方法。
4.執(zhí)行方法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();
}
}
在構造函數(shù)中初始化SignalR連接
WithUrl("http://localhost:5000/myserver") 是連接被調用方的URL
AddMessagePackProtocol() 是使用快速和精簡的二進制序列化格式進行傳輸。 在 connection.Closed 加入連接關閉事件，關閉后自動重新連接。 InitOnMethod 初始化服務方回調的監(jiān)聽事件
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 };
}
在請求中同時調用一個有返回值，一個無返回值的方法。無返回值的方法在任務執(zhí)行完后執(zhí)行一個回調。
啟動服務
可以看到服務調用已經成功 task done是我們無返回值調用那個方法中接收到回調時的輸出.
connection.On<string>("callback",(msg)=> {
Console.WriteLine($"------------{msg}----------");
});
以上就是我簡單做的一個DEMO。希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
asp.net core 獲取 MacAddress 地址方法示例
這篇文章主要介紹了asp.net core獲取MacAddress地址方法，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2019-02-02
為了更好的用戶體驗，不論是桌面軟件還是網站，在搜索查詢的輸入中都會加入提示功能，就像百度搜索一樣！今天筆者就ASP.NET編程介紹一下如何利用Ajax來實現(xiàn)搜索信息提示功能。2015-09-09
ASP.NET使用ajax實現(xiàn)分頁局部刷新頁面功能
使用ajax方法實現(xiàn)分頁也很簡單，主要是兩個，ContentTemplate和Trigger。先把listView扔ContentTemplate里面。然后在Trigger里面加入asp:AsyncPostBackTrigger，將ID指向之前的分頁控件DataPager控件。具體實現(xiàn)代碼大家可以參考下本文2017-03-03
這篇文章主要介紹了asp.net中生成餅狀與柱狀圖的方法,以實例形式較為詳細的講述了生成餅狀與柱狀圖的原理與具體代碼,包括前后臺的實現(xiàn)代碼,需要的朋友可以參考下2014-11-11
Visual Studio 2017新版發(fā)布 更強大!
Visual Studio 2017新版發(fā)布 更強大!對Visual Studio 2017感興趣的小伙伴們可以參考一下2017-05-05
這篇文章主要介紹了asp.net+ajax的Post請求實現(xiàn)方法,實例分析了Ajax的發(fā)送post數(shù)據(jù)的原理與技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-01-01
這篇文章主要介紹了Asp.Net中Cache操作類實例,需要的朋友可以參考下2014-07-07
Web.Config文件配置之限制上傳文件大小和時間的屬性配置
在Web.Config文件中配置限制上傳文件大小與時間字符串時，是在httpRuntime httpRuntime節(jié)中完成的，需要設置以下2個屬性：maxRequestLength屬性與ExecutionTimeout屬性,感興趣的朋友可以了解下,或許對你有所幫助2013-02-02
Ajax異步無刷新對局部數(shù)據(jù)更新的實例2013-03-03
有關XML文件的節(jié)點屬性值修改在使用過程中經常會遇到過，感興趣的朋友可以參考下本文，希望對你有所幫助2013-04-04