C#實(shí)現(xiàn)websocket雙向通信的示例代碼
更新時(shí)間：2024年06月26日 11:13:56 作者：靚仔很忙i
本文基于WebSocketSharp實(shí)現(xiàn)了websocket雙向通信,除基本的客戶端向服務(wù)端發(fā)送消息外,也支持客戶端向指定的客戶端發(fā)送消息、群發(fā)消息,其他協(xié)議可自定義,廢話不多說,直接上干貨,需要的朋友可以參考下
一.服務(wù)端
新建一個(gè).net項(xiàng)目，如websocket.server
安裝包
Install-Package WebSocketSharp -Pre
定義WebSocketHelper
using CaseAuto.helper.websocket;
using System.Collections.Generic;
using WebSocketSharp.Server;
namespace CaseAuto.helper
{
public class WebSocketHelper
{
static WebSocketServer wssv = new WebSocketServer("ws://127.0.0.1");
private static Dictionary<string,CaseInfoBehavior> clients = new Dictionary<string,CaseInfoBehavior>();
public static void Init()
{
wssv.AddWebSocketService<CaseInfoBehavior>("/caseInfo",()=>new CaseInfoBehavior(clients));
wssv.Start();
}
public static void End()
{
wssv.Stop();
}
}
}
創(chuàng)建CaseInfoBehavior
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using WebSocketSharp;
using WebSocketSharp.Server;
namespace CaseAuto.helper.websocket
{
public class CaseInfoBehavior : WebSocketBehavior
{
private string _username;
private Dictionary<string, CaseInfoBehavior> _clients = new Dictionary<string, CaseInfoBehavior>();
public CaseInfoBehavior(Dictionary<string,CaseInfoBehavior> clients)
{
_clients = clients;
}
protected override void OnMessage(MessageEventArgs e)
{
var data=JsonConvert.DeserializeObject<WebSocketMsgModel>(e.Data);
switch (data.msgType){
case MsgType.NORMAL:
var msg = $"This msg from serve,I recive msg:{data.content}";
Send(msg);
break;
case MsgType.GROUP:
SendMessageToAll(data.content);
//Sessions.Broadcast(data.content);
break;
case MsgType.TO_RECIVER:
SendMessageToReciver(data.reciver, data.content);
break;
default:
break;
}
}
protected override void OnOpen()
{
_username = Context.QueryString["name"];
if (string.IsNullOrEmpty(_username))
{
_username = this.ID;
return;
}
_clients.Add(_username, this);
Console.WriteLine("Client connected: " + _username);
}
protected override void OnClose(CloseEventArgs e)
{
_clients.Remove(_username);
Console.WriteLine("Client connected: " + _username);
}
protected void SendMessageToReciver(string reciver,string message)
{
foreach (var client in _clients)
{
if (client.Key == reciver) {
client.Value.Send(message);
break;
}
}
}
protected void SendMessageToAll(string message)
{
foreach (var client in _clients)
{
client.Value.Send(message);
}
}
}
}
創(chuàng)建WebSocketMsgModel
namespace CaseAuto.helper.websocket
{
public class WebSocketMsgModel
{
public MsgType msgType { get; set; }
public string content{ get; set; }
public string sender { get; set; }
public string reciver { get; set; }
}
public enum MsgType {
NORMAL=0,
GROUP=1,
TO_RECIVER = 2,
}
}
使用
WebSocketHelper.Init();
二.客戶端
新建一個(gè).net項(xiàng)目，如websocket.client
安裝包
Install-Package WebSocketSharp -Pre
使用
static void Main(string[] args)
{
using (var ws = new WebSocket("ws://127.0.0.1/caseInfo?name=c1"))
{
string? response = string.Empty;
ws.OnMessage += (sender, e) =>
{
response = e.Data;
Console.WriteLine("Response: " + response);
};
ws.Connect();
while (true)
{
string? request = Console.ReadLine();
ws.Send(request);
Console.ReadKey(true);
}
}
}
三.調(diào)試
- 啟動(dòng)分別啟動(dòng)服務(wù)端、客戶端
- 客戶端控制臺(tái)輸入【常規(guī)通訊測(cè)試】
{"msgType":0,"content":"hello"}
輸入后，回車，服務(wù)端返回
啟動(dòng)apipost，新建websocket,輸入以下內(nèi)容【群發(fā)】
ws://127.0.0.1/caseInfo?name=c2
{"msgType":1,"content":"hello456","reciver":"c1"}
點(diǎn)擊連接：
點(diǎn)擊發(fā)送：
4. 指定人發(fā)送
將apipost中發(fā)送的消息變?yōu)橄旅鎯?nèi)容，重新觀察apipost和自定義客戶端
{"msgType":2,"content":"hello c1","reciver":"c1"}
以上就是C#實(shí)現(xiàn)websocket雙向通信的示例代碼的詳細(xì)內(nèi)容，更多關(guān)于C# websocket雙向通信的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
本篇文章主要介紹了C#的裝箱和拆箱的知識(shí)點(diǎn)回顧，對(duì)大家的學(xué)習(xí)和復(fù)習(xí)具有很好的參考價(jià)值，需要的朋友一起來(lái)看下吧2016-12-12
C#實(shí)現(xiàn)讀取和設(shè)置文件與文件夾的權(quán)限
這篇文章主要為大家詳細(xì)介紹了如何使用C#實(shí)現(xiàn)讀取和設(shè)置文件與文件夾的權(quán)限,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-03-03
這篇文章主要為大家詳細(xì)介紹了Unity實(shí)現(xiàn)VR中在黑板上寫字效果，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2019-07-07
基于WPF實(shí)現(xiàn)Message消息提醒控件
這篇文章主要介紹了如何利用WPF實(shí)現(xiàn)Meesage消息提醒控件，文中的示例代碼講解詳細(xì)，對(duì)我們學(xué)習(xí)或工作有一定幫助，需要的可以參考一下2023-07-07
這篇文章主要介紹了md5加密,加密結(jié)果可以為32位、48位、64位，只要修改一下參數(shù)就可以實(shí)現(xiàn)2014-01-01
這篇文章主要為大家詳細(xì)介紹了C#超市收銀系統(tǒng)設(shè)計(jì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-06-06
這篇文章主要為大家詳細(xì)介紹了Unity Shader實(shí)現(xiàn)翻書效果，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2019-11-11
這篇文章介紹了C#寫入XML文檔的方法，文中通過示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2022-04-04
C#簡(jiǎn)單快速的json組件fastJSON使用介紹
JSON數(shù)據(jù)格式簡(jiǎn)潔，用于數(shù)據(jù)的持久化和對(duì)象傳輸很實(shí)用。最近在做一個(gè)Razor代碼生成器，需要把數(shù)據(jù)庫(kù)的表和列的信息修改后保存下來(lái)，想到用JSON序列化對(duì)象并保存，需要時(shí)再反序列化成對(duì)象會(huì)簡(jiǎn)單一些2012-11-11
這篇文章主要介紹了C#實(shí)現(xiàn)判斷圖形文件格式的方法,包括常見的擴(kuò)展名判定及文件內(nèi)容判定等,非常實(shí)用,需要的朋友可以參考下2014-09-09