.net平台下C#socket通信(上)

莎利亚 等级 843 0 0

.net平台下C#socket通信(上)

.net平台下C#socket通信(上)

完全是基础,新手可以随意看看,大牛可以关闭浏览页了,哈哈。

在开始介绍socket前先补充补充基础知识,在此基础上理解网络通信才会顺理成章,当然有基础的可以跳过去了。都是废话,进入正题。

  TCP/IP:Transmission Control Protocol/Internet Protocol,传输控制协议/因特网互联协议,又名网络通讯协议。简单来说:TCP控制传输数据,负责发现传输的问题,一旦有问题就发出信号,要求重新传输,直到所有数据安全正确地传输到目的地,而IP是负责给因特网中的每一台电脑定义一个地址,以便传输。从协议分层模型方面来讲:TCP/IP由:网络接口层(链路层)、网络层、传输层、应用层。它和OSI的七层结构以及对于协议族不同,下图简单表示:

.net平台下C#socket通信(上).net平台下C#socket通信(上).net平台下C#socket通信(上)

注:上图左图:TCP/IP的四层结构对应OSI七层结构。

中间的图示:TCP/IP协议族在OSI七层中的位置及对应的功能。

上图右图:TCP/IP协议模块关系图。

现阶段socket通信使用TCP、UDP协议,相对应UDP来说,TCP则是比较安全稳定的协议了。本文只涉及到TCP协议来说socket通信。首先讲述TCP/IP的三次握手,在握手基础上延伸socket通信的基本过程。

下面介绍对于应届生毕业面试来说是非常熟悉的,同时也是最臭名昭著的三次握手:

1 客户端发送syn报文到服务器端,并置发送序号为x。

2 服务器端接收到客户端发送的请求报文,然后向客户端发送syn报文,并且发送确认序号x+1,并置发送序号为y。

3 客户端受到服务器发送确认报文后,发送确认信号y+1,并置发送序号为z。至此客户端和服务器端建立连接。

.net平台下C#socket通信(上)

在此基础上,socket连接过程:

服务器监听:服务器端socket并不定位具体的客户端socket,而是处于等待监听状态,实时监控网络状态。

客户端请求:客户端clientSocket发送连接请求,目标是服务器的serverSocket。为此,clientSocket必须知道serverSocket的地址和端口号,进行扫描发出连接请求。

连接确认:当服务器socket监听到或者是受到客户端socket的连接请求时,服务器就响应客户端的请求,建议一个新的socket,把服务器socket发送给客户端,一旦客户端确认连接,则连接建立。

注:在连接确认阶段:服务器socket即使在和一个客户端socket建立连接后,还在处于监听状态,仍然可以接收到其他客户端的连接请求,这也是一对多产生的原因。

下图简单说明连接过程:

.net平台下C#socket通信(上)

socket连接原理知道了,此处编写最基本最简单的socket通信:

服务器端:

int port = 6000; string host = "127.0.0.1";

            IPAddress ip \= IPAddress.Parse(host);
            IPEndPoint ipe \= new IPEndPoint(ip, port);

            Socket sSocket \= new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            sSocket.Bind(ipe);
            sSocket.Listen(0);
            Console.WriteLine("监听已经打开,请等待"); //receive message
            Socket serverSocket = sSocket.Accept();
            Console.WriteLine("连接已经建立"); string recStr = ""; byte\[\] recByte = new byte\[4096\]; int bytes = serverSocket.Receive(recByte, recByte.Length, 0);
            recStr += Encoding.ASCII.GetString(recByte, 0, bytes); //send message
            Console.WriteLine("服务器端获得信息:{0}", recStr); string sendStr = "send to client :hello"; byte\[\] sendByte = Encoding.ASCII.GetBytes(sendStr);
            serverSocket.Send(sendByte, sendByte.Length, 0);
            serverSocket.Close();
            sSocket.Close();

客户端:

int port = 6000; string host = "127.0.0.1";//服务器端ip地址
 IPAddress ip \= IPAddress.Parse(host);
            IPEndPoint ipe \= new IPEndPoint(ip, port);

            Socket clientSocket \= new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            clientSocket.Connect(ipe); //send message
            string sendStr = "send to server : hello,ni hao"; byte\[\] sendBytes = Encoding.ASCII.GetBytes(sendStr);
            clientSocket.Send(sendBytes); //receive message
            string recStr = ""; byte\[\] recBytes = new byte\[4096\]; int bytes = clientSocket.Receive(recBytes, recBytes.Length, 0);
            recStr += Encoding.ASCII.GetString(recBytes, 0, bytes);
            Console.WriteLine(recStr);

            clientSocket.Close();

  上述服务器端和客户端建立通信,在互相发送一次信息后通信便结束,而在大家进行的项目中,这样的通信肯定满足不了需求。于是接着介绍异步通信,简单来说就是服务器端和客户端可以进行多次互发信息的通信而不用担心通道会关闭。在介绍异步通信时,客户端和服务器端的连接和上面介绍的同步通信建立连接的方式是一样的,这里只写出服务器端和客户端发送信息的方法和接收信息的方法。(服务器端和客户端的发送、接收的方法是一样的)

首先写出异步连接的方法吧:

public void Connect(IPAddress ip, int port)
        { this.clientSocket.BeginConnect(ip, port, new AsyncCallback(ConnectCallback), this.clientSocket);
        } private void ConnectCallback(IAsyncResult ar)
        { try {
                Socket handler \= (Socket)ar.AsyncState;
                handler.EndConnect(ar);
            } catch (SocketException ex)
            { }
        }

发送信息方法:

public void Send(string data)
        {
            Send(System.Text.Encoding.UTF8.GetBytes(data));
        } private void Send(byte\[\] byteData)
        { try { int length = byteData.Length; byte\[\] head = BitConverter.GetBytes(length); byte\[\] data = new byte\[head.Length + byteData.Length\];
                Array.Copy(head, data, head.Length);
                Array.Copy(byteData, 0, data, head.Length, byteData.Length); this.clientSocket.BeginSend(data, 0, data.Length, 0, new AsyncCallback(SendCallback), this.clientSocket);
            } catch (SocketException ex)
            { }
        } private void SendCallback(IAsyncResult ar)
        { try {
                Socket handler \= (Socket)ar.AsyncState;
                handler.EndSend(ar);
            } catch (SocketException ex)
            { }
        }

接收信息的方法:

public void ReceiveData()
        {
            clientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallback), null);
        } private void ReceiveCallback(IAsyncResult ar)
        { try { int REnd = clientSocket.EndReceive(ar); if (REnd > 0)
                { byte\[\] data = new byte\[REnd\];
                    Array.Copy(MsgBuffer, 0, data, 0, REnd); //在此次可以对data进行按需处理
 clientSocket.BeginReceive(MsgBuffer, 0, MsgBuffer.Length, 0, new AsyncCallback(ReceiveCallback), null);
                } else {
                    dispose();
                }
            } catch (SocketException ex)
            { }
        } private void dispose()
        { try { this.clientSocket.Shutdown(SocketShutdown.Both); this.clientSocket.Close();
            } catch (Exception ex)
            { }
        }

  异步问题解决了,再写一个自己在使用过程中经常出现的一个问题。接收的数据包处理问题:在网络通信中,使用异步进行通信,那么客户端在接收服务器发送来的数据包的处理上会有一些麻烦,比如粘包、断包,这是一些小问题,此处简单写写自己处理此问题的一个方法。
粘包处理:

public Hashtable DataTable = new Hashtable();//因为要接收到多个服务器(ip)发送的数据,此处按照ip地址分开存储发送数据

        public void DataArrial(byte\[\] Data , string ip)
        { try { if (Data.Length < 12)//按照需求进行判断
 { lock (DataTable)
                    { if (DataTable.Contains(ip))
                        {
                            DataTable\[ip\] \= Data; return;
                        }
                    }
                } if (Data\[0\] != 0x1F || Data\[1\] != 0xF1)//标志位(按照需求编写)
 { if (DataTable.Contains(ip))
                    { if (DataTable != null)
                        { byte\[\] oldData = (byte\[\])DataTable\[ip\];//取出粘包数据
                            if (oldData\[0\] != 0x1F || oldData\[1\] != 0xF1)
                            { return;
                            } byte\[\] newData = new byte\[Data.Length + oldData.Length\];
                            Array.Copy(oldData, 0, newData, 0, oldData.Length);
                            Array.Copy(Data, 0, newData, oldData.Length, Data.Length);//组成新数据数组,先到的数据排在前面,后到的数据放在后面

                            lock (DataTable)
                            {
                                DataTable\[ip\] \= null;
                            }
                            DataArrial(newData, ip); return;
                        }
                    } return;
                } int revDataLength = Data\[2\];//打算发送数据的长度
                int revCount = Data.Length;//接收的数据长度
                if (revCount > revDataLength)//如果接收的数据长度大于发送的数据长度,说明存在多帧数据,继续处理
 { byte\[\] otherData = new byte\[revCount - revDataLength\];
                    Data.CopyTo(otherData, revCount \- 1);
                    Array.Copy(Data, revDataLength, otherData, 0, otherData.Length);
                    Data \= (byte\[\])Redim(Data, revDataLength);
                    DataArrial(otherData, ip);
                } if (revCount < revDataLength) //接收到的数据小于要发送的长度
 { if (DataTable.Contains(ip))
                    {
                        DataTable\[ip\] \= Data;//更新当前粘包数据
                        return;
                    }
                } //此处可以按需进行数据处理
 } catch (Exception ex)
            { }
        } private Array Redim(Array origArray, Int32 desizedSize)
        { //确认每个元素的类型
            Type t = origArray.GetType().GetElementType(); //创建一个含有期望元素个数的新数组 //新数组的类型必须匹配数组的类型
            Array newArray = Array.CreateInstance(t, desizedSize); //将原数组中的元素拷贝到新数组中。
            Array.Copy(origArray, 0, newArray, 0, Math.Min(origArray.Length, desizedSize)); //返回新数组
            return newArray;
        }

socket最基本的内容终于写完了,结合上面的信息进行简单的应用应该是没有问题,可是如果牵涉到比较服务的通信问题,其解决的方法就需要委托、多线程、接口方面的知识了,这方面最近正在学习,最近有一个感悟:委托是.net下C#中最基本最重要的部分了吧,应该必须学会。

吐槽:一个委托不可怕,可怕的是多个委托,并且委托中套用委托才是最可怕的。

哎,慢慢学习吧。也许下文在一个星期后,或者一个月后会写出来吧,也许更久吧

.net平台下C#socket通信(中)在一个小项目的进行过程中被书写出来了,欢迎指出其中不足之处,谢谢。

收藏
评论区

相关推荐

.net平台下C#socket通信(上)
.net平台下Csocket通信(上) .net平台下Csocket通信(上) 完全是基础,新手可以随意看看,大牛可以关闭浏览页了,哈哈。 在开始介绍socket前先补充补充基础知识,在此基础上理解网络
.NET IDE Rider公布2020.2路线图
跨平台 .NET IDE Rider 近日公布了 2020.2 的路线图,介绍了目前正在开发的一些特性,并表示其中一些可能在接下来的版本中出现。主要包括: * Windows 上的 .NET Core 后端:Rider 2020.1 已在 macOS 和 Linux 上的 .NET Core 上运行 ReSharper 后端。Windows 方面,后端
.net core 面试题
第1题,什么是ASP net core? 首先ASP net core不是 asp net的升级版本。它遵循了dot net的标准架构, 可以运行于多个操作系统上。它更快,更容易配置,更加模块化,可扩展性更强。 第2题,asp dot core有哪些好的功能? 第一是依赖注入。 第二是日志系统架构。 第三是引入了一个跨平台的网络服务器,kestre
1.C#简介
/* .NET Framework的含义 .NET Framework是Microsoft为开发应用程序而创建的一个具有革命意义的平台 尽管.NET Framework的Microsoft版本运行在Windows系统上,但以后将推出运行在其他操作系统上的版本 例如mono,他是.NET Framework的开源
C#与.NET
C#从本质上来说,它是一门编程语言。他不是.NET体系的一部分。虽然C#总是用来生成.NET平台的代码。C#语言不能孤立的使用,必须与.NET平台一起使用。这样才能大大提高开发效率。 相对于C++,Java等语言,C#是一种比较新的语言。它是在吸收了C++和Java语言在设计上的优点设计出来的。从一开始C#就被设计为面向对象的开发语言。 .NET Fra
Java基础之UDP协议和TCP协议简介及简单案例的实现
写在前面的废话:马上要找工作了,做了一年的.net ,到要找工作了发现没几个大公司招聘.net工程师,真是坑爹呀。哎,java就java吧,咱从头开始学呗,啥也不说了,玩命撸吧,我真可怜啊。 摘要: --- 本片记载刚刚学习的网络编程的内容,网络编程也称 Socket 编程 、套接字编程。 什么是Socket? ---------- 用于描述ip地址
udp之关于linux udp收发包缓冲区大小
1、修订单个socket的缓冲区大小:通过setsockopt使用SO\_RCVBUF来设置接收缓冲区,该参数在设置的时候不会与rmem\_max进行对比校验,但是如果设置的大小超过rmem\_max的话,则超过rmem\_max的部分不会生效; 2、修订linux系统udp缓冲区大小:通过rmem\_max来设置系统中udp缓存的上限,该值可通过如下方
unity+json
各种粘贴,原作者见谅,开源有码万岁 LitJSON是一个.NET平台下处理 [JSON格式数据](https://www.oschina.net/action/GoToLink?url=http%3A%2F%2Fwww.87cool.com%2Farticle-239.aspx)的类库,小巧、快速。它的源代码使用C#编写,可以通过任何.Net平台上
linux
一.linux内核网络栈代码的准备知识 1. linux内核ipv4网络部分分层结构: BSD socket层: 这一部分处理BSD socket相关操作,每个socket在内核中以struct socket结构体现。这一部分的文件 主要有:/net/socket.c /net/protocols.c etc INET socket层:BSD so
C# .NET Socket 简单实用框架
背景: 首先向各位前辈,大哥哥小姐姐问一声好~ 这是我第一次写博客,目前为一个即将步入大四的学生,上学期在一家公司实习了半年,后期发现没有动力,而且由于薪水问题(废话嘛),于是跳槽到这家新的公司。 说到Socket,想必大家都或多或少有所涉及,从最初的计算机网络课程,讲述了tcp协议,而Socket就是对协议的进一步封装,使我们开发人员能够更加容易轻松
Dex
说明文档: https://berkeleyautomation.github.io/dex-net/code.html \=======================Dex-Net========================== Dex-Net 2.0 是一个HDF5文件数据集,包含了1500个物体到模型,平行夹具抓取点,
Socket
根据之前的经验,应用软件的网络通信无非就是Socket和HTTP,其中Socket又可以用TCP和UDP,HTTP的话就衍生出很多方式,基础的HTTP GET和POST请求,然后就是WebService的SOAP。 在这些方式中,Socket当然是最基础的。因此先从Socket开始。 服务端就不需要过多的说明了,无论采用什么语言什么平台都可以,只要遵循基
Swifter.Json 可能是 .Net 平台迄今为止性能最佳的 Json 序列化库【开源】
**Json 简介** Json (JavaScript Object Notation) 是一种轻量级的数据交换格式。它作为目前最欢迎的数据交换格式,也是各大开源贡献者的必争之地,如:阿里爸爸的 fastjson(java),腾讯的 rapidjson(c++) 等。但 .Net 却没有得到大厂的青睐,在 Swifter.Json 之前 .Net 的 J
TCP&UDP&Socket讲解(上)
这两天我将整理TCP&UDP&Socket,大约花大家10-15分钟之间,希望本篇文章让大家对TCP使用的理解提高一个层次。  建议大家拿出纸和笔,画一下!!! **一、TCP** 1\. TCP位于传输层,英语全称为Transmission Control Protocol ,又名传输控制协议;UDP英语全称为User Datagram Protoc
supersocket client 的简单使用方法
由于需要在服务端和客户端持续通信,于是在网上找了好久的socket通信工具。刚开始想直接用.net自带的socket通信,后来担心不够稳定健壮,毕竟自己不专业。找来找去觉得supersocket还可以,但是说实话,他们的帮助文档写的真是太烂了,使用也不够简单易懂,折腾了一阵大致明白如何使用。 1,在nuget上引用supersocket.clienteng