利用.NET怎么實(shí)現(xiàn)一個(gè)WebSocket服務(wù)端即時(shí)通信功能-創(chuàng)新互聯(lián)

CONNECT_POOL.Add(user, socket);

ws.send($("#to").val() + "|" + $('#content').val());

string userMsg = Encoding.UTF8.GetString(buffer.Array, 0, result.Count);

WebSocket destSocket = CONNECT_POOL[descUser];

await destSocket.SendAsync(buffer, WebSocketMessageType.Text, true, CancellationToken.None);

ws.onmessage = function (evt) {

　　$('#msg').append('
' + evt.data + '
');

}

 
 
 
 
 


 

 
 
 
 
 
 
 目的用戶
 
 
 

服務(wù)器端部分

服務(wù)器端使用Handler（也可用WebAPI）來做，主要用WebSocket的類來實(shí)現(xiàn)。代碼中都有相對詳細(xì)的注釋，這邊只說一些需要注意的問題

1：Dictionary CONNECT_POOL：用戶連接池。請求Handler的時(shí)候會將當(dāng)前連接者的用戶ID傳入，服務(wù)器端維護(hù)著所有已連接的用戶ID和當(dāng)前用戶的WebSocket連接對象

2：Dictionary> MESSAGE_POOL：離線消息池。如果A->B發(fā)送消息，B當(dāng)前因?yàn)槟撤N原因沒在線（突然斷網(wǎng)/黑屏等原因），會將這條消息先保存起來（2天），待B連接后立馬將B的離線消息推送給他。（2：MessageInfo：離線Entity。記錄當(dāng)前離線消息的時(shí)間、內(nèi)容）

using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Web;
using System.Web.WebSockets;

namespace WebApplication1
{
 /// 

 /// 離線消息
 /// 
 public class MessageInfo
 {
 public MessageInfo(DateTime _MsgTime, ArraySegment _MsgContent)
 {
  MsgTime = _MsgTime;
  MsgContent = _MsgContent;
 }
 public DateTime MsgTime { get; set; }
 public ArraySegment MsgContent { get; set; }
 }

 /// 

 /// Handler1 的摘要說明
 /// 
 public class Handler1 : IHttpHandler
 {
 private static Dictionary CONNECT_POOL = new Dictionary();//用戶連接池
 private static Dictionary> MESSAGE_POOL = new Dictionary>();//離線消息池

 public void ProcessRequest(HttpContext context)
 {
  if (context.IsWebSocketRequest)
  {
  context.AcceptWebSocketRequest(ProcessChat);
  } 
 }

 private async Task ProcessChat(AspNetWebSocketContext context)
 {
  WebSocket socket = context.WebSocket;
  string user = context.QueryString["user"].ToString();

  try
  {
  #region 用戶添加連接池
  //第一次open時(shí)，添加到連接池中
  if (!CONNECT_POOL.ContainsKey(user))
   CONNECT_POOL.Add(user, socket);//不存在，添加
  else
   if (socket != CONNECT_POOL[user])//當(dāng)前對象不一致，更新
   CONNECT_POOL[user] = socket;
  #endregion

  #region 離線消息處理
  if (MESSAGE_POOL.ContainsKey(user))
  {
   List msgs = MESSAGE_POOL[user];
   foreach (MessageInfo item in msgs)
   {
   await socket.SendAsync(item.MsgContent, WebSocketMessageType.Text, true, CancellationToken.None);
   }
   MESSAGE_POOL.Remove(user);//移除離線消息
  }
  #endregion

  string descUser = string.Empty;//目的用戶
  while (true)
  {
   if (socket.State == WebSocketState.Open)
   {
   ArraySegment buffer = new ArraySegment(new byte[2048]);
   WebSocketReceiveResult result = await socket.ReceiveAsync(buffer, CancellationToken.None);
   
   #region 消息處理（字符截取、消息轉(zhuǎn)發(fā)）
   try
   {
    #region 關(guān)閉Socket處理，刪除連接池
    if (socket.State != WebSocketState.Open)//連接關(guān)閉
    {
    if (CONNECT_POOL.ContainsKey(user)) CONNECT_POOL.Remove(user);//刪除連接池
    break;
    }
    #endregion

    string userMsg = Encoding.UTF8.GetString(buffer.Array, 0, result.Count);//發(fā)送過來的消息
    string[] msgList = userMsg.Split('|');
    if (msgList.Length == 2)
    {
    if (msgList[0].Trim().Length > 0)
     descUser = msgList[0].Trim();//記錄消息目的用戶
    buffer = new ArraySegment(Encoding.UTF8.GetBytes(msgList[1]));
    }
    else
    buffer = new ArraySegment(Encoding.UTF8.GetBytes(userMsg));

    if (CONNECT_POOL.ContainsKey(descUser))//判斷客戶端是否在線
    {
    WebSocket destSocket = CONNECT_POOL[descUser];//目的客戶端
    if (destSocket != null && destSocket.State == WebSocketState.Open)
     await destSocket.SendAsync(buffer, WebSocketMessageType.Text, true, CancellationToken.None);
    }
    else
    {
    Task.Run(() =>
    {
     if (!MESSAGE_POOL.ContainsKey(descUser))//將用戶添加至離線消息池中
     MESSAGE_POOL.Add(descUser, new List());
     MESSAGE_POOL[descUser].Add(new MessageInfo(DateTime.Now, buffer));//添加離線消息
    });
    }
   }
   catch (Exception exs)
   {
    //消息轉(zhuǎn)發(fā)異常處理，本次消息忽略 繼續(xù)監(jiān)聽接下來的消息
   }
   #endregion
   }
   else
   {
   break;
   }
  }//while end
  }
  catch (Exception ex)
  {
  //整體異常處理
  if (CONNECT_POOL.ContainsKey(user)) CONNECT_POOL.Remove(user);
  }
 }

 public bool IsReusable
 {
  get
  {
  return false;
  }
 }
 }
}

上述就是小編為大家分享的利用.NET怎么實(shí)現(xiàn)一個(gè)WebSocket服務(wù)端即時(shí)通信功能了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。