Python Socket编程：实现多连接、中文传输与SSH模拟详解

不晚

发布时间：2026-10-13| 3人浏览过

原创

本文详解Python Socket编程中如何处理多客户端并发连接、发送中文数据及模拟SSH命令执行。重点解析bytes类型与编码转换、Linux环境下多连接测试差异、recv/send缓冲区限制及文件上传实现，提供完整代码示例与注意事项。

一、前言

在前一篇文章中，我们了解了客户端如何通过Socket连接服务端并完成单次数据传输。那么，如何支持客户端多次发送数据？同时，服务端又该如何接收并处理来自多个客户端的连接请求呢？

二、发送中文信息

在Python 3环境中，Socket只能传输bytes类型的数据。由于bytes类型仅能表示0到225范围内的ASCII码值，无法直接表示中文字符，因此在需要发送中文内容时，必须对数据进行编码和解码处理。

客户端代码示例：

import socket
# 客户端
# 声明协议类型,同时生成socket对象
client = socket.socket()
#
client.connect(('localhost', 8888))
# python3 接收字节流数据
msg = input('>>:').strip()
client.send(msg.encode('utf-8')) # 先编码成utf-8格式
data = client.recv(1024) # 1024字节的数据
print(data)
print(data.decode())

服务端代码示例：

import socket
# 声明协议类型
server = socket.socket()
# 绑定本地网卡（多网卡选择），端口
server.bind(('localhost', 8888))
# 监听端口
server.listen() # 监听
# conn 就是客户端连接后，在服务器端为其生成的一个连接实例
# address 是客户端的 hostaddr,port
conn, address = server.accept()
print("进入等待时间....")
# 等待
# print(conn, address)
print("收到连接....")
# 接收数据
data_server = conn.recv(1024)
print('receive:', data_server.decode()) # 解码
# 返回一个值
conn.send(data_server)

三、Socket实现多个连接

本示例建议在Linux环境下进行测试。在Windows系统中测试时，若多个客户端同时运行（即同时执行多个socket_client.py程序），一旦其中一个客户端断开连接，服务端可能会报错。本示例使用的Linux环境Python版本为3.5。

示例代码如下：

客户端代码：

import socket
# 客户端
# 声明协议类型,同时生成socket对象
client = socket.socket()
#
client.connect(('localhost', 8888))
# python3 接收字节流数据
while True:
  msg = input('>>:').strip()
  if len(msg) == 0:   # 输入不能为空
    continue
  client.send(msg.encode('utf-8'))
  data = client.recv(1024) # 1024字节的数据
  print(data)
  print(data.decode())

注意：在示例中，如果输入为空（即len(msg)==0）是不允许的。如果不输入任何内容，Socket程序会默认等待用户输入，导致程序卡死。

服务端代码：

# -*- coding: UTF-8 -*-
import socket
# 声明协议类型
server = socket.socket()
# 绑定本地网卡（多网卡选择），端口
server.bind(('localhost', 8888))
# 监听端口
server.listen(5) # 监听
while True:
  conn, address = server.accept()
  print("进入等待时间....")
  while True:
    print("收到连接....")
    # 接收数据
    data_server = conn.recv(1024)
    if not data_server:  # 这里判断客户端断开的情况，不控制会无限循环
      print('client is lost...')
      break
    print('receive:', data_server.decode())
    # 返回一个值
    conn.send(data_server)

在Linux服务器上，我开启了6个客户端，每个客户端输入一次数据后即断开连接（此时服务端显示“client has lost...”）。服务端分别与这六个客户端建立连接并接收数据。

四、实现SSH功能

4.1 测试环境

服务端配置：IP地址为172.16.200.49，监听端口为('0.0.0.0', 8888)，操作系统为Linux。

客户端配置：本机Windows 10系统。

4.2 测试代码

服务端代码：

# -*- coding: UTF-8 -*-
import socket
import os
# 声明协议类型
server = socket.socket()
# 绑定本地网卡（多网卡选择），端口
server.bind(('0.0.0.0', 8888))
# 监听端口
server.listen() # 监听
while True:
  conn, address = server.accept()
  print("进入等待时间....")
  while True:
    print("收到连接....")
    # 接收数据
    data_server = conn.recv(1024)
    if not data_server:
      print('client is lost...')
      break
    res = os.popen("{}".format(data_server.decode())).read() # 将执行命令的结果存储返回
    # 返回结果
    conn.send(res.encode('utf-8'))

客户端代码：

# -*- coding: UTF-8 -*-
import socket
# 客户端
# 声明协议类型,同时生成socket对象
client = socket.socket()
#
client.connect(('172.16.200.49', 8888)) # 服务端ip和端口
# python3 接收字节流数据
while True:
  msg = input('>>:').strip()
  if len(msg) == 0:
    continue
  client.send(msg.encode('utf-8'))
  data = client.recv(1024) # 1024字节的数据
  print(data.decode())

运行结果如下：

注意：Socket中的recv()和send()函数在接收和发送数据时都有大小限制。如果一次发送的数据量过大，客户端无法一次性接收完毕，剩余数据会存储在缓存中。然而，下一次命令执行时，客户端接收到的可能仍是上一次未发送完的数据。

四、模拟FTP上传文件

当服务端运行在Linux环境中时，struct模块可能存在一些问题……目前该示例在Windows 10系统中可以正常运行。

服务端代码：

# -*- coding: UTF-8 -*-
import struct
import socket
class FtpServer(object):
  def __init__(self, host, port):
    self.host = host
    self.port = port
  def ftp_server(self):
    # 声明协议类型
    ftp_server = socket.socket()
    # 绑定本地网卡（多网卡选择），端口
    ftp_server.bind((self.host, self.port))
    # 监听端口
    ftp_server.listen() # 监听
    while True:
      print('等待...')
      conn, address = ftp_server.accept()
      while True:
        file_info = struct.calcsize('128sl')
        buf = conn.recv(file_info)
        if buf:
          file_name, file_size = struct.unpack('128sl', buf)
          # 使用strip()删除打包时附加的多余空字符
          file_new_name = file_name.decode().strip('\00')
          print('start receiving...')
          fw = open(file_new_name, 'wb')
          received_size = 0 # 接收文件的大小
          while not received_size == file_size:
            if file_size - received_size > 1024:
              r_data = conn.recv(1024)
              received_size += len(r_data)
            else:
              r_data = conn.recv(file_size - received_size)
              received_size = file_size
            fw.write(r_data)
          fw.close()
if __name__ == '__main__':
  server = FtpServer('localhost', 8888)
  server.ftp_server()

客户端代码：

# -*- coding: UTF-8 -*-
import socket
import os
import struct
class FtpClient(object):
  # 定义一个FtpClien类
  def __init__(self, host, port):
    self.host = host
    self.port = port
  def client_push(self):
    # 声明协议类型,同时生成socket对象
    ftp_client = socket.socket()
    # 连接服务端
    ftp_client.connect((self.host, self.port))
    while True:
      # 切换文件目录路径
      print("输入文件目录路径")
      pwd = input(">>:").strip()
      # 列出文件名称
      files_list = os.listdir('{}'.format(pwd))
      for i in files_list:
        print(i)
      file_name = input('输入上传的文件名:').strip()
      file_path = os.path.join(pwd, file_name)
      if os.path.isfile(file_path):
        file_info = struct.calcsize('128sl') # 定义打包规则
        f_head = struct.pack('128sl', file_name.encode('utf-8'), os.stat(file_path).st_size)
        ftp_client.send(f_head)
        fo = open(file_path, 'rb')
        while True:
          file_data = fo.read(1024)
          if not file_data:
            break
          ftp_client.send(file_data)
        fo.close()
        # 上传文件
        ftp_client.send(file_data)
# client.close()
if __name__ == '__main__':
  client = FtpClient('localhost', 8888)
  client.client_push()

运行结果：

在socket_server.py文件所在目录下，可以看到上传的文件。

总结

以上就是本文关于Python通过Socket实现多个连接并模拟SSH功能的详细教程，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站：Python入门之三角函数全解【收藏】、Python基础练习之用户登录实现代码分享、python好玩的项目—色情图片识别代码分享等。如有任何问题，欢迎随时留言，小编会及时回复大家。感谢朋友们对本站的支持！