第五节：SignalR大杂烩(与MVC融合、全局的几个配置、跨域的应用、C/S程序充当Client和Server)

 1     /// <summary>
 2     /// 整合MVC和SignalR
 3     /// </summary>
 4     public class BaseController<T> : Controller where T : Hub
 5     {
 6         public IHubConnectionContext<dynamic> Clients { get; set; }
 7 
 8         public IGroupManager Groups { get; set; }
 9 
10         public BaseController()
11         {
12             var hub = GlobalHost.ConnectionManager.GetHubContext<T>();
13             Clients = hub.Clients;
14             Groups = hub.Groups;
15         }
16     }

 1  public class HubController : BaseController<MySpecHub1>
 2     {
 3        
 4         /// <summary>
 5         /// 向所有人发送消息
 6         /// </summary>
 7         /// <param name="myConnectionId">当前用户的登录标记</param>
 8         /// <param name="msg">发送的信息</param>
 9         public string MySendAll(string myConnectionId, string msg)
10         {
11             //Hub模式
12             Clients.AllExcept(myConnectionId).receiveMsg($"用户【{myConnectionId}】发来消息：{msg}");
13             return "ok";
14         }
15 
16     }

 1   public class Startup
 2     {
 3         public void Configuration(IAppBuilder app)
 4         {
 5           //配置允许跨域
 6             //1. JSONP模式
 7             //app.MapSignalR(new HubConfiguration() { EnableJSONP = true });
 8 
 9             //2. Cors模式(需要安装Microsoft.Owin.Cors程序集)
10             app.UseCors(CorsOptions.AllowAll).MapSignalR();
11         }
12     }

 1   class Program
 2     {
 3         static void Main(string[] args)
 4         {
 5 
 6             //一. 基础信息配置
 7             //1. 与服务器路径进行匹配
 8             var conn = new HubConnection("http://localhost:8099/signalr/");
 9             //2. 创建代理类
10             var proxy = conn.CreateHubProxy("MySpecHub1");
11 
12 
13             //二. 定义客户端的方法
14             //特别注意，如果定义的方法大于一个参数的时候，msg的位置需要声明一个类来接受
15             //1 接受用户登录成功后的提示
16 
17             proxy.On("LoginSuccessNotice", (msg) =>
18             {
19                 Console.WriteLine(msg);
20             });
21 
22             //2  接收自己的connectionId
23             proxy.On("ReceiveOwnCid", (msg) =>
24             {
25                 Console.WriteLine(msg);
26             });
27 
28             //三. 启动
29             conn.Start().Wait();
30 
31             Console.ReadKey();
32 
33         }
34     }

 1       static void Main(string[] args)
 2         {
 3             try
 4             {
 5                 string url = "http://localhost:7080";
 6                 using (WebApp.Start<Startup>(url))
 7                 {
 8                     Console.WriteLine("Server running on {0}", url);
 9                     Console.ReadLine();
10                 }
11             }
12             catch (Exception ex)
13             {
14                 Console.WriteLine(ex.Message);
15             }
16             Console.ReadKey();
17         }