编程技术是改变世界的力量。
本站
当前位置:网站首页 > 后端语言 > 正文

c#上位机Socket通讯Server封装

gowuye 2024-05-16 14:57 4 浏览 0 评论

这篇主要介绍一下上位机常见通信(socket)项目中使用的封装,经过大量长时间的运行,稳定可靠!!主要封装了两个类,ServerClass 和ServerControl(可以扩展封装为组合控件使用):

ServerClass类

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Net;
using System.ComponentModel;
namespace ServerLib
{
    public delegate void ReceiveData(string ip, string str);
    public delegate void DisConnect(string ip);
    [Serializable]
    public class ServerClass
    {
        public event ReceiveData eventReceive;
        public event DisConnect  eventDisconnect;
        public event DisConnect eventConnect;
        private TcpListener listen;
        private List<TcpClient> list_socket = new List<TcpClient>();
        private BackgroundWorker bw = new BackgroundWorker();
        private bool bStop = false;
        private Byte[] str = new Byte[1024000];
        public ServerClass()
        {
            bw.DoWork += bw_DoWork;
        }

        void bw_DoWork(object sender, DoWorkEventArgs e)
        {
            while (!bStop)
            {
                try
                {
                    if (listen.Pending())
                    {
                        TcpClient temptcpclient = listen.AcceptTcpClient();
                        list_socket.Add(temptcpclient);
                        if (eventConnect != null)
                        {
                            eventConnect(((IPEndPoint)temptcpclient.Client.RemoteEndPoint).Address.ToString());
                        }
                        Array.Clear(str, 0, str.Length);
                        temptcpclient.GetStream().BeginRead(str, 0, str.Length, new AsyncCallback(GetData), temptcpclient);
                    }
                }
                catch
                {

                }
                System.Threading.Thread.Sleep(10);
            }
        }
        private void GetData(IAsyncResult result)
        {
            TcpClient tempclient = null;
            try
            {
                tempclient = (TcpClient)result.AsyncState;

                int lenth = tempclient.GetStream().EndRead(result);
                if (lenth == 0)
                {
                    list_socket.Remove(tempclient);
                    if (eventDisconnect != null)
                    {                       
                        eventDisconnect(((IPEndPoint)tempclient.Client.RemoteEndPoint).Address.ToString());
                        tempclient.Close();
                        list_socket.Remove(tempclient);
                       
                    }
                    return;
                }
                else
                {
                    if (eventReceive != null)
                    {
                        eventReceive(((IPEndPoint)tempclient.Client.RemoteEndPoint).Address.ToString(), Encoding.Default.GetString(str));
                        Array.Clear(str, 0, str.Length);
                        tempclient.GetStream().BeginRead(str, 0, str.Length, new AsyncCallback(GetData), tempclient);
                    }
                }
            }
            catch
            {
                if (eventReceive != null)
                {
                    if (!bStop)
                    {
                        eventDisconnect(((IPEndPoint)tempclient.Client.RemoteEndPoint).Address.ToString());
                        tempclient.Close();
                        list_socket.Remove(tempclient);
                    }
                }
            }
        }
        public bool OpenServer(string ip, int port)
        {
            try
            {
                listen = new TcpListener(IPAddress.Parse(ip), port);
                listen.Start();
                list_socket.Clear();
                bStop = false;
                bw.RunWorkerAsync();
                return true;
            }
            catch(Exception ex)
            {
                System.Windows.Forms.MessageBox.Show(ex.Message);
                return false;
            }
        }
        public void CloseServer()
        {
            if (listen != null)
            {
                bStop = true;
                listen.Stop();
                listen = null;
                for (int i = 0; i < list_socket.Count; i++)
                {
                    list_socket[i].Close();
                }
                list_socket.Clear();
            }
          
        }
        public void SendData(string sendstr)
        {
            for (int i = 0; i < list_socket.Count; i++)
            {
                list_socket[i].GetStream().Write(Encoding.Default.GetBytes(sendstr), 0, Encoding.Default.GetBytes(sendstr).Length);
            }
        }
    }
}

ServerControl类(可以封装成控件使用)

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Drawing;
using System.Data;
using System.Linq;
using System.Text;
using System.Windows.Forms;

namespace CommClass
{
    [Serializable]
    public  class ServerControl 
    {
 
        private ServerLib.ServerClass server = new ServerLib.ServerClass();

        
        public delegate void  ConnectHandle(string ip);
        public delegate void DeConnectHanle(string ip);
        public delegate void GetDataHandle(string ip,string receivedata);

        [Browsable(true)]
        [Description("有客户端连接时触发事件"), Category("自定义事件")]
        public event ConnectHandle ConnectEvent;
        [Browsable(true)]
        [Description("客户端断线时触发事件"), Category("自定义事件")]
        public event DeConnectHanle DeConnectEvent;
        [Browsable(true)]
        [Description("接收到客户端消息触发事件"), Category("自定义事件")]
        public event GetDataHandle ReceiveEvent;

        [Browsable(true)]
        [Description("设置服务器IP地址"), Category("自定义属性")]
        public string IP
        {
            get;
            set;
        }

        [Browsable(true)]
        [Description("设置服务器端口号"), Category("自定义属性")]
        public string PORT
        {
            get;
            set;
        }

        /// <summary>
        /// 接收到的数据
        /// </summary>
        public string ReceiveStr { private set; get;}

        /// <summary>
        /// 服务器状态,是打开,还是关闭
        /// </summary>
        public bool ServerStatus { private set; get; }
     
        public ServerControl()
        {
            server.eventConnect += new ServerLib.DisConnect(server_eventConnect);
            server.eventDisconnect += new ServerLib.DisConnect(server_eventDisconnect);
            server.eventReceive += new ServerLib.ReceiveData(server_eventReceive);
        }
        public bool OpenServer()
        {
            try
            {
                if (server.OpenServer(IP, Convert.ToInt32(PORT)))
                {
                    ServerStatus = true;
                    return true;
                }
                else
                {
                    return false;
                }             
            }
            catch (Exception ex)
            {
                ServerStatus = false;
                MessageBox.Show(ex.Message);          
                return false;
            }
        }

        void server_eventReceive(string ip, string str)
        {
            if(ReceiveEvent!=null)
            {
                ReceiveEvent(ip,str);
            }
        }
   
        void server_eventDisconnect(string ip)
        {
           if(DeConnectEvent!=null)
           {
               DeConnectEvent(ip);
           }
        }

        void server_eventConnect(string ip)
        {
            if(ConnectEvent!=null)
            {
                ConnectEvent(ip);
            }
        }

        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="str">要发送的数据</param>
        /// <returns>是否发送成功 true:成功 false:失败</returns>
        public bool SendData(string str)
        {
            try
            {
                server.SendData(str);
                return true;
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
                return false;
            }
        }

        /// <summary>
        /// 关闭服务器
        /// </summary>
        /// <returns></returns>
        public bool CloseServer()
        {
            try
            {
                server.CloseServer();
                ServerStatus = false;
                return true;
            }
            catch (Exception ex)
            {
                ServerStatus = false;
                MessageBox.Show(ex.Message);               
                return false;
            }
        }
    }
}

上面两个功能封装成的Server底层

在程序中使用

1.导入命名空间

using CommClass;
using System.IO.Ports;
using System.Threading;
using System.Net.Sockets;
using System.Net;

2.建立对象

    /// <summary>
        /// 本地服务器
        /// </summary>
        public static ServerControl ServerOfLoacl = new ServerControl();

3.初始化参数绑定接受数据事件和服务器断开事件

       
            ServerOfLoacl.ConnectEvent += new CommClass.ServerControl.ConnectHandle(ClientIsConnect);
            ServerOfLoacl.DeConnectEvent += new CommClass.ServerControl.DeConnectHanle(ClientDisConnect);
            ServerOfLoacl.ReceiveEvent += new CommClass.ServerControl.GetDataHandle(RecFromClient);
            ServerOfLoacl.IP = GlobClass.ServerLocationIP.PValue;//与前面文章讲到的单控件参数绑定一起使用更方便
            ServerOfLoacl.PORT = GlobClass.ServerLocationPort.PValue;//与前面文章讲到的单控件参数绑定一起使用更方便
到的单控件参数绑定一起使用更方便

4.事件触发接收函数

 /// 判断是否有客户端连接进来
        /// </summary>
        /// <param name="IP"></param>
        public static void ClientIsConnect(string IP)
        {
            if (IP == "192.168.1.2")
            {
             //刷新连接状态
            }
        }
        /// <summary>
        /// 判断客户端是否断开连接
        /// </summary>
        /// <param name="IP"></param>
        public static void ClientDisConnect(string IP)
        {
            if (IP =="192.168.1.2")
            {
              //可以做一些扩展...................../(刷新连接状态)
            }
        }
        /// <summary>
        /// 接收客户端发送过来的数据
        /// </summary>
        /// <param name="IP"></param>
        /// <param name="info"></param>
        public static void RecFromClient(string IP, string info)
      {
            if (IP == "192.168.1.2")//可以对指定数据进行分析
            {
                char[] trim = new char[2] { '\r', '\n' };
                int index = info.IndexOf("\0");
                if (index > 0)
                    info = info.Substring(0, index).Trim(trim);
                else
                    info = info.Trim(trim);

5.开启服务器

if (!ServerOfLoacl.ServerStatus)
{
     ServerOfLoacl.OpenServer();
 }


希望与大家多交流交流......

相关推荐

Nginx 响应提速10倍,你需要知道的缓存性能优化——FastCGI调优
Nginx 响应提速10倍,你需要知道的缓存性能优化——FastCGI调优

Nginx缓存优化是帮助大家提升网站性能的重要操作之一,proxy_cache主要用于反向代理时,对后端内容源服务器进行缓存;fastcgi_cache主要用于...

2024-05-20 14:44 gowuye

王者荣耀天魔缭乱和逐梦之音返场活动地址 3月22日开启返场活动
王者荣耀天魔缭乱和逐梦之音返场活动地址 3月22日开启返场活动

王者荣耀官方终于确定了天魔缭乱和逐梦之音的返场活动,这让不少小伙伴乐开了花,返场活动将会在3月22日开启,下面就带来王者荣耀天魔缭乱和逐梦之音返场活动地址!王者...

2024-05-20 14:44 gowuye

常见的嵌入式web服务器有哪些?

嵌入式WEB服务器常见的有:Lighttpd,Shttpd,Thttpd,Boa,Mini_httpd,Appweb,Goahead。Lighttpd地址:http://www.light...

简述几款常见的嵌入式web服务器
简述几款常见的嵌入式web服务器

嵌入式web服务器,是web服务器当中的一种,是基于嵌入式系统而实现的web服务器。指的是在嵌入式系统(通俗点就是单片机系统)上实现的一个web服务器,可以通过...

2024-05-20 14:44 gowuye

教你如何利用fastcgi_cache缓存加速WordPress

在使用nginx缓存之前,必须在nginx里面加载专门的模块,这个模块叫做ngx_cache_purge。添加ngx_cache_purge模块下载ngx_cache_purge模块ngx_cache...

扫描WordPress漏洞

检测已知漏洞WPScan是一款广泛使用的WordPress安全扫描工具,它的一项重要功能是检测已知漏洞。在这篇文章中,我们将深入探讨WPScan如何检测已知漏洞,并结合实际示例,帮助读者更好地理解和应...

消灭 Bug!推荐几个给力的开源 Bug 跟踪工具
消灭 Bug!推荐几个给力的开源 Bug 跟踪工具

在这个充满bug的世界里,最遥远的距离不是生与死,而是你亲手制造的bug就在你眼前,你却怎么都找不到它。因此本文准备了7款优秀的开源bug跟踪系...

2024-05-20 14:43 gowuye

生物信息分析入门全攻略

生物信息学是生命科学研究的重大前沿领域,未来将占据生命科学研究的半壁江山。已经有越来越多的小伙伴投入到生物信息的学习中,但是入门难、深入慢、摸不到方向等都成为持续学习的拦路虎。本文根据生物信息技术大牛...

elkb实践经验,再赠送一套复杂的配置文件
elkb实践经验,再赠送一套复杂的配置文件

原创:小姐姐味道(微信公众号ID:xjjdog),欢迎分享,转载请保留出处。宝剑锋从磨砺出,梅花香自苦寒来。诗人白居易,三月下江南,看到沿路开放的桃花,心潮澎湃...

2024-05-20 14:43 gowuye

超详细从0到1 搭建ELK监控
超详细从0到1 搭建ELK监控

监控分类?Metrics用于记录可聚合的数据。例如,1、队列的当前深度可被定义为一个度量值,在元素入队或出队时被更新;HTTP请求个数可被定义为一个计数器,...

2024-05-20 14:42 gowuye

嵌入式开发 之Web配置页面开发
嵌入式开发 之Web配置页面开发

1.PHP是最好的语言??开发动态页面首选的语言是PHP,村村不能在这里忽悠人,如果你的硬件性能允许切略懂PHP,看到这里就可以退出了。本文面向的受众是Linu...

2024-05-20 14:42 gowuye

Python开发一个网站目录扫描工具用来检测网站是否有漏洞?
Python开发一个网站目录扫描工具用来检测网站是否有漏洞?

开发一个网站目录扫描工具是用来检测网站是否有非法目录请求的一个常见需求之一,我们要通过这个扫描工具来找到通过某个域名可以访问到的网站路径,可能对于有些系统来讲,...

2024-05-20 14:42 gowuye

创建一个类似Youtube的Id——使用PHP/Python/JS/Java/SQL

id通常都是用数字,不巧的是只有10个数字来使用,所以如果你有很多的记录,id往往变得非常冗长。当然对于计算机来说无所谓,但我们更希望id尽可能短。所以我们如何能使id变短?我们可以利用字母让它们附加...

快速云:有助于移动应用安全开发的五条妙计
快速云:有助于移动应用安全开发的五条妙计

许多企业不断地向其开发团队提供培训。但是某些漏洞,如早在十多年前就发现的SQL注入,如今仍广泛存在于各种应用中。因而,安全培训永不过时。在开发移动应用时,开发者...

2024-05-20 14:41 gowuye

洛杉矶国际电影节最佳动画短片奖影片《G’DAY》正式全网上映
洛杉矶国际电影节最佳动画短片奖影片《G’DAY》正式全网上映

7月2日,由M&CSaatchi创作,由深受好评的澳大利亚导演迈克尔·格雷西执导的动画短片《G’day》,正式在全网上映。该影片因其出色的创意赢得了洛...

2024-05-20 14:41 gowuye

取消回复欢迎 发表评论: