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

c#上位机Socket通讯Client封装

gowuye 2024-05-16 14:56 3 浏览 0 评论

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

ClientClass 类

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Sockets;
using System.Text;
using System.Net;
namespace ClientLib
{
    public  delegate void   ClientReceiveData(string ip,string str);
    public  delegate void   ClientDisConnect(string ip);
    [Serializable]
    public class ClientClass
    {
        public event ClientReceiveData eventReceive;
        public event ClientDisConnect eventDisConnect;


        private TcpClient client = null;
        private byte[] str = new byte[10240000];

        public bool ConnectServer(string ip, int port)
        {
            try
            {
                client = new TcpClient();
               IAsyncResult ar =client.BeginConnect(IPAddress.Parse(ip), port,null,null);
              bool ret= ar.AsyncWaitHandle.WaitOne(500);
              if (!ret)
              {
                  return false;
              }
                Array.Clear(str,0,str.Length);
                client.GetStream().BeginRead(str, 0, str.Length, new AsyncCallback(GetData), client);
                return true;
            }
            catch(Exception ex)
            {
                System.Windows.Forms.MessageBox.Show(ex.Message);
                return false;
            }
        }
        private void GetData(IAsyncResult result)
        {
            TcpClient tempclient = null;
            try
            {
                tempclient = (TcpClient)result.AsyncState;              
                int lenth = tempclient.GetStream().EndRead(result);
                if (lenth == 0)
                {                 
                    if (eventDisConnect != null)
                    {
                        eventDisConnect(((IPEndPoint)tempclient.Client.RemoteEndPoint).Address.ToString());
                    }
                    client = null;
                    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 (eventDisConnect != null)
                {
                    if (client!=null)
                    {
                        eventDisConnect(((IPEndPoint)tempclient.Client.RemoteEndPoint).Address.ToString());
                    }                    
                }
                client = null;
            }
        }
        public bool SendData(string str)
        {
            try
            {
                if (client != null)
                {
                    client.GetStream().Write(Encoding.UTF8.GetBytes(str), 0, Encoding.UTF8.GetBytes(str).Length);
                    return true;
                }
                else
                {
                    return false;
                }
            }
            catch
            {
                return false;
            }
        }
        public void Close()
        {
            try
            {
                if (client != null)
                {
                    client.Close();
                    client= null;
                }
            }
            catch {  }
        }
    }
}

ClientControl类(可以扩展为Client控件的封装)

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

namespace CommClass
{
    [Serializable]
    public  class ClientControl 
    {
        private ClientLib.ClientClass client = new ClientLib.ClientClass();


        /// <summary>
        /// 客户端状态 true:连接状态 false:断开状态
        /// </summary>
        public bool ClientStatus { private set; get; }

        /// <summary>
        /// 服务器发送过来的数据
        /// </summary>
        public string ReceiveStr { private set; get; }

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

        [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>
        /// <returns></returns>
        public bool ConnectServer()
        {
            try
            {
                if (client.ConnectServer(IP,Convert.ToInt32( PORT)))
                {

                    ClientStatus = true;
                    return true;
                }
                else
                {
                    ClientStatus = false;
                    return false;
                }
            }
            catch (Exception ex)
            {
                ClientStatus = false;
                MessageBox.Show(ex.Message);
                return false;
            }
        }
    }
        /// <summary>
        /// 断开连接事件
        /// </summary>
        /// <returns></returns>
        void client_eventDisConnect(string ip)   
        {
            if (DeConnectEvent != null)
            {
                DeConnectEvent(ip);
                ClientStatus = false;
            }
        }
         /// <summary>
        /// 接收数据事件
        /// </summary>
        /// <returns></returns>
        void client_eventReceive(string ip, string str)  
        {
            if (ReceiveEvent != null)
            {
                ReceiveEvent(ip, str);
            }
        }
        /// <summary>
        /// 断开与服务器的连接
        /// </summary>
        /// <returns></returns>
        public bool DisConnectServer()
        {
            try
            {
                client.Close();
                ClientStatus = false;
                return true;
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
                ClientStatus = false;
                return false;
            }
        }
        /// <summary>
        /// 发送数据
        /// </summary>
        /// <param name="str">要发送的数据</param>
        /// <returns>是否发送成功 true:成功 false:失败</returns>
        object obj = new object();
        public bool SendData(string str)
        {
            lock (obj)
            {
                try
                {
                    client.SendData(str);
                    return true;
                }
                catch (Exception ex)
                {
                    MessageBox.Show(ex.Message);
                    return false;
                }
            }
        }
        public ClientControl()
        {
            client.eventReceive += new ClientLib.ClientReceiveData(client_eventReceive);
            client.eventDisConnect += new ClientLib.ClientDisConnect(client_eventDisConnect);
        }
    }
}

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

在程序中使用

1.导入命名空间

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

2.建立对象

   public static ClientControl ClientOfLeftCCD = new ClientControl();

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

            ClientOfLeftCCD.ReceiveEvent += new CommClass.ClientControl.GetDataHandle(RecFromLeftCCD);
            ClientOfLeftCCD.DeConnectEvent += new CommClass.ClientControl.DeConnectHanle(DisCntFromCCD);
            ClientOfLeftCCD.IP = GlobClass.m_sLeftCCDIP.PValue;//与前面文章讲到的单控件参数绑定一起使用更方便
            ClientOfLeftCCD.PORT = GlobClass.m_sLeftCCDPort.PValue;//与前面文章讲到的单控件参数绑定一起使用更方

4.事件触发接收函数

  /// <summary>
        /// 接收左CCD返回来的数据
        /// </summary>
        /// <param name="IP"></param>
        /// <param name="info"></param>
        private static void RecFromLeftCCD(string IP, string info)
        {
            if (info != null)
            {
                info = info.Trim('\0');
              ..................................................
            }
        }
        private static void DisCntFromCCD(string IP)
        {
            //断开与CCD的服务器的链接
        }

5.连接服务器

 if (!ClientOfLeftRobot.ClientStatus)
{
    ClientOfLeftRobot.ConnectServer();
}

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

相关推荐

R语言数据挖掘实践——支持向量机的常用函数
R语言数据挖掘实践——支持向量机的常用函数

e1071包是R语言中用于支持向量机建模与分析的软件包,其主要用于支持向量机的模型构建,提供核心函数svm()来建立支持向量机的基础模型,并且可辅助使用pred...

2024-05-18 12:15 gowuye

R数据分析:如何做聚类分析,实操解析
R数据分析:如何做聚类分析,实操解析

Clusteringisabroadsetoftechniquesforfindingsubgroupsofobservationswi...

2024-05-18 12:14 gowuye

用R语言做数据分析——马赛克图
用R语言做数据分析——马赛克图

到目前为止,我们已经学习了许多可视化定量或连续型变量间关系的方法。但如果变量是类别型的呢?若只观察单个类别型变量,可以使用柱状图或者饼图;若存在两个类别型变量,...

2024-05-18 12:14 gowuye

用R语言做数据分析——方差分析基本概论
用R语言做数据分析——方差分析基本概论

在实际工作中,影响一件事的因素是很多的,我们总是希望通过各种试验来观察各种因素对试验结果的影响。例如,不同的生产厂家、不同的原材料、不同的操作规程,以及不同的技...

2024-05-18 12:14 gowuye

R语言数据分析实战:数据清洗与可视化
R语言数据分析实战:数据清洗与可视化

《R语言数据分析实战:数据清洗与可视化》是一本深入浅出的实践指南,专为对数据分析感兴趣的读者精心编撰。本书旨在帮助读者掌握R语言这一强大的统计分析工具,通过实例...

2024-05-18 12:13 gowuye

用R语言做数据分析——双因素方差分析
用R语言做数据分析——双因素方差分析

在双因素方差分析中,受试者被分配到两因子的交叉类别组中。以基础安装中的Tooth-Growth数据集为例,随机分配60只豚鼠,分别采用两种喂食方法(橙汁或维生素...

2024-05-18 12:13 gowuye

用R语言做数据分析——独立两样本和K样本检验
用R语言做数据分析——独立两样本和K样本检验

coin包简介对于独立性问题,coin包提供了一个进行置换检验的一般性框架,通过这个包,我们可以回答如下问题:响应值与组的分配独立吗?两个数值变量独立吗?两个类...

2024-05-18 12:13 gowuye

用R语言做数据分析——用回归做方差分析
用R语言做数据分析——用回归做方差分析

之前提到方差分析和回归都是广义线性模型的特例,之前文章的所有设计都可以用lm()函数来分析。为了更好地理解输出结果,需要弄明白在拟合模型时,R语言是如何处理类别...

2024-05-18 12:13 gowuye

数据分析R语言——数据结构
数据分析R语言——数据结构

数据分析R语言——数据结构数组数组(array)与矩阵类似,但是维度可以大于2.数组通过array()函数创建。形式如;myarray<-array(v...

2024-05-18 12:13 gowuye

R语言数据挖掘实践——关联分析的常用函数
R语言数据挖掘实践——关联分析的常用函数

arules和arulesViz是R语言中两个专用于关联分析的软件包。其中arules用于关联规则的数字化生成,提供Apriori和Eclat这两种快速挖掘频繁...

2024-05-18 12:12 gowuye

R语言数据挖掘实践——判别分析的常用函数
R语言数据挖掘实践——判别分析的常用函数

判别算法在R语言中实现主要涉及4个软件包中的相关函数,它们依次为MASS、klaR、class和kknn。其中MASS包含有大量实用而先进的统计计数函数及适用数...

2024-05-18 12:12 gowuye

用R语言读取Excel、PDF和JSON文件,终于有人讲明白了
用R语言读取Excel、PDF和JSON文件,终于有人讲明白了

导读:本文将讨论Excel、PDF等文件的读取,以及相应函数的参数设置。作者:刘健邬书豪如需转载请联系华章科技下图总结了主要程序包,希望读者在日常练习和工作中...

2024-05-18 12:12 gowuye

R语言数据挖掘实践——聚类分析的常用函数
R语言数据挖掘实践——聚类分析的常用函数

使用R语言可以轻松实现聚类分析,stats、cluster、fpc和mclust是常用的四个聚类分析软件包。stats主要包含一些基本的统计函数,如用于统计计算...

2024-05-18 12:12 gowuye

用R语言做数据分析——时间序列分类
用R语言做数据分析——时间序列分类

时间序列分类是根据已标注的时间序列建立一个分类模型,然后使用分类模型预测未标记时间序列的类别。从时间序列中抽取出新特征肯呢个有助于提高分类模型的性能。特征提取技...

2024-05-18 12:11 gowuye

一文看懂用R语言读取Excel、PDF和JSON文件(附代码)
一文看懂用R语言读取Excel、PDF和JSON文件(附代码)

导读:本文将讨论Excel、PDF等文件的读取,以及相应函数的参数设置。作者:刘健邬书豪如需转载请联系华章科技下图总结了主要程序包,希望读者在日常练习和工作中...

2024-05-18 12:11 gowuye

取消回复欢迎 发表评论: