网上查询过很多关于ASP .网核心使用信号员的简单例子，但是大部分都是简易聊天功能，今天心血来潮就搞了个使用信号员进行服务间调用的简单演示。

至于信号员是什么我就不多说了，微软官方文档也不少。

第一步新建项目

所有对开发第一步都是新建一个解决方案哈，这里我就不多介绍如何新建项目啦~~

开发环境，VS2017，10 .网络核心2.1新建两个ASP。网核心项目

如此简单的操作大家都懂的

注入信号员

在被调用的服务端的Startup.cs中注入信号员在ASP。网核心2.1中已经默认包含了信号员的库，直接在配置服务方法中添加如下代码：

服务AddSignalR().AddMessagePackProtocol()

AddMessagePackProtocol()表示启用MessagePack支持在服务器上

新建一个继承中心类的类

公共类服务器集线器：集线器{ }里面可以实现需要被客户端执行的方法。

配置中心连接统一资源定位器

在Startup.cs的安装使成形添加下面代码

应用程序.usesignor(routes={ routes .MapHubServerHub(“/my server”)；});添加服务

新建一个服务文件夹，添加我们的服务接口和接口实现类。

公共接口IMyservice { TaskString SayHello()；任务睡眠();}公共类我的服务： IMyService {公共异步任务字符串sayHello(){返回等待任务.工厂。StartNew(()=' Hello ')；}公共异步任务睡眠(){等待任务。延迟(3000);}}在Startup.cs中的配置服务方法中进行依赖注入，注意需要在AddSignalR()之前注入。

服务AddScopedIMyService，my service()；

在服务器中心添加依赖注入

在服务器中心中添加如下代码

private readonly IServiceProvider _ ServiCeProvider；public ServerHub(iServiceProvider ServiCeProvider){ _ ServiCeProvider=ServiCeProvider；}因为我们需要使用到依赖注入获取指定服务，所以只注入IServiceProvider，使用构造函数动态获取服务接口。

使用反射动态获取服务接口并执行指定方法

为了可以动态的选择服务并且执行服务相应的方法，我们使用反射来动态获取。这里我们添加两个方法，一个有返回值，一个没有返回值

公共异步任务动态执行（字符串服务器名、字符串函数名、对象[]参数){返回等待任务。工厂。开始新(()={变量类型=类型. GetType(服务器名);var service=_serviceProvider .GetRequiredService(类型);定义变量方法=类型GetMethod(函数名)；var resultTask=方法。将（服务，新对象[] { })作为任务调用；动态结果=结果任务GetType().获取属性("结果")。GetValue(resultTask，null)；返回结果；});}公共异步任务ExcuteWithoutResult(字符串服务器名、字符串函数名、对象[]参数){变量类型=类型.GetType(服务器名);var service=_serviceProvider .GetRequiredService(类型);定义变量方法=类型GetMethod(函数名)；var resultTask=方法。将（服务，新对象[] { })作为任务调用；等待结果任务；var msg="任务完成";等待客户。调用者。SendAsync(“”回调，味精)；}方法中传入三个参数

服务器名：服务接口名称（完整的命名空间)功能名称：方法的名称参数：方法所需的参数1.使用打字。获取类型（服务器名)获取服务接口的类型.2.使用_服务提供商.GetRequiredService(类型)从依赖注入中获取对应服务。3.使用打字GetMethod(函数名)获取需要执行的方法。4.执行方法方法。调用（服务，新对象[] { })

由于我们的服务是异步方法，方法。调用()返回的是一个目标对象，所以在将方法。调用()返回类型转为工作类型。

结果任务GetType().获取属性("结果")。获取值（结果任务，空)是通过反射获取工作的结果属性来回去相应的返回结果。

因为我们不知道方法返回的工作中返回的结果类型是什么，所以我们依旧使用反射来获取工作的结果并使用动态的接收。

无返回值的我们使用客户。调用方。发送异步()在任务处理结束后给调用方返回一条消息。

在调用方添加一个单循环客户端类

公共类信号客户端{私有只读HubConnection连接；公共信号客户端(){ connection=new HubConnectionBuilder().带URl(' http://localhost :5000/我的服务器').AddMessagePackProtocol().build()；连接。关闭=异步（错误)={等待任务。延迟（新的随机()。Next(0，5)* 1000；等待连接StartAsync()；};InitOnMethod()；连接StartAsync().配置等待（假)。GetAwaiter().GetResult()；}}在构造函数中初始化信号员连接

带URl(' http://localhost :5000/我的服务器')是连接被调用方的URLAddMessagePackProtocol()是使用快速和精简的二进制序列化格式进行传输。在连接。关闭的加入连接关闭事件，关闭后自动重新连接初始化方法。初始化服务方回调的监听事件

private void InitOnMethod(){连接.Onstring('callback '，(msg)={ Console .写行($ '-{ msg }-')；});}连接StartAsync()启动连接。

添加两个请求服务端的方法

一个有返回值，一个无返回值。

公共异步任务动态请求服务器1(){ var result=等待连接.调用异步动态(“执行”，“信号服务器1 .服务。IMyService '，' SayHello '，新对象[]{ })；返回结果；}公共异步任务请求无结果(){等待连接发送异步消息('除外结果'，'信号服务器1 .服务。IMyService '，'睡眠'，新对象[]{ });}需要返回值的我们使用连接InvokeAsync()方法

不需要返回值的我们使用连接发送异步()方法

将信号客户端以单例形式注册依赖注入

在Startup.cs中的配置服务方法中添加服务. AddSingletonSignalRClient()。

使用信号客户端请求服务

在控制器中将信号客户端注入

私有只读信号客户端_信号客户端；公共值控制器(信号客户端信号客户端){ _信号客户端=信号客户端；}//GET API/values[HttpGet]public async tasactionresultienumerablesting GET(){ var str=await _ signal rcclient .RequestServer1().配置等待（假);await _ signalRClient .RequestWithoutResult().配置等待（假);返回新字符串[]{ str }；}在请求中同时调用一个有返回值，一个无返回值的方法。无返回值的方法在任务执行完后执行一个回调。

启动服务

可以看到服务调用已经成功任务完成是我们无返回值调用那个方法中接收到回调时的输出。

连接Onstring('callback '，(msg)={ Console .写行($ '-{ msg }-')；});以上就是我简单做的一个演示。希望对大家的学习有所帮助，也希望大家多多支持我们。