C#實(shí)現(xiàn)websocket雙向通信的示例代碼
更新時(shí)間：2024年06月26日 11:13:56 作者：靚仔很忙i
本文基于WebSocketSharp實(shí)現(xiàn)了websocket雙向通信,除基本的客戶端向服務(wù)端發(fā)送消息外,也支持客戶端向指定的客戶端發(fā)送消息、群發(fā)消息,其他協(xié)議可自定義,廢話不多說(shuō),直接上干貨,需要的朋友可以參考下
一.服務(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í)現(xiàn)在服務(wù)器端裁剪圖片的方法
這篇文章主要介紹了C#實(shí)現(xiàn)在服務(wù)器端裁剪圖片的方法,涉及C#操作圖片的相關(guān)技巧,需要的朋友可以參考下2015-04-04
WPF實(shí)現(xiàn)在控件上顯示Loading等待動(dòng)畫(huà)的方法詳解
這篇文章主要介紹了WPF 如何在控件上顯示 Loading 等待動(dòng)畫(huà)，文中的示例代碼講解詳細(xì)，對(duì)我們學(xué)習(xí)或工作有一定幫助，需要的可以參考一下2023-03-03
這篇文章主要為大家詳細(xì)介紹了如何利用C#實(shí)現(xiàn)自定義屏保的功能，文中的示例代碼講解詳細(xì)，對(duì)我們學(xué)習(xí)C#有一定的幫助，感興趣的小伙伴可以跟隨小編一起了解一下2022-12-12
這篇文章主要介紹了C#通過(guò)域名獲得IP地址的方法,涉及C#中GetHostByName方法的使用技巧,需要的朋友可以參考下2015-04-04
C#程序總會(huì)生成bin和obj文件夾，為了減小源碼的大小，就有必要將這兩個(gè)文件夾刪除，于是想到用批處理文件來(lái)刪除2013-07-07
C# 將透明圖片的非透明區(qū)域轉(zhuǎn)換成Region的實(shí)例代碼
以下代碼實(shí)現(xiàn)將一張帶透明度的png圖片的非透明部分轉(zhuǎn)換成Region輸出的方法，有需要的朋友可以參考一下2013-10-10
本文一介紹了數(shù)據(jù)結(jié)構(gòu)的基本概念 而介紹了算法的基本概念，并且重點(diǎn)討論了算法時(shí)間復(fù)雜度，并且用程序予以證明2012-10-10
這篇文章主要為大家詳細(xì)介紹了如何基于C#編寫一個(gè)修改文件時(shí)間屬性的小工具,可以批量修改文件的創(chuàng)建時(shí)間、最后訪問(wèn)時(shí)間和最后修改時(shí)間,需要的可以參考下2024-11-11
C#采用mouse_event函數(shù)實(shí)現(xiàn)模擬鼠標(biāo)功能
這篇文章主要介紹了C#模擬鼠標(biāo)點(diǎn)擊小功能，通過(guò)代碼向大家做分析,需要的朋友可以參考下2015-07-07
基于C#的圖表控件庫(kù) ScottPlot編譯visual studio 2022
基于 C# 的 圖表控件庫(kù) ScottPlot，開(kāi)源免費(fèi)，可以用于開(kāi)發(fā)一些上位機(jī)軟件，如電壓、電流波形的顯示，開(kāi)發(fā)【示波器】圖形界面，可以顯示一些圖表、波形，總之功能比較的強(qiáng)大，本文介紹了基于C#的圖表控件庫(kù) ScottPlot編譯visual studio 2022,需要的朋友可以參考下2022-06-06