Python怎么用socket进行网络编程_socket模块TCP/IP网络通信基础-Python教程-PHP中文网

Python怎么用socket进行网络编程_socket模块TCP/IP网络通信基础

冰火之心

发布： 2025-09-12 13:13:01

原创

595人浏览过

答案：Python使用socket模块进行网络编程，通过创建socket对象实现TCP/IP通信。客户端用connect连接服务器，发送和接收数据；服务器通过bind、listen和accept处理连接。可设置超时提升健壮性，使用多线程实现并发处理，通过消息头携带长度信息解决TCP粘包问题。

python怎么用socket进行网络编程_socket模块tcp/ip网络通信基础

Python使用socket进行网络编程，核心在于

socket

登录后复制

模块。它允许你创建网络连接，发送和接收数据，是构建TCP/IP网络应用的基础。简单来说，你用它来让你的程序“说话”并“听”到网络上的其他程序。

解决方案

首先，你需要导入

socket

登录后复制

模块：

import socket

登录后复制

然后，创建一个socket对象。你需要指定地址族（Address Family）和socket类型（Socket Type）。对于TCP/IP，通常使用

AF_INET

登录后复制

(IPv4) 和

SOCK_STREAM

登录后复制

(TCP):

立即学习“Python免费学习笔记（深入）”；

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

登录后复制

客户端通常需要连接到服务器：

server_address = ('localhost', 12345) # 服务器的地址和端口
s.connect(server_address)

try:
    message = b'This is the message.  It will be repeated.'
    print(f"sending {message}")
    s.sendall(message)

    amount_received = 0
    amount_expected = len(message)

    while amount_received < amount_expected:
        data = s.recv(16)
        amount_received += len(data)
        print(f"received {data}")

finally:
    print('closing socket')
    s.close()

登录后复制

服务器端则需要绑定到一个地址和端口，并监听连接：

import socket
import sys

# 创建一个TCP/IP socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 绑定socket到端口
server_address = ('localhost', 12345)
print(f'starting up on {server_address[0]} port {server_address[1]}')
sock.bind(server_address)

# 监听连接
sock.listen(1)

while True:
    # 等待连接
    print('waiting for a connection')
    connection, client_address = sock.accept()
    try:
        print(f'connection from {client_address}')

        # 接收数据并重新发送
        while True:
            data = connection.recv(16)
            print(f'received {data}')
            if data:
                print('sending data back to the client')
                connection.sendall(data)
            else:
                print(f'no data from {client_address}')
                break

    finally:
        # 清理连接
        connection.close()

登录后复制

这就是一个简单的TCP/IP socket编程的例子。客户端发送消息，服务器接收并返回。

socket编程涉及很多细节，比如错误处理、超时设置、非阻塞I/O等。这些可以根据你的具体需求进行调整。

socket模块支持UDP协议，只需将

SOCK_STREAM

登录后复制

改为

SOCK_DGRAM

登录后复制

即可。UDP是无连接的，所以不需要

connect

登录后复制

和

listen

登录后复制

，而是直接使用

sendto

登录后复制

和

recvfrom

登录后复制

发送和接收数据。

副标题1

Python socket编程中，如何处理连接超时？

在客户端，你可以在连接之前设置超时时间：

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.settimeout(5) # 设置超时时间为5秒
try:
    s.connect(server_address)
except socket.timeout:
    print("连接超时！")
except Exception as e:
    print(f"连接失败: {e}")
finally:
    s.close()

登录后复制

在服务器端，你可以在

accept

登录后复制

调用上设置超时，但这通常不是一个好主意，因为它会影响所有连接。更好的做法是在每个连接上单独处理超时，例如在接收数据时：

connection.settimeout(10) # 设置连接超时时间为10秒
try:
    data = connection.recv(16)
except socket.timeout:
    print("接收数据超时！")
except Exception as e:
    print(f"接收数据失败: {e}")

登录后复制

设置超时时间可以防止程序无限期地等待，提高程序的健壮性。

网易天音

网易出品！一站式音乐创作工具！零基础写歌！

查看详情

副标题2

如何使用Python socket实现多线程并发服务器？

并发服务器可以同时处理多个客户端连接。使用多线程是实现并发的一种常见方式。

import socket
import threading

def handle_client(connection, address):
    try:
        print(f'Connection from {address}')
        while True:
            data = connection.recv(1024)
            if data:
                print(f'Received {data} from {address}')
                connection.sendall(data) # Echo back to client
            else:
                print(f'No data from {address}')
                break
    finally:
        connection.close()

def server():
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_address = ('localhost', 12345)
    sock.bind(server_address)
    sock.listen(5)  # 允许最多5个排队的连接

    while True:
        connection, client_address = sock.accept()
        thread = threading.Thread(target=handle_client, args=(connection, client_address))
        thread.start()

if __name__ == "__main__":
    server()

登录后复制

在这个例子中，

handle_client

登录后复制

函数处理单个客户端连接，

server

登录后复制

函数接受新的连接，并为每个连接创建一个新的线程。这使得服务器可以同时处理多个客户端的请求。要注意线程安全问题，例如使用锁来保护共享资源。

副标题3

Python socket编程中，如何处理TCP粘包问题？

TCP是面向流的协议，数据像水流一样连续传输，没有明确的边界。这可能导致“粘包”问题，即多个小的数据包被合并成一个大的数据包发送，或者一个大的数据包被分成多个小的数据包发送。

解决粘包问题的常用方法是：

固定长度消息： 每个消息都使用固定长度，接收方读取固定长度的数据。如果实际数据长度小于固定长度，则需要填充。
消息头包含长度信息： 在每个消息的开头添加一个固定长度的消息头，其中包含消息体的长度。接收方首先读取消息头，获取消息体的长度，然后再读取相应长度的消息体。
使用特殊分隔符： 在消息的末尾添加一个特殊的分隔符，接收方通过查找分隔符来确定消息的边界。

下面是一个使用消息头包含长度信息的例子：

import struct

def send_msg(sock, msg):
    # 给消息添加长度前缀
    msg = struct.pack('>I', len(msg)) + msg
    sock.sendall(msg)

def recv_msg(sock):
    # 读取消息长度
    raw_msglen = recvall(sock, 4)
    if not raw_msglen:
        return None
    msglen = struct.unpack('>I', raw_msglen)[0]
    # 读取消息体
    return recvall(sock, msglen)

def recvall(sock, n):
    # 辅助函数，用于接收指定长度的数据
    data = bytearray()
    while len(data) < n:
        packet = sock.recv(n - len(data))
        if not packet:
            return None
        data.extend(packet)
    return data

# 示例用法
# send_msg(sock, b"This is my message")
# data = recv_msg(sock)
# print(data)

登录后复制

在这个例子中，