脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → C#教程 → C# websocket双向通信

C#实现websocket双向通信的示例代码

 更新时间：2024年06月26日 11:13:56   作者：靓仔很忙i  
本文基于WebSocketSharp实现了websocket双向通信,除基本的客户端向服务端发送消息外,也支持客户端向指定的客户端发送消息、群发消息,其他协议可自定义,废话不多说,直接上干货,需要的朋友可以参考下

一.服务端

新建一个.net项目，如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();
        }
    }
}

创建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);
            }
        }
    }
}

创建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();

二.客户端

新建一个.net项目，如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);
                }
            }
        }

三.调试

  • 启动分别启动服务端、客户端
  • 客户端控制台输入【常规通讯测试】
{"msgType":0,"content":"hello"}

输入后，回车，服务端返回

在这里插入图片描述

启动apipost，新建websocket,输入以下内容【群发】

ws://127.0.0.1/caseInfo?name=c2
{"msgType":1,"content":"hello456","reciver":"c1"}

在这里插入图片描述

点击连接：

在这里插入图片描述

点击发送：

在这里插入图片描述

在这里插入图片描述

4. 指定人发送

将apipost中发送的消息变为下面内容，重新观察apipost和自定义客户端

{"msgType":2,"content":"hello c1","reciver":"c1"}

以上就是C#实现websocket双向通信的示例代码的详细内容，更多关于C# websocket双向通信的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

  • C# 装箱和拆箱的知识回顾

    C# 装箱和拆箱的知识回顾

    本篇文章主要介绍了C#的装箱和拆箱的知识点回顾，对大家的学习和复习具有很好的参考价值，需要的朋友一起来看下吧
    2016-12-12
  • C#实现读取和设置文件与文件夹的权限

    C#实现读取和设置文件与文件夹的权限

    这篇文章主要为大家详细介绍了如何使用C#实现读取和设置文件与文件夹的权限,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下
    2024-03-03
  • Unity实现VR中在黑板上写字效果

    Unity实现VR中在黑板上写字效果

    这篇文章主要为大家详细介绍了Unity实现VR中在黑板上写字效果，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2019-07-07
  • 基于WPF实现Message消息提醒控件

    基于WPF实现Message消息提醒控件

    这篇文章主要介绍了如何利用WPF实现Meesage消息提醒控件，文中的示例代码讲解详细，对我们学习或工作有一定帮助，需要的可以参考一下
    2023-07-07
  • c#实现md5加密示例

    c#实现md5加密示例

    这篇文章主要介绍了md5加密,加密结果可以为32位、48位、64位，只要修改一下参数就可以实现
    2014-01-01
  • C#超市收银系统设计

    C#超市收银系统设计

    这篇文章主要为大家详细介绍了C#超市收银系统设计，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2017-06-06
  • Unity Shader实现翻书效果

    Unity Shader实现翻书效果

    这篇文章主要为大家详细介绍了Unity Shader实现翻书效果，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2019-11-11
  • C#写入XML文档

    C#写入XML文档

    这篇文章介绍了C#写入XML文档的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2022-04-04
  • C#简单快速的json组件fastJSON使用介绍

    C#简单快速的json组件fastJSON使用介绍

    JSON数据格式简洁，用于数据的持久化和对象传输很实用。最近在做一个Razor代码生成器，需要把数据库的表和列的信息修改后保存下来，想到用JSON序列化对象并保存，需要时再反序列化成对象会简单一些
    2012-11-11
  • C#实现判断图形文件格式的方法

    C#实现判断图形文件格式的方法

    这篇文章主要介绍了C#实现判断图形文件格式的方法,包括常见的扩展名判定及文件内容判定等,非常实用,需要的朋友可以参考下
    2014-09-09

最新评论