WebSocketServer ws = new WebSocketServer();
ws.NewMessageReceived += Ws_NewMessageReceived;//當(dāng)有信息傳入時(shí)
ws.NewSessionConnected += Ws_NewSessionConnected;//當(dāng)有用戶連入時(shí)
ws.SessionClosed += Ws_SessionClosed;//當(dāng)有用戶退出時(shí)
ws.NewDataReceived += Ws_NewDataReceived;//當(dāng)有數(shù)據(jù)傳入時(shí)
if (ws.Setup(10086))//綁定端口
    ws.Start();//啟動(dòng)服務(wù)  

Dictionary<WebSocketSession, string> userlist = new Dictionary<WebSocketSession, string>();//用戶列表

//添加至用戶集合的方法
   public void AddUser(string UserName, WebSocketSession session)
   {
       userList.Add(session, UserName);
   }
   //login對應(yīng)封裝dic方法
    public Dictionary<string, string> login(Dictionary<string, string> Query, T curUser)
   {
       UserConnHandle userConn = () => { return Query["userid"]; };
       Dictionary<string, string> Respon = new Dictionary<string, string>();
       if (!service.userList.ContainsKey(curUser))
       {
           if (Query["user"] == "" || Query["user"] == null)
           {
               Respon.Add("user", Guid.NewGuid().ToString().Replace("-", ""));
           }
           else
           {
               Respon.Add("userid", Query["userid"]);
           }
           Respon.Add("type", "1");//為了前端更容易操作
           Respon.Add("send", "0");//這里0是告訴發(fā)給所有用戶還是當(dāng)前用戶
           service.AddUser(Respon["user"], curUser);//將當(dāng)前用戶添加至用戶集合
       }
       return Respon;
   }
//有新消息傳入時(shí)
   private void Ws_NewMessageReceived(WebSocketSession session, string value)
   {
       Dictionary<string, string> res = login(value, session, this) as Dictionary<string, string>;
       switch (res["send"])
       {
           case "0":
               res.Remove("send");
               Send(res);//全部發(fā)送
               break;
           case "1":
               res.Remove("send");
               string username = res["to"];
               WebSocketSession keys = userlist.Where(q => q.Value == username).Select(q => q.Key).First();
               SendTo(keys, res);//針對發(fā)送
               break;
       }
   }

//發(fā)送給所有用戶
   public void Send(string msg)
   {
       foreach (var item in userList)
       {
           item.Key.Send(msg);
       }
   }
 
   //發(fā)送給單個(gè)用戶
   public void SendTo(WebSocketSession session, string msg)
   {
       session.Send(msg);
   }