XdCxRhDW/XdCxRhDW.WebApi/SignalR/Client.cs

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

namespace XdCxRhDW.WebApi.SignalR
{
    class Program
    {
        //static void Main(string[] args)
        //{
        //    IHubProxy hub;
        //    //服务端配置 Startup类中  app.MapSignalR();
        //    //string url = "http://localhost:5000/signalr";

        //    //服务端配置 Startup类中 app.MapSignalR("/hubs", new HubConfiguration());
        //    string url = "http://localhost:5000/hubs";
        //    HubConnection connection = new HubConnection(url);
        //    connection.ConnectionSlow += Connection_ConnectionSlow;
        //    connection.Error += Connection_Error;
        //    connection.StateChanged += Connection_StateChanged;
        //    ///服务端 配置 [HubName("MyTestHub")]
        //    hub = connection.CreateHubProxy("MyTestHub");
        //    connection.Start().Wait();
        //    hub.On("addMessage", x =>
        //    Console.WriteLine(x));
        //    hub.On("SendClient", x =>
        //    {
        //        Console.WriteLine(x);
        //    }
        // );

        //    string groupName = Console.ReadLine();
        //    hub.Invoke("Sign", groupName).Wait();

        //    string sendgroupName = Console.ReadLine();
        //    hub.Invoke("SameGroupMessage", sendgroupName).Wait();

        //    string line = "";
        //    while ((line = Console.ReadLine()) != null)
        //    {
        //        hub.Invoke("Send", "测试", line).Wait();
        //    }

        //    Console.ReadKey();

        //    //connection.Stop();
        //    //connection.Dispose();
        //}

        private static void Connection_StateChanged(StateChange obj)
        {
            if (obj.NewState == ConnectionState.Disconnected)
            {
                Console.WriteLine("连接状态为未连接啦");
            }
        }

        private static void Connection_Error(Exception obj)
        {
            Console.WriteLine("连接发生错误啦");
        }

        private static void Connection_ConnectionSlow()
        {
            Console.WriteLine("连接超时啦");
        }
    }
}