Socket 通信原理

Michael_Lin 发布于2019-07-31 11:04 / 1053人阅读

摘要：什么是的中文翻译过来就是套接字。套接字是什么，我们先来看看它的英文含义插座。服务端过程咱再来聊聊服务端的过程，服务端先初始化，建立流式套接字，与本机地址及端口进行绑定，然后通知，准备好接收连接，调用阻塞，等待来自客户端的连接。

什么是 Socket？

Socket 的中文翻译过来就是“套接字”。套接字是什么，我们先来看看它的英文含义：插座。

Socket 就像一个电话插座，负责连通两端的电话，进行点对点通信，让电话可以进行通信，端口就像插座上的孔，端口不能同时被其他进程占用。而我们建立连接就像把插头插在这个插座上，创建一个 Socket 实例开始监听后，这个电话插座就时刻监听着消息的传入，谁拨通我这个“IP 地址和端口”，我就接通谁。

实际上，Socket 是在应用层和传输层之间的一个抽象层，它把 TCP/IP 层复杂的操作抽象为几个简单的接口，供应用层调用实现进程在网络中的通信。Socket 起源于 UNIX，在 UNIX 一切皆文件的思想下，进程间通信就被冠名为文件描述符（file descriptor），Socket 是一种“打开—读/写—关闭”模式的实现，服务器和客户端各自维护一个“文件”，在建立连接打开后，可以向文件写入内容供对方读取或者读取对方内容，通讯结束时关闭文件。

另外我们经常说到的Socket 所在位置如下图：

Socket 通信过程

Socket 保证了不同计算机之间的通信，也就是网络通信。对于网站，通信模型是服务器与客户端之间的通信。两端都建立了一个 Socket 对象，然后通过 Socket 对象对数据进行传输。通常服务器处于一个无限循环，等待客户端的连接。

一图胜千言，下面是面向连接的 TCP 时序图：

客户端过程：

客户端的过程比较简单，创建 Socket，连接服务器，将 Socket 与远程主机连接（注意：只有 TCP 才有“连接”的概念，一些 Socket 比如 UDP、ICMP 和 ARP 没有“连接”的概念），发送数据，读取响应数据，直到数据交换完毕，关闭连接，结束 TCP 对话。

import socket
import sys

if __name__ == "__main__":
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建 Socket 连接
    sock.connect(("127.0.0.1", 8001))  # 连接服务器
    while True:
        data = input("Please input data:")
        if not data:
            break
        try:
            sock.sendall(data)
        except socket.error as e:
            print("Send Failed...", e)
            sys.exit(0)
        print("Send Successfully")

        res = sock.recv(4096)  # 获取服务器返回的数据，还可以用 recvfrom()、recv_into() 等
        print(res)
    sock.close()

sock.sendall(data)这里也可用 send() 方法：不同在于 sendall() 在返回前会尝试发送所有数据，并且成功时返回 None，而 send() 则返回发送的字节数量，失败时都抛出异常。

服务端过程：

咱再来聊聊服务端的过程，服务端先初始化 Socket，建立流式套接字，与本机地址及端口进行绑定，然后通知 TCP，准备好接收连接，调用 accept() 阻塞，等待来自客户端的连接。如果这时客户端与服务器建立了连接，客户端发送数据请求，服务器接收请求并处理请求，然后把响应数据发送给客户端，客户端读取数据，直到数据交换完毕。最后关闭连接，交互结束。

import socket
import sys

if __name__ == "__main__":
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建 Socket 连接（TCP）
    print("Socket Created")

    try:
        sock.bind(("127.0.0.1", 8001))  # 配置 Socket，绑定 IP 地址和端口号
    except socket.error as e:
        print("Bind Failed...", e)
        sys.exit(0)

    sock.listen(5)  # 设置最大允许连接数，各连接和 Server 的通信遵循 FIFO 原则

    while True:  # 循环轮询 Socket 状态，等待访问
        conn, addr = sock.accept()
        try:
            conn.settimeout(10)  # 如果请求超过 10 秒没有完成，就终止操作

            # 如果要同时处理多个连接，则下面的语句块应该用多线程来处理
            while True:  # 获得一个连接，然后开始循环处理这个连接发送的信息
                data = conn.recv(1024)
                print("Get value " + data, end="

")
                if not data:
                    print("Exit Server", end="

")
                    break
                conn.sendall("OK")  # 返回数据
        except socket.timeout:  # 建立连接后，该连接在设定的时间内没有数据发来，就会引发超时
            print("Time out")

        conn.close()  # 当一个连接监听循环退出后，连接可以关掉
    sock.close()

conn, addr = sock.accept()

调用 accept() 时，Socket 会进入waiting状态。客户端请求连接时，方法建立连接并返回服务器。accept() 返回一个含有两个元素的元组 (conn, addr)。第一个元素 conn 是新的 Socket 对象，服务器必须通过它与客户端通信；第二个元素 addr 是客户端的 IP 地址及端口。

data = conn.recv(1024)接下来是处理阶段，服务器和客户端通过 send() 和 recv() 通信（传输数据）。
服务器调用 send()，并采用字符串形式向客户端发送信息，send() 返回已发送的字符个数。
服务器调用 recv() 从客户端接收信息。调用 recv() 时，服务器必须指定一个整数，它对应于可通过本次方法调用来接收的最大数据量。recv() 在接收数据时会进入blocked状态，最后返回一个字符串，用它表示收到的数据。如果发送的数据量超过了 recv() 所允许的，数据会被截短。多余的数据将缓冲于接收端，以后调用 recv() 时，会继续读剩余的字节，如果有多余的数据会从缓冲区删除（以及自上次调用 recv() 以来，客户端可能发送的其它任何数据）。传输结束，服务器调用 Socket 的 close() 关闭连接。

从 TCP 连接的视角看 Socket 过程：

TCP 三次握手的 Socket 过程：

服务器调用 socket()、bind()、listen() 完成初始化后，调用 accept() 阻塞等待；

客户端 Socket 对象调用 connect() 向服务器发送了一个 SYN 并阻塞；

服务器完成了第一次握手，即发送 SYN 和 ACK 应答；

客户端收到服务端发送的应答之后，从 connect() 返回，再发送一个 ACK 给服务器；

服务器 Socket 对象接收客户端第三次握手 ACK 确认，此时服务端从 accept() 返回，建立连接。

接下来就是两个端的连接对象互相收发数据。

TCP 四次挥手的 Socket 过程：

某个应用进程调用 close() 主动关闭，发送一个 FIN；

另一端接收到 FIN 后被动执行关闭，并发送 ACK 确认；

之后被动执行关闭的应用进程调用 close() 关闭 Socket，并也发送一个 FIN；

接收到这个 FIN 的一端向另一端 ACK 确认。

总结：

上面的代码简单地演示了 Socket 的基本函数使用，其实不管有多复杂的网络程序，这些基本函数都会用到。上面的服务端代码只有处理完一个客户端请求才会去处理下一个客户端的请求，这样的服务器处理能力很弱，而实际中服务器都需要有并发处理能力，为了达到并发处理，服务器就需要 fork 一个新的进程或者线程去处理请求。

超融合服务器服务器托管 socket通信方式 socket通信实例 socket异步通信 socket?C?通信

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/44600.html

socket.io原理和实战

摘要：就是为了解决这一问题产生的，现在已经写入标准，主流浏览器基本支持。由于最近写项目要使用socekt.io技术，于是研究了一段时间，把自己早期学习阶段写的小游戏改造了一下，变成了一个比较完整的小程序。点击这里可以体验游戏,建议使用手机模式查看，也可以下载打包好的webapp，安卓版已上架酷安市场,扫码可下载体验： showImg(https://segmentfault.com/img...

ivyzhang 2019-08-22 13:59 评论0 收藏0
【HTTP基础】HTTPS原理及WebSocket原理

摘要：使用约定好的计算握手消息，并使用生产的随机数对消息进行加密，最后将之前生成的所有消息发送给网站。之后所有的通信数据将由之前浏览器生成的随机密码并利用对称加密算法进行加密。支持四个异步事件。由于HTTP没有加密机制，其传输的内容很容易泄漏，并且HTTP协议没法确认通信方，也无法保证接收到的报文在传输过程中是否被篡改，因此HTTPS是在HTTP协议的基础上提供了加密、认证和完整性保护的功...

fyber 2019-08-06 13:28 评论0 收藏0
八问WebSocket协议：为你快速解答WebSocket热门疑问

一、引言 WebSocket是一种比较新的协议，它是伴随着html5规范而生的，虽然还比较年轻，但大多主流浏览器都已经支持。它使用方面、应用广泛，已经渗透到前后端开发的各种场景中。对http一问一答中二式流程（就是从所周之的长轮询技要啦）的不满，催生了支持双向通信的WebSocket诞生。WebSocket是个不太干净协议。本文将从8个常见的疑问入手，为还不了解WebSocket协议的开发者快...

Zoom 2019-08-05 16:49 评论0 收藏0
即时通信相关技术总结

摘要：解决问题即时通信要解决三方面的问题双全工通信低延时支持跨域各种即时通信技术轮询客户端定时向服务器发送请求，服务器接到请求后马上返回响应信息并关闭连接。优点实现真正的即时通信，而不是伪即时。解决问题即时通信要解决三方面的问题：双全工通信低延时支持跨域各种即时通信技术轮询客户端定时向服务器发送Ajax请求，服务器接到请求后马上返回响应信息并关闭连接。优点：后端程序编写比...

reclay 2019-08-21 17:11 评论0 收藏0
Web实时弹幕原理分析

摘要：官方地址支持协议用于实时通信和跨平台的框架。如实时分析系统二进制流数据处理应用在线聊天室在线客服系统评论系统等。官方地址动画效果是一款优雅的网页弹幕插件支持显示图片文字以及超链接。废话不多说，首先上效果图。效果图 showImg(https://segmentfault.com/img/bVGo0P?w=521&h=635); 用途搞活动、年会的时候，在大屏幕上实时显示留言、吐...

tigerZH 2019-06-27 14:56 评论0 收藏0