网络编程 Socket 技术详细使用教程

Socket 技术概述

Socket（套接字）是网络编程的核心接口，它如同应用程序与网络之间的”插座”，让不同的进程能够在网络上进行通信。Socket 技术诞生于 Unix 系统，如今已成为所有现代操作系统的标准网络 API。

核心概念

Socket：网络连接的两端，一个 Socket 代表一个通信端点
IP 地址：网络中设备的唯一标识，如 192.168.1.100
端口号：同一设备上不同应用的标识，范围 0-65535
协议栈：TCP/IP 协议族，包含传输层、网络层等
客户端/服务端模型：最常见的网络通信架构

TCP vs UDP 对比

特性	TCP	UDP
连接性	面向连接	无连接
可靠性	可靠传输，保证数据顺序	不可靠，可能丢包
速度	较慢，有握手开销	快，无额外开销
适用场景	文件传输、网页浏览	视频直播、在线游戏
流量控制	有	无

Socket 核心操作流程

服务端流程

创建 Socket：调用 `socket()` 函数创建套接字
绑定地址：使用 `bind()` 将 Socket 绑定到特定 IP 和端口
监听连接：调用 `listen()` 进入监听状态
接受连接：使用 `accept()` 等待并接受客户端连接
收发数据：通过 `read()/write()` 或 `recv()/send()` 交换数据
关闭连接：调用 `close()` 关闭 Socket

客户端流程

创建 Socket：调用 `socket()` 函数
连接服务端：使用 `connect()` 连接到服务端地址
收发数据：通过 Socket 交换数据
关闭连接：调用 `close()` 关闭连接

Python 实现示例

TCP Socket 服务端

“`python
import socket

def create_tcp_server(host=’0.0.0.0′, port=8888):
# 1. 创建 Socket（AF_INET: IPv4, SOCK_STREAM: TCP）
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 允许端口复用
server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

# 2. 绑定地址
server_socket.bind((host, port))

# 3. 开始监听（最大排队连接数为 5）
server_socket.listen(5)
print(f”服务监听在 {host}:{port}”)

try:
while True:
# 4. 接受客户端连接
client_socket, client_addr = server_socket.accept()
print(f”新连接：{client_addr}”)

try:
# 5. 接收数据（最多接收 1024 字节）
data = client_socket.recv(1024).decode(‘utf-8’)
print(f”收到消息：{data}”)

# 发送响应
response = “服务器收到消息”
client_socket.send(response.encode(‘utf-8’))

except Exception as e:
print(f”通信错误：{e}”)
finally:
# 关闭客户端 Socket
client_socket.close()

except KeyboardInterrupt:
print(“服务器关闭”)
finally:
# 关闭服务器 Socket
server_socket.close()

if __name__ == “__main__”:
create_tcp_server()


TCP Socket 客户端

python
import socket

def create_tcp_client(host=’127.0.0.1′, port=8888):
# 1. 创建 Socket
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

try:
# 2. 连接服务端
client_socket.connect((host, port))
print(f”已连接到 {host}:{port}”)

# 3. 发送数据
message = “你好，服务器！”
client_socket.send(message.encode(‘utf-8’))
print(f”发送：{message}”)

# 4. 接收响应
response = client_socket.recv(1024).decode(‘utf-8’)
print(f”收到响应：{response}”)

except Exception as e:
print(f”客户端错误：{e}”)
finally:
# 5. 关闭连接
client_socket.close()
print(“连接已关闭”)

if __name__ == “__main__”:
create_tcp_client()


UDP Socket 示例

python
import socket

def create_udp_server(host=’0.0.0.0′, port=9999):
# SOCK_DGRAM: UDP 协议
udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
udp_socket.bind((host, port))
print(f”UDP 服务监听在 {host}:{port}”)

try:
while True:
# UDP 无需连接，直接接收
data, client_addr = udp_socket.recvfrom(1024)
print(f”从 {client_addr} 收到：{data.decode(‘utf-8’)}”)

# 发送响应
response = “UDP 服务器回复”
udp_socket.sendto(response.encode(‘utf-8′), client_addr)

finally:
udp_socket.close()

def create_udp_client(host=’127.0.0.1’, port=9999):
udp_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

try:
message = “UDP 客户端消息”
udp_socket.sendto(message.encode(‘utf-8’), (host, port))
print(f”发送：{message}”)

# UDP 接收可能有多个服务器的响应
data, _ = udp_socket.recvfrom(1024)
print(f”收到：{data.decode(‘utf-8’)}”)

finally:
udp_socket.close()

if __name__ == “__main__”:
# 先运行服务端，再运行客户端
create_udp_client()


C/C++ Socket 实现

TCP 服务端（C 语言）

c
#include
#include
#include
#include
#include

#define PORT 8888
#define BUFFER_SIZE 1024

int main() {
int server_fd, client_fd;
struct sockaddr_in address;
int opt = 1;
char buffer[BUFFER_SIZE] = {0};

// 1. 创建 Socket
if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
perror(“socket failed”);
exit(EXIT_FAILURE);
}

// 2. 设置选项（允许端口复用）
if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {
perror(“setsockopt”);
exit(EXIT_FAILURE);
}

address.sin_family = AF_INET;
address.sin_addr.s_addr = INADDR_ANY;
address.sin_port = htons(PORT);

// 3. 绑定地址
if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) { perror("bind failed"); exit(EXIT_FAILURE); } // 4. 监听 if (listen(server_fd, 3) < 0) { perror("listen"); exit(EXIT_FAILURE); } printf("服务器监听端口：%d\n", PORT); // 5. 接受连接 socklen_t len = sizeof(address); if ((client_fd = accept(server_fd, (struct sockaddr *)&address, &len)) < 0) { perror("accept"); exit(EXIT_FAILURE); } // 6. 收发数据 read(client_fd, buffer, BUFFER_SIZE); printf("收到：%s\n", buffer); const char *response = "Hello from server"; write(client_fd, response, strlen(response)); close(client_fd); close(server_fd); return 0; } ```