IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 网络协议 -> c# websocket 服务端 -> 正文阅读

[网络协议]c# websocket 服务端

using Fleck;
using Mono.Web;
using System;
using System.Collections.Generic;
using System.Windows.Forms;

namespace demoforQQ.WebSocket
{
    public partial class WebSocketForm : Form
    {
        public WebSocketForm()
        {
            InitializeComponent();
            this.WindowState = FormWindowState.Minimized;
            this.ShowInTaskbar = false;
        }

        private void WebSocketForm_Load(object sender, EventArgs e)
        {
            runSocket();
        }

        static void runSocket()
        {
            //FleckLog.Level = LogLevel.Debug;
            //var allSockets = new List<IWebSocketConnection>();
            Dictionary<string, dynamic> dicSocketServer = new Dictionary<string, dynamic>();
            Dictionary<string, dynamic> dicSocketCustomer = new Dictionary<string, dynamic>();
            string userIp = "";
            var server = new WebSocketServer("ws://0.0.0.0:1818");
            server.Start(socket =>
            {
                userIp = socket.ConnectionInfo.ClientIpAddress.ToString();

                var ClientIp = socket.ConnectionInfo.ClientIpAddress;
                var Path = socket.ConnectionInfo.Path;
                var url = "http://" + ClientIp + Path;
                Uri myUri = new Uri(url);

                string role = HttpUtility.ParseQueryString(myUri.Query).Get("role");
                var ClientPort = socket.ConnectionInfo.ClientPort;
                var key = role + ClientPort;
              
                socket.OnOpen = () =>
                {
                    Console.WriteLine(key + "已上线!");
                    //allSockets.Add(socket);
                    if (role == "customer")
                    {
                        if (!dicSocketCustomer.ContainsKey(key))
                        {
                            dicSocketCustomer.Add(key, socket);
                        }
                    }
                    if (role == "server")
                    {
                        if (!dicSocketServer.ContainsKey(key))
                        {
                            dicSocketServer.Add(key, socket);
                        }
                    }

                };
                socket.OnClose = () =>
                {
                    Console.WriteLine(key + "下线了!");
                    //allSockets.Remove(socket);
                    if (role == "customer")
                    {
                        dicSocketCustomer.Remove(key);
                    }
                    if (role == "server")
                    {
                        dicSocketServer.Remove(key);
                    }

                };
                socket.OnMessage = message =>
                {
                    //Console.WriteLine("消息发送者:" + key);
                    //Console.WriteLine("消息:" + message);
                    /*Console.WriteLine("role:" + role);*/
                    if (role == "server")
                    {
                        //广播给 customer
                        foreach (var perCustomer in dicSocketCustomer)
                        {
                            var sc = perCustomer.Value;
                            sc.Send(message);
                            
                        }
                    }

                    if (role == "customer")
                    {
                        //Console.WriteLine(dicSocketCustomer.Count);
                        //广播给 customer  ,server收不到信息
                        foreach (var perCustomer in dicSocketCustomer)
                        {
                            var sc = perCustomer.Value;
                            sc.Send(message);
                        }
                    }

                };
            });
        }
    }
}

此项目是做收银端和客显端显示,有customer和server身份区分,对应https://blog.csdn.net/weixin_42674576/article/details/121703047?spm=1001.2014.3001.5501,可根据自己需求做调整

  网络协议 最新文章
使用Easyswoole 搭建简单的Websoket服务
常见的数据通信方式有哪些?
Openssl 1024bit RSA算法---公私钥获取和处
HTTPS协议的密钥交换流程
《小白WEB安全入门》03. 漏洞篇
HttpRunner4.x 安装与使用
2021-07-04
手写RPC学习笔记
K8S高可用版本部署
mySQL计算IP地址范围
上一篇文章      下一篇文章      查看所有文章
加:2021-12-15 18:40:09  更:2021-12-15 18:42:40 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/26 11:53:20-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码