写操作

• 阻塞 socket：

  直到发送完所有数据，写操作才返回

• 非阻塞 socket：

  • 当 socket 的发送缓冲区中没有空间时，直接返回 EWOULDBLOCK 错误
  • 当 socket 的发送缓冲区中有足够的空间或不足以拷贝所有待发送数据的空间时，则拷贝前 n 个能够容纳的字节，返回实际拷贝的字节数

读操作

• 阻塞 socket：

  • 当 socket 的接收缓冲区中没数据时，读操作会一直阻塞到有数据流入
  • 当 socket 的接收缓冲区中的数据量大于期望读取的数据量时，读取期望的字节数，返回实际读取的字节数
  • 当 socket 的接收缓冲区中的数据量小于期望读取的数据量时，读取全部的数据，返回实际读取的字节数

• 非阻塞 socket：

  • 当 socket 的接收缓冲区中没有数据时，直接返回 EWOULDBLOCK 错误
  • 当 socket 的接收缓冲区中有数据时，和阻塞 socket 的行为一致

accept

• 阻塞 socket：

  • 当连接队列中没有建立好的连接时，accept 将阻塞，直到有可用的连接才返回
  • 当连接队列中有建立好的连接时，accept 会从连接队列中弹出第一个连接，并返回新 socket，之后服务端使用该 socket 和客户端进行通信

• 非阻塞 socket：

  • 当连接队列中没有建立好的连接时，直接返回 EWOULDBLOCK 错误
  • 当连接队列中有建立好的连接时，和阻塞 socket 的行为一致

connect

• 阻塞 socket：

  • 首先发送 syn 报文到服务端，在收到服务端返回的 ack + syn 报文后，connect 才返回，否则一直阻塞

• 非阻塞 socket：

  • connect 不等待连接建立好才返回，而是立即返回，返回的错误码是 EINPROGRESS

非阻塞 connect 和 epoll

Python 示例（on Linux）：

xxxxxxxxxx
import errno
import socket
import select

if "EPOLLRDHUP" not in dir(select):
    select.EPOLLRDHUP = 0x2000
epoll = select.epoll()

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.setblocking(False)

try:
    sock.connect(("127.0.0.1", 80))
except IOError as ex:
    if ex.errno != errno.EINPROGRESS:
        raise

epoll.register(sock.fileno(),
               select.EPOLLIN | select.EPOLLOUT |
               select.EPOLLERR | select.EPOLLHUP |
               select.EPOLLRDHUP)

while True:
    events = epoll.poll(timeout=0.02)
    if not events:
        continue

    for fd, event in events:
        if event & select.EPOLLIN:
            print("in")
        if event & select.EPOLLOUT:
            print("out")
        if event & select.EPOLLERR:
            print("err")
        if event & select.EPOLLHUP:
            print("hup")
        if event & select.EPOLLRDHUP:
            print("rdhup")
    break
sock.close()

Posix 定义了两条与 select 和非阻塞 connect 相关的规定：

• 当连接建立成功时，socket 描述符变为可写
• 当连接建立失败时，socket 描述变为可读、可写、错误、关闭