数码控科技猎奇Iphone动漫星座游戏电竞lolcosplay王者荣耀攻略allcnewsBLOGNEWSBLOGASKBLOGBLOGZSK全部技术问答问答技术问答it问答代码软件新闻开发博客电脑/网络手机/数码笔记本电脑互联网操作系统软件硬件编程开发360产品资源分享电脑知识文档中心IT全部全部分类全部分类技术牛文全部分类教程最新网页制作cms教程平面设计媒体动画操作系统网站运营网络安全服务器教程数据库工具网络安全软件教学vbscript正则表达式javascript批处理更多»编程更新教程更新游戏更新allitnewsJava新闻网络医疗信息化安全创业站长电商科技访谈域名会议专栏创业动态融资创投创业学院 / 产品经理创业公司人物访谈营销开发数据库服务器系统虚拟化云计算嵌入式移动开发作业作业1常见软件all电脑网络手机数码生活游戏体育运动明星影音休闲爱好文化艺术社会民生教育科学医疗健康金融管理情感社交地区其他电脑互联网软件硬件编程开发360相关产品手机平板其他电子产品摄影器材360硬件通讯智能设备购物时尚生活常识美容塑身服装服饰出行旅游交通汽车购房置业家居装修美食烹饪单机电脑游戏网页游戏电视游戏桌游棋牌游戏手机游戏小游戏掌机游戏客户端游戏集体游戏其他游戏体育赛事篮球足球其他运动球类运动赛车健身运动运动用品影视娱乐人物音乐动漫摄影摄像收藏宠物幽默搞笑起名花鸟鱼虫茶艺彩票星座占卜书画美术舞蹈小说图书器乐声乐小品相声戏剧戏曲手工艺品历史话题时事政治就业职场军事国防节日风俗法律法规宗教礼仪礼节自然灾害360维权社会人物升学入学人文社科外语资格考试公务员留学出国家庭教育学习方法语文物理生物工程学农业数学化学健康知识心理健康孕育早教内科外科妇产科儿科皮肤科五官科男科整形中医药品传染科其他疾病医院两性肿瘤科创业投资企业管理财务税务银行股票金融理财基金债券保险贸易商务文书国民经济爱情婚姻家庭烦恼北京上海重庆天津黑龙江吉林辽宁河北内蒙古山西陕西宁夏甘肃青海新疆西藏四川贵州云南河南湖北湖南山东江苏浙江安徽江西福建广东广西海南香港澳门台湾海外地区

Asp.Net Core使用SignalR进行服务间调用方法示例

来源:脚本之家  责任编辑:小易  

网上查询过很多关于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类的类

public class ServerHub : Hub
{
 }

里面可以实现需要被客户端执行的方法。

配置Hub连接URL

Startup.csConfigure 添加下面代码

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) 是通过反射获取 TaskResult 属性来回去相应的返回结果。

因为我们不知道方法返回的 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}----------");

    });

以上就是我简单做的一个DEMO。希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

您可能感兴趣的文章:


  • 本文相关:
  • asp.net core signalr中的流式传输深入讲解
  • asp.net core 2.0 webapi集成signalr(实例讲解)
  • 详解在asp.net core下使用signalr技术
  • asp.net dropdownlist 三级联动下拉菜单实现代码
  • asp.net中日历控件和js版日历控件的使用方法(第5节)
  • “/”应用程序中的服务器错误
  • 详解将asp.net core应用程序部署至生产环境中(centos7)
  • c# 邮件地址是否合法的验证
  • asp.net文件上传控件uploadify的使用方法
  • asp.net中nhiernate的session的管理
  • asp.net json字符串与实体类的互转换示例代码
  • .net 日志系统解析
  • 彻底解决asp.net md5加密中文结果和asp不一致的问题
  • 免责声明 - 关于我们 - 联系我们 - 广告联系 - 友情链接 - 帮助中心 - 频道导航
    Copyright © 2017 www.zgxue.com All Rights Reserved