&

.net+H5 webSocket 實現聊天

admin

2019年11月12日 15:16 本文熱度 3918

Html代碼：

var webSocket = new WebSocket("ws://localhost:9226/api/sys/test/GetConnect?nickName=admin" );

webSocket.onopen = function () {

console.log("opened");

alert("已開啟，可聊天");

}

webSocket.onerror = function () {

console.log("web socket error");

}

webSocket.onmessage = function (event) {

console.log("onmessage");

console.log(event);

document.getElementById("contentArea").value = document.getElementById("contentArea").value + "\r\n" + event.data;

}

webSocket.onclose = function () { console.log("closed"); }

function send() {

var value =document.getElementById("name").value+":"+ document.getElementById("content").value;

webSocket.send(value);

document.getElementById("contentArea").value = document.getElementById("contentArea").value + "\r\n" + value;

document.getElementById("content").value = "";

}

</script>

.net 代碼

web.config處

在 system.web 下 httpRuntime加入 targetFramework="4.5"

ApiControoler部分

private static List<WebSocket> _sockets = new List<WebSocket>();

[System.Web.Http.HttpGet]

public HttpResponseMessage GetConnect(string nickName)

{

HttpContext.Current

.AcceptWebSocketRequest(

ProcessRequest); //在服務器端接受Web Socket請求，傳入的函數作為Web Socket的處理函數，待Web Socket建立后該函數會被調用，在該函數中可以對Web Socket進行消息收發

return Request.CreateResponse(HttpStatusCode.SwitchingProtocols); //構造同意切換至Web Socket的Response.

}

public async Task ProcessRequest(AspNetWebSocketContext context)

{

var socket = context.WebSocket; //傳入的context中有當前的web socket對象

_sockets.Add(socket); //此處將web socket對象加入一個靜態列表中

//進入一個無限循環，當web socket close是循環結束

while (true)

{

var buffer = new ArraySegment<byte>(new byte[1024]);

var receivedResult = await socket.ReceiveAsync(buffer, CancellationToken.None); //對web socket進行異步接收數據

if (receivedResult.MessageType == WebSocketMessageType.Close)

{

await socket.CloseAsync(WebSocketCloseStatus.Empty, string.Empty,

CancellationToken.None); //如果client發起close請求，對client進行ack

_sockets.Remove(socket);

break;

}

if (socket.State == System.Net.WebSockets.WebSocketState.Open)

{

string recvMsg = Encoding.UTF8.GetString(buffer.Array, 0, receivedResult.Count);

var recvBytes = Encoding.UTF8.GetBytes(recvMsg);

var sendBuffer = new ArraySegment<byte>(recvBytes);

foreach (var innerSocket in _sockets) //當接收到文本消息時，對當前服務器上所有web socket連接進行廣播

{

if (innerSocket != socket)

{

await innerSocket.SendAsync(sendBuffer, WebSocketMessageType.Text, true,

CancellationToken.None);

}

該文章在 2019/11/12 15:16:57 編輯過

關鍵字查詢

實現

聊天

正在查詢...

點晴ERP是一款針對中小制造業的專業生產管理軟件系統,系統成熟度和易用性得到了國內大量中小企業的青睞。

點晴PMS碼頭管理系統主要針對港口碼頭集裝箱與散貨日常運作、調度、堆場、車隊、財務費用、相關報表等業務管理，結合碼頭的業務特點，圍繞調度、堆場作業而開發的。集技術的先進性、管理的有效性于一體，是物流碼頭及其他港口類企業的高效ERP管理信息系統。

點晴WMS倉儲管理系統提供了貨物產品管理,銷售管理,采購管理,倉儲管理,倉庫管理,保質期管理,貨位管理,庫位管理,生產管理,WMS管理系統,標簽打印,條形碼,二維碼管理,批號管理軟件。

點晴免費OA是一款軟件和通用服務都免費，不限功能、不限時間、不限用戶的免費OA協同辦公管理系統。