SignalR入門之多平台SignalR服務端

之前創建SignalR服務端是基於Web應用程序而言的。那么能不能把SignalR服務端做成控制台應用程序、Winform或windows服務呢？

答案是肯定的。

之前盡管看起來好像是IIS和ASP.Net構成托管SignalR服務的唯一環境，但事實上並非如此，很多情況下采用的並非是IIS和ASP.NET。

現在，在這里以控制台程序為例，將SignalR服務端建立在控制台程序里。

如何在控制台程序實現基於Hub或持久性連接的SignalR服務呢，首先安裝下面的包：

install-package Microsoft.AspNet.SignalR.SelfHost

安裝完成后，項目會自動加載需要引用的庫文件。

然后在控制台的Program類中

using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            using (WebApp.Start<Startup>("http://localhost:8888/"))//啟動服務，訪問路徑在這里配置。
            {
                Console.WriteLine("Server running at http://localhost:8888/");
                Console.ReadLine();
            }
        }
    }
}

在上面的代碼中，我們可以看出需要一個啟動類Starup,這個類與我們之前建立持久性連接或Hub一樣。

using System;
using System.Threading.Tasks;
using Microsoft.Owin;
using Owin;

[assembly: OwinStartup(typeof(Startup))]

public class Startup
{
    public void Configuration(IAppBuilder app)
    {
        app.MapSignalR<TestConnection>("/test");//配置指定持久性連接類，同時映射訪問路徑后面有用
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using System.Web;
using Microsoft.AspNet.SignalR;

public class TestConnection : PersistentConnection
{
    protected override Task OnConnected(IRequest request, string connectionId)
    {
        return Connection.Send(connectionId, "Welcome!");
    }

    protected override Task OnReceived(IRequest request, string connectionId, string data)
    {
        Console.WriteLine(connectionId+"============="+data);//服務端接受消息
        return Connection.Broadcast(data);//將消息發送給所有客戶端
    }
}

以上的方式是在控制台里面建立SignalR服務，以持久性連接的方式進行編碼的。

當然，我們也可以利用Hub來設置服務端，方式與之前的一樣。

SignalR的服務端建立好后，我們需要建立一個客戶端，之前，我們的客戶端都是在html中以js的方式進行建立連接的。那么現在，我們將客戶端也建立為控制台應用程序。

首先建立一個控制台應用程序，然后安裝如下包：

install-package microsoft.aspnet.signalr.client

 

然后在Program類中的Main方法中編寫：

using Microsoft.AspNet.SignalR.Client.Transports;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Microsoft.AspNet.SignalR;
using Microsoft.AspNet.SignalR.Client;
namespace ConsoleApplication2
{
    class Program
    {
        static void Main(string[] args)
        {
            try
            {
                //GlobalHost
                var connection = new Connection("http://localhost:8888/test");//服務端配置好的訪問路徑以及持久性連接映射路徑
                
                connection.Start();//開始連接
                connection.Received += Connection_Received;//配置接受消息事件
                string str = "";
                while ((str = Console.ReadLine()) != "")
                {
                    connection.Send(str);//發送消息
                }
        
            }
            catch (Exception ex)
            {

                Console.WriteLine(ex.Message);
            }
            Console.Read();
        }

        private static void Connection_Received(string obj)
        {
            Console.WriteLine(obj);
        }
    }
}