教程 Python - 使用 Websockets 进行文件传输

通过这个全面的教程，了解如何在 Python 中使用 WebSockets 传输文件。高效简化数据交换，实现实时通信。

Equipment list

Here you can find the list of equipment used to create this tutorial.

Equipment list

This link will also show the software list used to create this tutorial.

什么是 WebSocket？

WebSocket 是一种通信协议，它通过客户端和服务器之间的单个长期连接提供全双工通信通道。与传统的 HTTP 不同，WebSocket 允许实时、双向通信，从而实现交互式 Web 应用程序和高效的数据传输。它通常用于需要实时更新的应用程序，例如在线游戏、聊天应用程序和实时数据传输。

是否可以使用 WebSockets 发送文件？

是的，可以使用 WebSockets 发送文件。为此，需要将文件数据编码为适合传输的格式，例如 base64 或二进制数据。编码后，数据可以以较小的块形式发送，也可以通过 WebSocket 连接作为连续流发送。在接收端，数据被解码并重建为原始文件格式。这种方法允许高效、可靠地实时传输文件，使其成为需要交换各种类型数据（包括图像、文档和多媒体文件）的应用程序的理想选择。

为什么要使用 WebSockets 传输文件？

使用 WebSockets 传输文件具有多种优势，包括实时双向通信，无需频繁轮询即可实现无缝数据传输。 WebSocket 能够高效处理大型或频繁的数据传输，使其适用于需要即时数据更新的应用程序。

教程 Python – 使用 Websockets 进行文件传输

创建一个服务器脚本以使用 Websockets 接收文件传输。

Copy to Clipboard

下面是 Python Websockets 服务器脚本。

Copy to Clipboard

import asyncio
import websockets
import json

async def receive_file(websocket, path):
    # Receive data from the WebSocket connection
    data_received = await websocket.recv()
    # Convert received data to a Python dictionary from JSON format
    data_received = json.loads(data_received.replace("'", '"'))
    # Extract the filename to save from the received data
    filename_to_save = data_received["filename"]
    # Convert the content to bytes for writing to a file
    file_content = bytes(data_received["content"])
    # Write the content to a file with the specified filename
    with open(f"{filename_to_save}", 'wb') as file:
        file.write(file_content)

# Save the received data to a JSON file (commented out for now)
    # with open("mylog.json", 'w') as log_file:
    #     json.dump(data_received, log_file)

# Start the WebSocket server
start_server = websockets.serve(receive_file, '0.0.0.0', 8765)

# Run the event loop until the server is complete
asyncio.get_event_loop().run_until_complete(start_server)

# Run the event loop forever to keep the server running
asyncio.get_event_loop().run_forever()

在 TCP 端口 8765 上启动 Websockets 服务器。

Copy to Clipboard

创建一个客户端脚本以使用 Websockets 发送文件。

Copy to Clipboard

下面是 Python Websockets 客户端脚本。

Copy to Clipboard

import asyncio
import websockets
import json

async def send_file(websocket, filename, save_as):
    # Open the specified file for reading in binary mode
    with open(filename, 'rb') as file:
        # Read the content of the file as bytes
        file_content = file.read()
        # Create a dictionary with the filename and its content to send
        data_to_send = {"filename": save_as, "content": list(file_content)}
        # Convert the dictionary to a JSON string and send it via the WebSocket
        await websocket.send(json.dumps(data_to_send))

async def client(filename, save_as):
    # Establish a WebSocket connection to the specified address
    async with websockets.connect('ws://localhost:8765') as websocket:
        # Call the send_file function to send the specified file
        await send_file(websocket, filename, save_as)

# Define the filename and the save filename here
filename = "calc.exe"
#save_as = "c:\\tmp\\test1.txt"
save_as = "mycalc.exe"
# Run the client function to initiate the file sending process
asyncio.run(client(filename, save_as))

使用 Websockets 客户端脚本发送文件。

Copy to Clipboard

客户端脚本已连接到 localhost TCP 端口 8765。

在我们的示例中，我们发送了一个名为 CALC 的二进制文件，并将其保存为服务器上的 MYCALC。

结论

总之，利用 Python 的 WebSockets 的强大功能来促进实时、安全的文件传输。实现我们的数据传输脚本并对其进行更改以满足您的需求。

Python – 使用 Websockets 进行文件传输

Python – 使用 Websockets 进行文件传输

Equipment list

相关教程 – Python

什么是 WebSocket？

是否可以使用 WebSockets 发送文件？

为什么要使用 WebSockets 传输文件？

教程 Python – 使用 Websockets 进行文件传输

结论

Related Posts