以前建立SignalR服务端是基于Web应用程序而言的。那么能不能把SignalR服务端作成控制台应用程序、Winform或windows服务呢?html
答案是确定的。windows
以前尽管看起来好像是IIS和ASP.Net构成托管SignalR服务的惟一环境,但事实上并不是如此,不少状况下采用的并不是是IIS和ASP.NET。app
如今,在这里以控制台程序为例,将SignalR服务端创建在控制台程序里。ide
如何在控制台程序实现基于Hub或持久性链接的SignalR服务呢,首先安装下面的包:ui
install-package Microsoft.AspNet.SignalR.SelfHost编码
安装完成后,项目会自动加载须要引用的库文件。spa
而后在控制台的Program类中code
1 using System.Linq; 2 using System.Text; 3 using System.Threading.Tasks; 4 5 namespace ConsoleApplication1 6 { 7 class Program 8 { 9 static void Main(string[] args) 10 { 11 using (WebApp.Start<Startup>("http://localhost:8888/"))//启动服务,访问路径在这里配置。 12 { 13 Console.WriteLine("Server running at http://localhost:8888/"); 14 Console.ReadLine(); 15 } 16 } 17 } 18 }
在上面的代码中,咱们能够看出须要一个启动类Starup,这个类与咱们以前创建持久性链接或Hub同样。orm
1 using System; 2 using System.Threading.Tasks; 3 using Microsoft.Owin; 4 using Owin; 5 6 [assembly: OwinStartup(typeof(Startup))] 7 8 public class Startup 9 { 10 public void Configuration(IAppBuilder app) 11 { 12 app.MapSignalR<TestConnection>("/test");//配置指定持久性链接类,同时映射访问路径后面有用 13 } 14 }
1 using System; 2 using System.Collections.Generic; 3 using System.Linq; 4 using System.Threading.Tasks; 5 using System.Web; 6 using Microsoft.AspNet.SignalR; 7 8 public class TestConnection : PersistentConnection 9 { 10 protected override Task OnConnected(IRequest request, string connectionId) 11 { 12 return Connection.Send(connectionId, "Welcome!"); 13 } 14 15 protected override Task OnReceived(IRequest request, string connectionId, string data) 16 { 17 Console.WriteLine(connectionId+"============="+data);//服务端接受消息 18 return Connection.Broadcast(data);//将消息发送给全部客户端 19 } 20 }
以上的方式是在控制台里面创建SignalR服务,以持久性链接的方式进行编码的。htm
固然,咱们也能够利用Hub来设置服务端,方式与以前的同样。
SignalR的服务端创建好后,咱们须要创建一个客户端,以前,咱们的客户端都是在html中以js的方式进行创建链接的。那么如今,咱们将客户端也创建为控制台应用程序。
首先创建一个控制台应用程序,而后安装以下包:
install-package microsoft.aspnet.signalr.client
而后在Program类中的Main方法中编写:
1 using Microsoft.AspNet.SignalR.Client.Transports; 2 using System; 3 using System.Collections.Generic; 4 using System.Linq; 5 using System.Text; 6 using System.Threading.Tasks; 7 using Microsoft.AspNet.SignalR; 8 using Microsoft.AspNet.SignalR.Client; 9 namespace ConsoleApplication2 10 { 11 class Program 12 { 13 static void Main(string[] args) 14 { 15 try 16 { 17 //GlobalHost 18 var connection = new Connection("http://localhost:8888/test");//服务端配置好的访问路径以及持久性链接映射路径 19 20 connection.Start();//开始链接 21 connection.Received += Connection_Received;//配置接受消息事件 22 string str = ""; 23 while ((str = Console.ReadLine()) != "") 24 { 25 connection.Send(str);//发送消息 26 } 27 28 } 29 catch (Exception ex) 30 { 31 32 Console.WriteLine(ex.Message); 33 } 34 Console.Read(); 35 } 36 37 private static void Connection_Received(string obj) 38 { 39 Console.WriteLine(obj); 40 } 41 } 42 }