Python 基础之网络 socket 使用 tcp （SOCK_STREAM）实现简单文件下载的客户端、服务端

左手的ㄟ右手 2022-10-29 01:55 390阅读 0赞

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70][]

# Python 基础 之 网络 socket 使用 tcp （SOCK\_STREAM）实现简单 文件下载 的 客户端、服务端 #

**目录**

Python 基础 之 网络 socket 使用 tcp （SOCK\_STREAM）实现简单 文件下载 的 客户端、服务端

一、简单介绍

二、实现原理

tcp\_client 客户端

tcp\_server 服务端

三、注意事项

四、效果预览

五、实现步骤

六、关键代码

--------------------

## 一、简单介绍 ##

Python是一种跨平台的计算机程序设计语言。是一种面向对象的动态类型语言，最初被设计用于编写自动化脚本(shell)，随着版本的不断更新和语言新功能的添加，越多被用于独立的、大型项目的开发。Python是一种解释型脚本语言，可以应用于以下领域： Web 和 Internet开发、科学计算和统计、人工智能、教育、桌面界面开发、软件开发、后端开发、网络爬虫。

本节简单介绍，使用 python 进行网络通讯的的案例，socket tcp 实现一个简单的文件下载的客户端和服务端。

## 二、实现原理 ##

### tcp\_client 客户端 ###

1、socket.socket(socket.AF\_INET, socket.SOCK\_STREAM) 创建套接字

2、socket.connect 连接服务器

3、socket.sendto 和 socket.recvfrom 发送和接收消息

4、获得数据 写入本地文件保存

### tcp\_server 服务端 ###

1、socket.socket(socket.AF\_INET, socket.SOCK\_STREAM) 创建套接字

2、socket.bind 绑定 ip 和 端口号

3、socket.listen 监听客户端

4、socket.accept 接入客户端

5、socket.sendto 和 socket.recvfrom 发送和接收消息

6、读取客户端请求的文件发送个客户端

## 三、注意事项 ##

1、如果 socket.bind 绑定ip和端口，会自动绑定本地ip和动态端口

2、注意发送带有中文等消息的时候，注意进行encode和decode

3、创建完 socket 最后记得关闭 socket.close

## 四、效果预览 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 1][]

## 五、实现步骤 ##

1、打开 pycharm 新建一个工程，即可新建一个python文件

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 2][]

2、编写脚本，实现使用 socket 实现文件下载的客户端和服务端代码逻辑

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 3][]

3、准备一个文件，测试文件下载

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 4][]

4、使用 cmd 运行服务端

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 5][]

5、pycharm 中运行 文件下载客户端，并连接服务端

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 6][]

6、客户端输入要下载的文件名称，下载文件成功如下

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 1][]

7、新文件内如和源文件一样，下载功能OK

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 7][]

## 六、关键代码 ##

1、tcp\_client\_file\_download.py

import socket
    
    
    def tcp_client_download_file():
        """
        使用 tcp 下载文件
        :return:
        """
    
        # 创建数据流套接字
        tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
        # 输入请求服务器的 ip 和 port
        server_ip = input("请输入下载服务器的 ip : ")
        server_port = int(input("请输入下载服务器的 ip : "))
    
        # 连接服务器
        tcp_socket.connect((server_ip, server_port))
    
        # 获取下载的文件名字
        download_filename = input("请输入下载文件名称 ： ")
    
        # 将文件名字发送到服务器
        tcp_socket.send(download_filename.encode('utf-8'))
    
        # 接收服务器发过来的数据
        recv_data = tcp_socket.recv(1024)
    
        if recv_data:
            # 保存数据，生成文件
            with open("new_"+download_filename,'wb') as f:
                f.write(recv_data)
                print("文件请求下载成功。")
                pass
        else:
            print("文件请求下载失败，服务端没有该文件：%s" % download_filename)
    
        # 关闭套接字
        tcp_socket.close()
        pass
    
    
    def main():
        tcp_client_download_file()
        pass
    
    
    if __name__ == "__main__":
        main()

2、tcp\_server\_file\_download.py

import socket
    
    
    def send_file_to_client(tcp_client_socket, tcp_client_addr):
        # 接收客户端请求的文件名
        filename = tcp_client_socket.recv(1024).decode('utf-8')
        print("客户端（%s）请求下载文件：%s" % (str(tcp_client_addr), str(filename)))
    
        file_content = None
        # 读取文件，发送给客户端
        try:
            f = open(filename, 'rb')
            file_content = f.read()
            f.close()
        except Exception as ret:
            print("服务端没有该文件：%s" % filename)
    
        # 发送给客户端
        if file_content:
            tcp_client_socket.send(file_content)
    
        pass
    
    
    def tcp_server_download_file():
        # 创建套接字
        tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    
        # 绑定 ip 和 port
        tcp_socket.bind(("", 5566))
        print("绑定 ip 和 port")
    
        # 监听客户端
        tcp_socket.listen(128)
        print("开始监听客户端……")
    
        # 等待接入客户端
        tcp_client_socket, tcp_client_addr = tcp_socket.accept()
        print("客户端接入……")
    
        # 发送客户端请求的文件
        send_file_to_client(tcp_client_socket, tcp_client_addr)
    
        # 关闭套接字
        tcp_client_socket.close()
        tcp_socket.close()
    
        pass
    
    
    def main():
        tcp_server_download_file()
        pass
    
    
    if __name__ == "__main__":
        main()

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 8][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70]: /images/20221024/d803a6d20165464e8cc8744efbd29b84.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 1]: /images/20221024/4e3ee43335764ab3992373aec5c41436.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 2]: /images/20221024/db6b4835c09046f3af722483b1b368bb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 3]: /images/20221024/9f8ea45bbee145999f1210f9b6a99561.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 4]: /images/20221024/b73363f39adc454890c8a815cf71c4fd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 5]: /images/20221024/70c027ccbc0b411e9324cb5d9b40ad8f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 6]: /images/20221024/0f4111f6431844e6bbb9ebd420361226.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 7]: /images/20221024/7a6a08067ee34e4aa6b7e83f35564e7c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTQzNjEyODA_size_16_color_FFFFFF_t_70 8]: /images/20221024/a3d0261cb2c9490197ae0177c1e772be.png