Go网络编程

腾马發表於 2020-1-6 16:31:00

<div class="toc"><div class="toc-container-header">目录</div><ul><li>概述<ul><li>网络协议</li><li>典型协议</li><li>分层模型<ul><li>网络分层架构</li><li>层与协议</li><li>协议功能<ul><li>链路层</li><li>网络层</li><li>传输层</li><li>应用层</li></ul></li></ul></li><li>通信过程</li></ul></li><li>Socket编程<ul><li>什么是Socket</li><li>网络应用程序设计模式<ul><li>C/S模式</li><li>B/S模式</li><li>优缺点</li></ul></li><li>TCP的C/S架构</li><li>简单的C/S模型通信<ul><li>Server端</li><li>Client端</li></ul></li><li>并发的C/S模型通信<ul><li>并发Server</li><li>并发Client</li></ul></li><li>TCP通信<ul><li>三次握手</li><li>四次挥手</li></ul></li><li>UDP通信<ul><li>UDP服务器</li><li>UDP客户端</li><li>并发</li><li>UDP与TCP的差异</li></ul></li></ul></li></ul></div>
<h2 id="概述">概述</h2>
<h3 id="网络协议">网络协议</h3>
从应用的角度出发，协议可理解为“规则”，是数据传输和数据的解释的规则。假设，A、B双方欲传输文件。规定：
<ul>
<li>第一次，传输文件名，接收方接收到文件名，应答OK给传输方；</li>
<li>第二次，发送文件的尺寸，接收方接收到该数据再次应答一个OK；</li>
<li>第三次，传输文件内容。同样，接收方接收数据完成后应答OK表示文件内容接收成功。</li>
</ul>
由此，无论A、B之间传递何种文件，都是通过三次数据传输来完成。A、B之间形成了一个最简单的数据传输规则。双方都按此规则发送、接收数据。A、B之间达成的这个相互遵守的规则即为协议。
这种仅在A、B之间被遵守的协议称之为原始协议。
当此协议被更多的人采用，不断的增加、改进、维护、完善。最终形成一个稳定的、完整的文件传输协议，被广泛应用于各种文件传输过程中。该协议就成为一个标准协议。最早的ftp协议就是由此衍生而来。
<h3 id="典型协议">典型协议</h3>
<code>应用层</code>: 常见的协议有HTTP协议，FTP协议。
<code>传输层</code>: 常见协议有TCP/UDP协议。
<code>网络层</code>: 常见协议有IP协议、ICMP协议、IGMP协议。
<code>网络接口层</code>: 常见协议有ARP协议、RARP协议。
各个协议用途简述:
IP协议是因特网互联协议（Internet Protocol）
TCP传输控制协议（Transmission Control Protocol）是一种面向连接的、可靠的、基于字节流的传输层通信协议。
UDP用户数据报协议（User Datagram Protocol）是OSI参考模型中一种无连接的传输层协议，提供面向事务的简单不可靠信息传送服务。
ICMP协议是Internet控制报文协议（Internet Control Message Protocol）它是TCP/IP协议族的一个子协议，用于在IP主机、路由器之间传递控制消息。
IGMP协议是 Internet 组管理协议（Internet Group Management Protocol），是因特网协议家族中的一个组播协议。该协议运行在主机和组播路由器之间。
ARP协议是正向地址解析协议（Address Resolution Protocol），通过已知的IP，寻找对应主机的MAC地址。
RARP是反向地址转换协议，通过MAC地址确定IP地址。
<h3 id="分层模型">分层模型</h3>
<h4 id="网络分层架构">网络分层架构</h4>
为了减少协议设计的复杂性，大多数网络模型均采用分层的方式来组织。每一层都有自己的功能，就像建筑物一样，每一层都靠下一层支持。每一层利用下一层提供的服务来为上一层提供服务，本层服务的实现细节对上层屏蔽。
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106163236924-508428758.png" alt="" loading="lazy">
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162303726-307068193.png" alt="" loading="lazy">
造车比喻(协议分层)
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162317652-1248307042.png" alt="" loading="lazy">
减少复杂度，解耦
越下面的层，越靠近硬件；越上面的层，越靠近用户。至于每一层叫什么名字，对应编程而言不重要，但面试的时候，面试官可能会问每一层的名字。
业内普遍的分层方式有两种。OSI七层模型和TCP/IP四层模型。可以通过背诵两个口诀来快速记忆：
OSI七层模型: 应、表、会、传、网、数、物
TCP/IP四层模型: 应、传、网、链
<code>物理层</code>: 主要定义物理设备标准，如网线的接口类型、光纤的接口类型、各种传输介质的传输速率等。它的主要作用是传输比特流（就是由1、0转化为电流强弱来进行传输，到达目的地后再转化为1、0，也就是我们常说的数模转换与模数转换）。这一层的数据叫做比特。
<code>数据链路层</code>：定义了如何让格式化数据以帧为单位进行传输，以及如何让控制对物理介质的访问。这一层通常还提供错误检测和纠正，以确保数据的可靠传输。如：串口通信中使用到的115200、8、N、1
<code>网络层</code>: 在位于不同地理位置的网络中的两个主机系统之间提供连接和路径选择。Internet的发展使得从世界各站点访问信息的用户数大大增加，而网络层正是管理这种连接的层。
<code>传输层</code>: 定义了一些传输数据的协议和端口号（WWW端口80等），如：TCP（传输控制协议，传输效率低，可靠性强，用于传输可靠性要求高，数据量大的数据），UDP（用户数据报协议，与TCP特性恰恰相反，用于传输可靠性要求不高，数据量小的数据，如QQ聊天数据就是通过这种方式传输的）。主要是将从下层接收的数据进行分段和传输，到达目的地址后再进行重组。常常把这一层数据叫做段。
<code>会话层</code>: 通过传输层(端口号：传输端口与接收端口)建立数据传输的通路。主要在你的系统之间发起会话或者接受会话请求（设备之间需要互相认识可以是IP也可以是MAC或者是主机名）。
<code>应用层</code>: 是最靠近用户的OSI层。这一层为用户的应用程序（例如电子邮件、文件传输和终端仿真）提供网络服务。
<h4 id="层与协议">层与协议</h4>
每一层都是为了完成一种功能，为了实现这些功能，就需要大家都遵守共同的规则。大家都遵守这规则，就叫做“协议”（protocol）。
网络的每一层，都定义了很多协议。这些协议的总称，叫“TCP/IP协议”。TCP/IP协议是一个大家族，不仅仅只有TCP和IP协议，它还包括其它的协议，如下图：
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162342228-35259713.png" alt="" loading="lazy">
<h4 id="协议功能">协议功能</h4>
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162406504-1780991465.png" alt="" loading="lazy">
<h5 id="链路层">链路层</h5>
以太网规定，连入网络的所有设备，都必须具有“网卡”接口。数据包必须是从一块网卡，传送到另一块网卡。通过网卡能够使不同的计算机之间连接，从而完成数据通信等功能。网卡的地址——MAC 地址，就是数据包的物理发送地址和物理接收地址。
网卡对应到协议里面就是与链路层ARP协议相关的
每个网卡有自己唯一的Mac地址
ARP可以帮助借助IP获取Mac地址
RARP可以借助Mac地址获取IP。
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162420944-1639350450.png" alt="" loading="lazy">
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162435483-1737703816.png" alt="" loading="lazy">
<h5 id="网络层">网络层</h5>
网络层的作用是引进一套新的地址，使得我们能够区分不同的计算机是否属于同一个子网络。这套地址就叫做“网络地址”，这是我们平时所说的IP地址。这个IP地址好比我们的手机号码，通过手机号码可以得到用户所在的归属地。
网络地址帮助我们确定计算机所在的子网络，MAC 地址则将数据包送到该子网络中的目标网卡。网络层协议包含的主要信息是源IP和目的IP。
于是，“网络层”出现以后，<code>每台计算机有了两种地址，一种是 MAC 地址，另一种是网络地址</code>。两种地址之间没有任何联系，MAC 地址是绑定在网卡上的，网络地址则是管理员分配的，它们只是随机组合在一起。
网络地址帮助我们确定计算机所在的子网络，MAC 地址则将数据包送到该子网络中的目标网卡。因此，从逻辑上可以推断，必定是先处理网络地址，然后再处理 MAC 地址。
IP地址本质:2进制数。----点分十进制IP地址（string)
<h5 id="传输层">传输层</h5>
当我们一边聊QQ，一边聊微信，当一个数据包从互联网上发来的时候，我们怎么知道，它是来自QQ的内容，还是来自微信的内容？
也就是说，我们还需要一个参数，表示这个数据包到底供哪个程序（进程）使用。这个参数就叫做“端口”（port），它其实是每一个使用网卡的程序的编号。每个数据包都发到主机的特定端口，所以不同的程序就能取到自己所需要的数据。
端口就是在传输层指定的。
port -- 在一台主机上唯一标识一个进程
端口特点:
<ul>
<li>对于同一个端口，在不同系统中对应着不同的进程</li>
<li>对于同一个系统，一个端口只能被一个进程拥有</li>
</ul>
常用协议:TCP、UDP
<h5 id="应用层">应用层</h5>
应用程序收到“传输层”的数据，接下来就要进行解读。由于互联网是开放架构，数据来源五花八门，必须事先规定好格式，否则根本无法解读。“应用层”的作用，就是规定应用程序的数据格式。
FTP、HTTP、或自定义协议 
对数据进行封装、解封装
<h3 id="通信过程">通信过程</h3>
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162455833-153777143.png" alt="" loading="lazy">
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162510053-1743053537.png" alt="" loading="lazy">
数据通信过程
封装:应用层 ----------------- 传输层 ---------------- 网络层 ----------- 链路层
解封装: 链路层 ------------- 网路层 ------------- 传输层 ------------应用层
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162526051-1028596011.png" alt="" loading="lazy">
<h2 id="socket编程">Socket编程</h2>
<h3 id="什么是socket">什么是Socket</h3>
Socket，英文含义是【插座、插孔】，一般称之为套接字，用于描述IP地址和端口。可以实现不同程序间的数据通信。
Socket起源于Unix，而Unix基本哲学之一就是“一切皆文件”，都可以用“打开open –> 读写write/read –> 关闭close”模式来操作。Socket就是该模式的一个实现，网络的Socket数据传输是一种特殊的I/O，Socket也是一种文件描述符。Socket也具有一个类似于打开文件的函数调用：Socket()，该函数返回一个整型的Socket描述符，随后的连接建立、数据传输等操作都是通过该Socket实现的。
套接字的内核实现较为复杂，不宜在学习初期深入学习，了解到如下结构足矣。
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162550906-29473565.png" alt="" loading="lazy">
在TCP/IP协议中，“IP地址+TCP或UDP端口号”唯一标识网络通讯中的一个进程。“IP地址+端口号”就对应一个socket。欲建立连接的两个进程各自有一个socket来标识，那么这两个socket组成的socket pair就唯一标识一个连接。因此可以用Socket来描述网络连接的一对一关系。
常用的Socket类型有两种：流式Socket（SOCK_STREAM）和数据报式Socket（SOCK_DGRAM）。流式是一种面向连接的Socket，针对于面向连接的TCP服务应用；数据报式Socket是一种无连接的Socket，对应于无连接的UDP服务应用。
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162602829-355535267.png" alt="" loading="lazy">
Socket是典型的双向全双工
<h3 id="网络应用程序设计模式">网络应用程序设计模式</h3>
<h4 id="cs模式">C/S模式</h4>
传统的网络应用设计模式，客户机(client)/服务器(server)模式。需要在通讯两端各自部署客户机和服务器来完成数据通信。
<h4 id="bs模式">B/S模式</h4>
浏览器(Browser)/服务器(Server)模式。只需在一端部署服务器，而另外一端使用每台PC都默认配置的浏览器即可完成数据的传输。
<h4 id="优缺点">优缺点</h4>
对于C/S模式来说，其优点明显。客户端位于目标主机上可以保证性能，将数据缓存至客户端本地，从而提高数据传输效率。且，一般来说客户端和服务器程序由一个开发团队创作，所以他们之间所采用的协议相对灵活。可以在标准协议的基础上根据需求裁剪及定制。例如，腾讯所采用的通信协议，即为ftp协议的修改剪裁版。
 因此，传统的网络应用程序及较大型的网络应用程序都首选C/S模式进行开发。如，知名的网络游戏魔兽世界。3D画面，数据量庞大，使用C/S模式可以提前在本地进行大量数据的缓存处理，从而提高观感。
 C/S模式的缺点也较突出。由于客户端和服务器都需要有一个开发团队来完成开发。工作量将成倍提升，开发周期较长。另外，从用户角度出发，需要将客户端安插至用户主机上，对用户主机的安全性构成威胁。这也是很多用户不愿使用C/S模式应用程序的重要原因。
 B/S模式相比C/S模式而言，由于它没有独立的客户端，使用标准浏览器作为客户端，其工作开发量较小。只需开发服务器端即可。另外由于其采用浏览器显示数据，因此移植性非常好，不受平台限制。如早期的偷菜游戏，在各个平台上都可以完美运行。
 B/S模式的缺点也较明显。由于使用第三方浏览器，因此网络应用支持受限。另外，没有客户端放到对方主机上，缓存数据不尽如人意，从而传输数据量受到限制。应用的观感大打折扣。第三，必须与浏览器一样，采用标准http协议进行通信，协议选择不灵活。
 因此在开发过程中，模式的选择由上述各自的特点决定。根据实际需求选择应用程序设计模式。
<h3 id="tcp的cs架构">TCP的C/S架构</h3>
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162615227-1483833109.png" alt="" loading="lazy">
服务器首先启动一个net.Listen()，这个net.Listen()从名字上看好像是启动一个监听，实际上这是由于套接字socket最早期设计的原因，在Go语言设计的时候还是沿用了Unix当初设计的思想，直接把函数名拿过来了，这个函数初学的同学都会有一个误解，认为它是监听，实际上它不是，这个listen()函数不是真正的监听客户端，要监听的话监听什么？要监听客户端和我的连接，但是这个Listen不是监听客户端，而是我设置服务器监听的资源(IP、端口)，Accept()才是真正监听的，那言外之意，监听嘛，我等着你对我进行访问吧，那就是说，你没访问我之前是不是应该一直处于等待状态，一会儿我们写程序看一下，是在Listen()的时候等着还是在Accept的时候等着，所以Accept是表示接受的意思，当它Accpet调用起来以后，它就等着客户端和我建立连接，比方说，图示上已经说了，它会阻塞等待用户建立连接，那言外之意，我没有用户建立连接之前它就一直阻塞在那里等待着，实际上监听是在Accept的时候才发起的，当然Accept不是无源之水，它必要Listen设置好了连接方式(tcp还是udp)、IP地址以及端口以后才能阻塞去监听，当有一个客户端和服务器发起请求之后，我调Accept()函数完成了，那就说明我服务器和客户端之间的连接建立好了，接来下干什么呢？进行数据传输，我建立好连接的目的就是为了进行数据传递，我们这里假定那一般实际上也是这样，客户端主动找服务器建立连接，连接建立好了，客户端先发送数据给服务器，服务器被动的接受客户端发来的请求，被动接受客户端请求数据，接受到了请求以后，服务器进行相应的分析处理，处理完以后把你要请求的数据回写回去，服务端Read()是读取客户端发送过来的请求，Write()是我把你的请求处理完之后再给你写回去，当这些都做完了，说明我们跟客户端的一次通信就完成了，那这个时候我们就可以关闭连接。当然如果你还想后续继续通信的话，这个close()关闭就要延迟。
客户端这个流程很简单，因为服务器先要站出来在那儿等着客户端和我建立连接，所以说，服务器就得先启动，客户端相当于是我得等你服务器启动起来以后你都准备好了，我在给你发送访问请求，客户端发送访问请求，也是调用一个函数，叫做net.Dail()函数，这个Dail()函数会对阻塞的Accept()发送一个请求，如果服务器准备好，Accept()返回的时候，Dail也返回，咱们就说客户端和服务器建立好了连接，客户端先发送数据，所以客户端先是一个写操作，发送完数据，服务器那边读到客户端请求进行处理，处理完之后写回来，客户端再Read()读取服务器写回来的数据，读完以后客户端也可以做简单处理，比方说我读到了以后，打印显示，完成了写，完成了读，一次跟网络端的通信也就完成了，客户端可以关闭连接，大致的流程就是这样。
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162626621-257455136.png" alt="" loading="lazy">
前面说过，socket通信，既然要通信，至少得是一对，如上图所示，Accpet()和Dail()成功后都会返回一个socket。
其实Listen()的时候也会创建一个socket，但是这个socket不是用于通信的，只是创建用于通信的socket,绑定IP地址和端口设置监听的
<h3 id="简单的cs模型通信">简单的C/S模型通信</h3>
<h4 id="server端">Server端</h4>
Listen函数:
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162640116-1166530080.png" alt="" loading="lazy">
network: 选用的协议:TCP、UDP 如: "tcp"或"udp"
address：IP地址+端口号 如: "127.0.0.1:8000"或":8000"
Listener接口:
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162651462-1412042685.png" alt="" loading="lazy">
Conn接口:
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162701452-1483515998.png" alt="" loading="lazy">
参看 https://studygolang.com/pkgdoc 中文帮助文档中的demo：
TCP服务器端代码:
<pre><code class="language-go">package main

import (
"fmt"
"net"
)

func main() {
//指定服务器通信协议,IP地址,port. 创建一个用户监听的socket
listener, err := net.Listen("tcp", "127.0.0.1:8000")
if err != nil {
fmt.Printf("服务器设置监听失败,原因是:%v\n", err)
return
}
defer listener.Close()

fmt.Println("服务器等待客户端建立连接...")
//阻塞监听客户端连接请求,成功建立连接,返回用于通信的socket
conn, err := listener.Accept()
if err != nil {
fmt.Printf("服务器监听失败,原因是:%v\n", err)
}
defer conn.Close()

fmt.Println("服务器与客户端成功建立连接!!!")
//读取客户端发送的数据
buf := make([]byte, 1024)
n, err := conn.Read(buf)
if err != nil {
fmt.Printf("Conn Read()错误,原因是:%v\n", err)
}

//处理数据 -- 打印
fmt.Println("服务器读到数据:", string(buf[:n]))
}
</code></pre>
运行代码
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162715728-1874873964.png" alt="" loading="lazy">
利用nc模式客户端请求
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162725384-53773720.png" alt="" loading="lazy">
再次查看运行的终端，可以发现已经成功建立了连接
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162739453-1008537704.png" alt="" loading="lazy">
我们用nc连接后，还可以发送数据
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162749260-1944323114.png" alt="" loading="lazy">
再次查看运行的终端
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162759100-416055046.png" alt="" loading="lazy">
如图，在整个通信过程中，服务器端有两个socket参与进来，但用于通信的只有 conn 这个socket。它是由 listener创建的。隶属于服务器端。
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162846000-249745155.png" alt="" loading="lazy">
<h4 id="client端">Client端</h4>
Dial函数:
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162906263-623283986.png" alt="" loading="lazy">
network: 选用的协议:TCP、UDP 如: "tcp"或"udp"
address：IP地址+端口号 如: "127.0.0.1:8000"或":8000"
Conn接口:
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162921867-655967046.png" alt="" loading="lazy">
客户端代码:
<pre><code class="language-go">package main

import (
"fmt"
"net"
)

func main() {

//指定服务器IP+port创建通信套接字
conn, err := net.Dial("tcp", "127.0.0.1:8000")
if err != nil {
fmt.Printf("net.Dial err:%v\n", err)
return
}
defer conn.Close()

//主动写数据给服务器
_, err = conn.Write([]byte("Are you ready?"))
if err != nil {
fmt.Printf("conn.Write err:%v\n", err)
return
}

buf := make([]byte, 1024)
//接受服务器回发的数据
n, err := conn.Read(buf)
if err != nil {
fmt.Printf("conn.Read err:%v\n", err)
return
}

fmt.Printf("服务器回发的数据为:%v\n", string(buf[:n]))
}
</code></pre>
由于我们想要服务器端回写内容，所以需要修改一下之前的服务端代码
更新服务器端代码:
<pre><code class="language-go">package main

import (
"fmt"
"net"
)

func main() {
//指定服务器通信协议,IP地址,port. 创建一个用户监听的socket
listener, err := net.Listen("tcp", "127.0.0.1:8000")
if err != nil {
 fmt.Printf("服务器设置监听失败,原因是:%v\n", err)
 return
}
defer listener.Close()

fmt.Println("服务器等待客户端建立连接...")
//阻塞监听客户端连接请求,成功建立连接,返回用于通信的socket
conn, err := listener.Accept()
if err != nil {
 fmt.Printf("服务器监听失败,原因是:%v\n", err)
}
defer conn.Close()

fmt.Println("服务器与客户端成功建立连接!!!")
//读取客户端发送的数据
buf := make([]byte, 1024)
n, err := conn.Read(buf)
if err != nil {
 fmt.Printf("Conn Read()错误,原因是:%v\n", err)
}

//处理数据 -- 回写给客户端
if string(buf[:n]) == "Are you ready?" {
 conn.Write([]byte("I am ready!!!"))
} else {
 conn.Write([]byte("I don`t know what you say!!!"))
}
}
</code></pre>
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106162939751-1914099286.png" alt="" loading="lazy">
<h3 id="并发的cs模型通信">并发的C/S模型通信</h3>
<h4 id="并发server">并发Server</h4>
现在已经完成了客户端与服务端的通信，但是服务端只能接收一个用户发送过来的数据，怎样接收多个客户端发送过来的数据，实现一个高效的并发服务器呢？
Accept()函数的作用是等待客户端的链接，如果客户端没有链接，该方法会阻塞。如果有客户端链接，那么该方法返回一个Socket负责与客户端进行通信。所以，每来一个客户端，该方法就应该返回一个Socket与其通信，因此，可以使用一个死循环，将Accept()调用过程包裹起来。
需要注意的是，实现并发处理多个客户端数据的服务器，就需要针对每一个客户端连接，单独产生一个Socket，并创建一个单独的goroutine与之完成通信。
<pre><code class="language-go">func main() {

//创建监听套接字
listener, err := net.Listen("tcp", "127.0.0.1:8000")
if err != nil {
 fmt.Printf("net.Listen() err:%v\n", err)
 return
}
defer listener.Close()

//监听客户端连接请求
for {
 fmt.Println("服务器等待客户端连接...")
 conn, err := listener.Accept()
 if err != nil {
 fmt.Printf("listener.Accept() err:%v\n", err)
 return
 }
 //具体完成服务器和客户端的数据通信
 go HandleConnect(conn)
}
}
</code></pre>
将客户端的数据处理工作封装到HandleConn方法中，需将Accept()返回的Socket传递给该方法，变量conn的类型为：net.Conn。可以使用conn.RemoteAddr()来获取成功与服务器建立连接的客户端IP地址和端口号：
客户端可能持续不断的发送数据，因此接收数据的过程可以放在for循环中，服务端也持续不断的向客户端返回处理后的数据。
<pre><code class="language-go">func HandleConnect(conn net.Conn) {
defer conn.Close()
//获取连接的客户端 Addr

addr := conn.RemoteAddr()
fmt.Println(addr, "客户端成功连接!")
//循环读取客户端发送数据
buf := make([]byte, 1024)
for {
//注意，read读取时，会将命令行里的换行符也给读取了，在*Unix上换行符是\n,在Windows上时\r\n
n, err := conn.Read(buf)
if err != nil {
if err == io.EOF {
fmt.Println("客户端退出了!!!")
break
} else {
fmt.Printf("conn.Read() err:%v\n", err)
return
}
}
fmt.Printf("服务器读到数据:%v", string(buf[:n]))
//小写转大写,回发给客户端
conn.Write(bytes.ToUpper(buf[:n]))
}
}
</code></pre>
<h4 id="并发client">并发Client</h4>
客户端不仅需要持续的向服务端发送数据，同时也要接收从服务端返回的数据。因此可将发送和接收放到不同的协程中。
主协程循环接收服务器回发的数据（该数据应已转换为大写），并打印至屏幕；子协程循环从键盘读取用户输入数据，写给服务器。读取键盘输入可使用 os.Stdin.Read(str)。定义切片str，将读到的数据保存至str中。
这样，客户端也实现了多任务。
客户端代码:
<pre><code class="language-go">package main

import (
"fmt"
"io"
"net"
"os"
)

func main() {

//发起连接请求
conn, err := net.Dial("tcp", "127.0.0.1:8000")
if err != nil {
fmt.Printf("net.Dial() err:%v\n", err)
return
}
defer conn.Close()

//获取用户键盘输入(os.Stdin),并将输入数据发送给服务器
go func() {
str := make([]byte, 1024)
for {
n, err := os.Stdin.Read(str)
if err != nil {
fmt.Printf("os.Stdin.Read() err:%v\n", err)
continue
}
//写给服务器,读多少,写多少
conn.Write(str[:n])
}
}()

for {
buf := make([]byte, 1024)
n, err := conn.Read(buf)
if err != nil {
if err == io.EOF {
fmt.Println("服务端退出了!!!")
return
} else {
fmt.Printf("conn.Read() err:%v\n", err)
continue
}
}
fmt.Printf("客户端读到服务器回发数据:%s",buf[:n])
}
}
</code></pre>
<h3 id="tcp通信">TCP通信</h3>
下图是一次TCP通讯的时序图。TCP连接建立断开。包含大家熟知的三次握手和四次挥手。
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106163001515-709590857.png" alt="" loading="lazy">
在这个例子中，首先客户端主动发起连接、发送请求，然后服务器端响应请求，然后客户端主动关闭连接。两条竖线表示通讯的两端，从上到下表示时间的先后顺序。注意，数据从一端传到网络的另一端也需要时间，所以图中的箭头都是斜的。
<h4 id="三次握手">三次握手</h4>
所谓三次握手（Three-Way Handshake）即建立TCP连接，就是指建立一个TCP连接时，需要客户端和服务端总共发送3个包以确认连接的建立。好比两个人在打电话：
Client: "喂，你能听得到吗？"
Server: "我听得到，你听得到我吗？"
Client: "我能听到你，今天balabala..."
建立连接(三次握手)的过程:
<ol>
<li>客户端发送一个带SYN标志的TCP报文到服务器。这是上图中三次握手过程中的段1。客户端发出SYN位表示连接请求。序号是1000，这个序号在网络通讯中用作临时的地址，每发一个数据字节，这个序号要加1，这样在接收端可以根据序号排出数据包的正确顺序，也可以发现丢包的情况。 
另外，规定SYN位和FIN位也要占一个序号，这次虽然没发数据，但是由于发了SYN位，因此下次再发送应该用序号1001。 
mss表示最大段尺寸，如果一个段太大，封装成帧后超过了链路层的最大长度，就必须在IP层分片，为了避免这种情况，客户端声明自己的最大段尺寸，建议服务器端发来的段不要超过这个长度。</li>
<li>服务器端回应客户端，是三次握手中的第2个报文段，同时带ACK标志和SYN标志。表示对刚才客户端SYN的回应；同时又发送SYN给客户端，询问客户端是否准备好进行数据通讯。 
服务器发出段2，也带有SYN位，同时置ACK位表示确认，确认序号是1001，表示“我接收到序号1000及其以前所有的段，请你下次发送序号为1001的段”，也就是应答了客户端的连接请求，同时也给客户端发出一个连接请求，同时声明最大尺寸为1024。</li>
<li>客户必须再次回应服务器端一个ACK报文，这是报文段3。 
客户端发出段3，对服务器的连接请求进行应答，确认序号是8001。在这个过程中，客户端和服务器分别给对方发了连接请求，也应答了对方的连接请求，其中服务器的请求和应答在一个段中发出。</li>
</ol>
因此一共有三个段用于建立连接，称为“三方握手”。在建立连接的同时，双方协商了一些信息，例如，双方发送序号的初始值、最大段尺寸等。
数据传输的过程:
<ol>
<li>客户端发出段4，包含从序号1001开始的20个字节数据。</li>
<li>服务器发出段5，确认序号为1021，对序号为1001-1020的数据表示确认收到，同时请求发送序号1021开始的数据，服务器在应答的同时也向客户端发送从序号8001开始的10个字节数据。</li>
<li>客户端发出段6，对服务器发来的序号为8001-8010的数据表示确认收到，请求发送序号8011开始的数据。</li>
</ol>
在数据传输过程中，ACK和确认序号是非常重要的，应用程序交给TCP协议发送的数据会暂存在TCP层的发送缓冲区中，发出数据包给对方之后，只有收到对方应答的ACK段才知道该数据包确实发到了对方，可以从发送缓冲区中释放掉了，如果因为网络故障丢失了数据包或者丢失了对方发回的ACK段，经过等待超时后TCP协议自动将发送缓冲区中的数据包重发。
<h4 id="四次挥手">四次挥手</h4>
所谓四次挥手（Four-Way-Wavehand）即终止TCP连接，就是指断开一个TCP连接时，需要客户端和服务端总共发送4个包以确认连接的断开。在socket编程中，这一过程由客户端或服务器任一方执行close来触发。好比两个人打完电话要挂断：
Client: "我要说的事情都说完了，我没事了。挂啦？"
Server: "等下，我还有一个事儿。Balabala…"
Server: "好了，我没事儿了。挂了啊。"
Client: "ok！拜拜"
关闭连接(四次握手)的过程:
由于TCP连接是全双工的，因此每个方向都必须单独进行关闭。这原则是当一方完成它的数据发送任务后就能发送一个FIN来终止这个方向的连接。收到一个 FIN只意味着这一方向上没有数据流动，一个TCP连接在收到一个FIN后仍能发送数据。首先进行关闭的一方将执行主动关闭，而另一方执行被动关闭。
<ol>
<li>客户端发出段7，FIN位表示关闭连接的请求。</li>
<li>服务器发出段8，应答客户端的关闭连接请求。</li>
<li>服务器发出段9，其中也包含FIN位，向客户端发送关闭连接请求。</li>
<li>客户端发出段10，应答服务器的关闭连接请求。</li>
</ol>
建立连接的过程是三次握手，而关闭连接通常需要4个段，服务器的应答和关闭连接请求通常不合并在一个段中，因为有连接半关闭的情况，这种情况下客户端关闭连接之后就不能再发送数据给服务器了，但是服务器还可以发送数据给客户端，直到服务器也关闭连接为止。
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106163021227-1474496982.png" alt="" loading="lazy">
下图是TCP状态转换图
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106232257768-767520919.png" alt="" loading="lazy">
<h3 id="udp通信">UDP通信</h3>
在之前的案例中，我们一直使用的是TCP协议来编写Socket的客户端与服务端。其实也可以使用UDP协议来编写Socket的客户端与服务端。
<h4 id="udp服务器">UDP服务器</h4>
由于UDP是“无连接”的，所以，服务器端不需要额外创建监听套接字，只需要指定好IP和port，然后监听该地址，等待客户端与之建立连接，即可通信。
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106232614294-17269298.png" alt="" loading="lazy">
<ol>
<li>
创建监听地址
<pre><code class="language-go">func ResolveUDPAddr(network, address string) (*UDPAddr, error)
</code></pre>
ResolveUDPAddr将addr作为UDP地址解析并返回。参数addr格式为"host:port"或":port"，解析得到网络名和端口名；net必须是"udp"、"udp4"或"udp6"。 
IPv6地址字面值/名称必须用方括号包起来，如"[::1]:80"、":http"或":80"。
</li>
<li>
创建用于通信的socket
<pre><code class="language-go">func ListenUDP(network string, laddr *UDPAddr) (*UDPConn, error)
</code></pre>
ListenUDP创建一个接收目的地是本地地址laddr的UDP数据包的网络连接。net必须是"udp"、"udp4"、"udp6"；如果laddr端口为0，函数将选择一个当前可用的端口，可以用Listener的Addr方法获得该端口。返回的*UDPConn的ReadFrom和WriteTo方法可以用来发送和接收UDP数据包（每个包都可获得来源地址或设置目标地址）。
</li>
<li>
接受UDP数据
<pre><code class="language-go">func (c *UDPConn) ReadFromUDP(b []byte) (n int, addr *UDPAddr, err error)
</code></pre>
ReadFromUDP从c读取一个UDP数据包，将有效负载拷贝到b，返回拷贝字节数和数据包来源地址。
ReadFromUDP方法会在超过一个固定的时间点之后超时，并返回一个错误。
</li>
<li>
写出数据到UDP
<pre><code class="language-go">func (c *UDPConn) WriteToUDP(b []byte, addr *UDPAddr) (int, error)
</code></pre>
WriteToUDP通过c向地址addr发送一个数据包，b为包的有效负载，返回写入的字节。
WriteToUDP方法会在超过一个固定的时间点之后超时，并返回一个错误。在面向数据包的连接上，写入超时是十分罕见的。
</li>
</ol>
服务器端代码:
<pre><code class="language-go">package main

import (
"fmt"
"net"
)

func main() {

//0.本应从步骤1开始,但是在写步骤1的时候发现,步骤1还需要*UDPAddr类型的参数,所以需要先创建一个*DUPAddr
//组织一个udp地址结构,指定服务器的IP+port
udpAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8000")
if err != nil {
 fmt.Printf("net.ResolveUDPAddr()函数执行出错,错误为:%v\n", err)
 return
}
fmt.Printf("UDP服务器地址结构创建完成!!!\n")

//1.创建用户通信的socket
//由于ListenUDP需要一个*UDPAddr类型的参数,所以我们还需要先创建一个监听地址
udpConn, err := net.ListenUDP("udp", udpAddr)
if err != nil {
 fmt.Printf("net.ListenUDP()函数执行出错,错误为:%v\n", err)
 return
}
defer udpConn.Close()
fmt.Printf("UDP服务器通信socket创建完成!!!\n")

//2.读取客户端发送的数据(阻塞发生在ReadFromUDP()方法中)
buf := make([]byte, 4096)
//ReadFromUDP()方法返回三个值,分别是读取到的字节数,客户端的地址,error
n, clientUDPAddr, err := udpConn.ReadFromUDP(buf)
if err != nil {
 fmt.Printf("*UDPAddr.ReadFromUDP()方法执行出错,错误为:%v\n", err)
 return
}
//3.模拟处理数据
fmt.Printf("服务器读到%v的数据:%s",clientUDPAddr, buf[:n])

//4.回写数据给客户端
_, err = udpConn.WriteToUDP([]byte("I am OK!"), clientUDPAddr)
if err != nil {
 fmt.Printf("*UDPAddr.WriteToUDP()方法执行出错,错误为:%v\n", err)
 return
}
}
</code></pre>
运行代码
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106232329789-1071083652.png" alt="" loading="lazy">
通过nc请求测试
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106232338134-429879154.png" alt="" loading="lazy">
服务端读取请求数据，并回写"I am OK!"
<img src="https://img2018.cnblogs.com/blog/720430/202001/720430-20200106232346550-548316228.png" alt="" loading="lazy">
<h4 id="udp客户端">UDP客户端</h4>
udp客户端的编写与TCP客户端的编写，基本上是一样的，只是将协议换成udp.代码如下：
<pre><code class="language-go">package main

import (
"fmt"
"net"
)

func main() {
conn, err := net.Dial("udp", "127.0.0.1:8000")
if err != nil {
 fmt.Printf("net.Dial()函数执行出错,错误为:%v\n", err)
 return
}
defer conn.Close()

conn.Write([]byte("hello, I`m a client in UDP!"))

buf := make([]byte, 4096)
n, err := conn.Read(buf)
if err != nil {
 fmt.Printf("Conn.Read()方法执行出错,错误为:%v\n", err)
 return
}
fmt.Printf("服务器发来数据:%s\n", buf[:n])
}
</code></pre>
<h4 id="并发">并发</h4>
其实对于UDP而言，服务器不需要并发，只要循环处理客户端数据即可。客户端也等同于TCP通信并发的客户端。
服务器:
<pre><code class="language-go">package main

import (
"fmt"
"net"
)

func main() {

//0.本应从步骤1开始,但是在写步骤1的时候发现,步骤1还需要*UDPAddr类型的参数,所以需要先创建一个*DUPAddr
//组织一个udp地址结构,指定服务器的IP+port
udpAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8000")
if err != nil {
 fmt.Printf("net.ResolveUDPAddr()函数执行出错,错误为:%v\n", err)
 return
}
fmt.Printf("UDP服务器地址结构创建完成!!!\n")

//1.创建用户通信的socket
//由于ListenUDP需要一个*UDPAddr类型的参数,所以我们还需要先创建一个监听地址
udpConn, err := net.ListenUDP("udp", udpAddr)
if err != nil {
 fmt.Printf("net.ListenUDP()函数执行出错,错误为:%v\n", err)
 return
}
defer udpConn.Close()
fmt.Printf("UDP服务器通信socket创建完成!!!\n")

for {
 //2.读取客户端发送的数据(阻塞发生在ReadFromUDP()方法中)
 buf := make([]byte, 4096)
 //ReadFromUDP()方法返回三个值,分别是读取到的字节数,客户端的地址,error
 n, clientUDPAddr, err := udpConn.ReadFromUDP(buf)
 if err != nil {
 fmt.Printf("*UDPAddr.ReadFromUDP()方法执行出错,错误为:%v\n", err)
 continue
 }
 //3.模拟处理数据
 fmt.Printf("服务器读到%v的数据:%s\n",clientUDPAddr, buf[:n])

 //4.回写数据给客户端
 _, err = udpConn.WriteToUDP([]byte("I am OK!"), clientUDPAddr)
 if err != nil {
 fmt.Printf("*UDPAddr.WriteToUDP()方法执行出错,错误为:%v\n", err)
 continue
 }
}
}
</code></pre>
客户端:
<pre><code class="language-go">package main

import (
"fmt"
"net"
"os"
)

func main() {
conn, err := net.Dial("udp", "127.0.0.1:8000")
if err != nil {
 fmt.Printf("net.Dial()函数执行出错,错误为:%v\n", err)
 return
}
defer conn.Close()

go func() {
 buf := make([]byte, 4096)
 for {
 //从键盘读取内容,放入buf
 n, err := os.Stdin.Read(buf)
 if err != nil {
 fmt.Printf("os.Stdin.Read()执行出错,错误为:%v\n", err)
 return
 }
 //给服务器发送
 conn.Write(buf[:n])
 }
}()
for {
 buf := make([]byte, 4096)
 n, err := conn.Read(buf)
 if err != nil {
 fmt.Printf("Conn.Read()方法执行出错,错误为:%v\n", err)
 return
 }
 fmt.Printf("服务器发来数据:%s\n", buf[:n])
}
}
</code></pre>
<h4 id="udp与tcp的差异">UDP与TCP的差异</h4>
<table>
<thead>
<tr>
<th>TCP</th>
<th>UDP</th>
</tr>
</thead>
<tbody>
<tr>
<td>面向连接</td>
<td>面向无连接</td>
</tr>
<tr>
<td>要求系统资源较多</td>
<td>要求系统资源较少</td>
</tr>
<tr>
<td>TCP程序结构复杂</td>
<td>UDP程序结构比较简单</td>
</tr>
<tr>
<td>使用流式</td>
<td>使用数据包式</td>
</tr>
<tr>
<td>保证数据准确性</td>
<td>不保证数据准确性</td>
</tr>
<tr>
<td>保证数据顺序</td>
<td>不保证数据顺序</td>
</tr>
<tr>
<td>通讯速度较慢</td>
<td>通讯速度较快</td>
</tr>
</tbody>
</table>
使用场景
TCP: 对数据传输安全性、稳定性要求高的场合。网络文件传输。下载、上传。
UDP: 对数据实时传输要求较高的场合。视频直播、在线电话会议。游戏
相关文章:
http请求是如何先建立的三次握手? 
来源：https://www.cnblogs.com/itbsl/p/12157025.html

頁: [1]

琼殿技术论坛's Archiver

Go网络编程