{"id":1030525,"date":"2024-12-31T11:17:45","date_gmt":"2024-12-31T03:17:45","guid":{"rendered":"https:\/\/docs.pingcode.com\/ask\/ask-ask\/1030525.html"},"modified":"2024-12-31T11:17:47","modified_gmt":"2024-12-31T03:17:47","slug":"%e5%a6%82%e4%bd%95%e5%9c%a8%e4%b8%8d%e5%90%8cpython%e8%84%9a%e6%9c%ac%e4%b9%8b%e9%97%b4%e8%bf%9b%e8%a1%8c%e9%80%9a%e4%bf%a1","status":"publish","type":"post","link":"https:\/\/docs.pingcode.com\/ask\/ask-ask\/1030525.html","title":{"rendered":"\u5982\u4f55\u5728\u4e0d\u540cpython\u811a\u672c\u4e4b\u95f4\u8fdb\u884c\u901a\u4fe1"},"content":{"rendered":"

\"\u5982\u4f55\u5728\u4e0d\u540cpython\u811a\u672c\u4e4b\u95f4\u8fdb\u884c\u901a\u4fe1\"<\/p>\n

\u5728\u4e0d\u540cPython\u811a\u672c\u4e4b\u95f4\u8fdb\u884c\u901a\u4fe1\u7684\u65b9\u5f0f\u6709\uff1a\u4f7f\u7528\u6587\u4ef6\u3001\u4f7f\u7528\u6570\u636e\u5e93\u3001\u4f7f\u7528\u6d88\u606f\u961f\u5217\u3001\u4f7f\u7528sockets\u3002<\/strong> \u5176\u4e2d\uff0c\u4f7f\u7528\u6d88\u606f\u961f\u5217\u662f\u4e00\u79cd\u9ad8\u6548\u4e14\u7075\u6d3b\u7684\u65b9\u5f0f\u3002\u6d88\u606f\u961f\u5217\u5141\u8bb8\u4e0d\u540c\u811a\u672c\u548c\u670d\u52a1\u4e4b\u95f4\u8fdb\u884c\u5f02\u6b65\u901a\u4fe1\uff0c\u786e\u4fdd\u6d88\u606f\u4e0d\u4f1a\u4e22\u5931\uff0c\u5e76\u4e14\u53ef\u4ee5\u5904\u7406\u9ad8\u5e76\u53d1\u7684\u901a\u4fe1\u9700\u6c42\u3002RabbitMQ\u548cKafka\u662f\u5e38\u7528\u7684\u6d88\u606f\u961f\u5217\u5de5\u5177\u3002<\/p>\n<\/p>\n

\u4e00\u3001\u4f7f\u7528\u6587\u4ef6<\/h3>\n<\/p>\n

\u6587\u4ef6\u662f\u4e00\u79cd\u7b80\u5355\u4e14\u5e38\u7528\u7684\u65b9\u5f0f\u6765\u5b9e\u73b0\u4e0d\u540cPython\u811a\u672c\u4e4b\u95f4\u7684\u901a\u4fe1\u3002\u4e00\u4e2a\u811a\u672c\u53ef\u4ee5\u5c06\u6570\u636e\u5199\u5165\u4e00\u4e2a\u6587\u4ef6\uff0c\u53e6\u4e00\u4e2a\u811a\u672c\u53ef\u4ee5\u8bfb\u53d6\u8be5\u6587\u4ef6\u4e2d\u7684\u6570\u636e\u8fdb\u884c\u5904\u7406\u3002<\/p>\n<\/p>\n

\u521b\u5efa\u5e76\u5199\u5165\u6587\u4ef6<\/h4>\n<\/p>\n

\u4f7f\u7528Python\u7684\u5185\u7f6e\u51fd\u6570\uff0c\u53ef\u4ee5\u8f7b\u677e\u5730\u521b\u5efa\u6587\u4ef6\u5e76\u5199\u5165\u6570\u636e\u3002\u4ee5\u4e0b\u662f\u4e00\u4e2a\u793a\u4f8b\uff1a<\/p>\n<\/p>\n

# script1.py<\/p>\n
data = "Hello from script1"<\/p>\n
with open('data.txt', 'w') as file:<\/p>\n
    file.write(data)<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u8bfb\u53d6\u6587\u4ef6<\/h4>\n<\/p>\n
\u53e6\u4e00\u4e2a\u811a\u672c\u53ef\u4ee5\u8bfb\u53d6\u6587\u4ef6\u4e2d\u7684\u6570\u636e\uff1a<\/p>\n<\/p>\n
# script2.py<\/p>\n
with open('data.txt', 'r') as file:<\/p>\n
    data = file.read()<\/p>\n
print(f"Received data: {data}")<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u5c3d\u7ba1\u8fd9\u79cd\u65b9\u6cd5\u7b80\u5355\u6613\u884c\uff0c\u4f46\u5b83\u7684\u6548\u7387\u8f83\u4f4e\uff0c\u4e0d\u9002\u7528\u4e8e\u9700\u8981\u9ad8\u9891\u7387\u901a\u4fe1\u7684\u573a\u666f\u3002<\/p>\n<\/p>\n
\u4e8c\u3001\u4f7f\u7528\u6570\u636e\u5e93<\/h3>\n<\/p>\n
\u6570\u636e\u5e93\u662f\u4e00\u79cd\u66f4\u52a0\u53ef\u9760\u548c\u6301\u4e45\u7684\u65b9\u6cd5\u6765\u5728\u4e0d\u540cPython\u811a\u672c\u4e4b\u95f4\u5171\u4eab\u6570\u636e\u3002\u5e38\u7528\u7684\u6570\u636e\u5e93\u6709MySQL\u3001PostgreSQL\u548cSQLite\u7b49\u3002<\/p>\n<\/p>\n
\u63d2\u5165\u6570\u636e<\/h4>\n<\/p>\n
\u4e00\u4e2a\u811a\u672c\u53ef\u4ee5\u5411\u6570\u636e\u5e93\u63d2\u5165\u6570\u636e\uff1a<\/p>\n<\/p>\n
# script1.py<\/p>\n
import sqlite3<\/p>\n
conn = sqlite3.connect('example.db')<\/p>\n
c = conn.cursor()<\/p>\n
c.execute('''CREATE TABLE IF NOT EXISTS data (message TEXT)''')<\/p>\n
c.execute("INSERT INTO data VALUES ('Hello from script1')")<\/p>\n
conn.commit()<\/p>\n
conn.close()<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u83b7\u53d6\u6570\u636e<\/h4>\n<\/p>\n
\u53e6\u4e00\u4e2a\u811a\u672c\u53ef\u4ee5\u4ece\u6570\u636e\u5e93\u4e2d\u8bfb\u53d6\u6570\u636e\uff1a<\/p>\n<\/p>\n
# script2.py<\/p>\n
import sqlite3<\/p>\n
conn = sqlite3.connect('example.db')<\/p>\n
c = conn.cursor()<\/p>\n
c.execute("SELECT message FROM data")<\/p>\n
data = c.fetchone()[0]<\/p>\n
print(f"Received data: {data}")<\/p>\n
conn.close()<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u4f7f\u7528\u6570\u636e\u5e93\u7684\u65b9\u6cd5\u9002\u7528\u4e8e\u9700\u8981\u6301\u4e45\u5316\u5b58\u50a8\u548c\u67e5\u8be2\u529f\u80fd\u7684\u573a\u666f\uff0c\u4f46\u9700\u8981\u66f4\u591a\u7684\u8bbe\u7f6e\u548c\u7ef4\u62a4\u3002<\/p>\n<\/p>\n
\u4e09\u3001\u4f7f\u7528\u6d88\u606f\u961f\u5217<\/h3>\n<\/p>\n
\u6d88\u606f\u961f\u5217\u662f\u4e00\u79cd\u9ad8\u6548\u7684\u65b9\u5f0f\u6765\u5b9e\u73b0\u4e0d\u540cPython\u811a\u672c\u4e4b\u95f4\u7684\u5f02\u6b65\u901a\u4fe1\u3002RabbitMQ\u548cKafka\u662f\u5e38\u7528\u7684\u6d88\u606f\u961f\u5217\u5de5\u5177\u3002<\/p>\n<\/p>\n
RabbitMQ\u793a\u4f8b<\/h4>\n<\/p>\n
RabbitMQ\u662f\u4e00\u4e2a\u5f00\u6e90\u7684\u6d88\u606f\u4ee3\u7406\u8f6f\u4ef6\uff0c\u53ef\u4ee5\u8f7b\u677e\u5b9e\u73b0\u4e0d\u540c\u811a\u672c\u4e4b\u95f4\u7684\u901a\u4fe1\u3002<\/p>\n<\/p>\n
\u5b89\u88c5pika\u5e93\uff1a<\/p>\n<\/p>\n
pip install pika<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u751f\u4ea7\u8005\u811a\u672c\uff1a<\/p>\n<\/p>\n
# producer.py<\/p>\n
import pika<\/p>\n
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))<\/p>\n
channel = connection.channel()<\/p>\n
channel.queue_declare(queue='hello')<\/p>\n
channel.basic_publish(exchange='',<\/p>\n
                      routing_key='hello',<\/p>\n
                      body='Hello from producer')<\/p>\n
print(" [x] Sent 'Hello from producer'")<\/p>\n
connection.close()<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u6d88\u8d39\u8005\u811a\u672c\uff1a<\/p>\n<\/p>\n
# consumer.py<\/p>\n
import pika<\/p>\n
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))<\/p>\n
channel = connection.channel()<\/p>\n
channel.queue_declare(queue='hello')<\/p>\n
def callback(ch, method, properties, body):<\/p>\n
    print(f" [x] Received {body}")<\/p>\n
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)<\/p>\n
print(' [*] WAI<\/a>ting for messages. To exit press CTRL+C')<\/p>\n
channel.start_consuming()<\/p>\n
<\/code><\/pre>\n<\/p>\n
Kafka\u793a\u4f8b<\/h4>\n<\/p>\n
Kafka\u662f\u53e6\u4e00\u4e2a\u5e7f\u6cdb\u4f7f\u7528\u7684\u6d88\u606f\u961f\u5217\u5de5\u5177\uff0c\u9002\u7528\u4e8e\u5904\u7406\u5927\u91cf\u6570\u636e\u7684\u573a\u666f\u3002<\/p>\n<\/p>\n
\u5b89\u88c5kafka-python\u5e93\uff1a<\/p>\n<\/p>\n
pip install kafka-python<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u751f\u4ea7\u8005\u811a\u672c\uff1a<\/p>\n<\/p>\n
# producer.py<\/p>\n
from kafka import KafkaProducer<\/p>\n
producer = KafkaProducer(bootstrap_servers='localhost:9092')<\/p>\n
producer.send('test-topic', b'Hello from producer')<\/p>\n
producer.flush()<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u6d88\u8d39\u8005\u811a\u672c\uff1a<\/p>\n<\/p>\n
# consumer.py<\/p>\n
from kafka import KafkaConsumer<\/p>\n
consumer = KafkaConsumer('test-topic', bootstrap_servers='localhost:9092')<\/p>\n
for message in consumer:<\/p>\n
    print(f"Received: {message.value}")<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u6d88\u606f\u961f\u5217\u65b9\u6cd5\u975e\u5e38\u9002\u5408\u9700\u8981\u9ad8\u5e76\u53d1\u548c\u5f02\u6b65\u901a\u4fe1\u7684\u573a\u666f\uff0c\u4f46\u9700\u8981\u66f4\u591a\u7684\u914d\u7f6e\u548c\u7ef4\u62a4\u3002<\/p>\n<\/p>\n
\u56db\u3001\u4f7f\u7528Sockets<\/h3>\n<\/p>\n
Sockets\u63d0\u4f9b\u4e86\u4e00\u4e2a\u7075\u6d3b\u7684\u65b9\u5f0f\u6765\u5b9e\u73b0\u5b9e\u65f6\u7684\u53cc\u5411\u901a\u4fe1\u3002\u53ef\u4ee5\u4f7f\u7528Python\u7684socket\u5e93\u6765\u521b\u5efa\u5ba2\u6237\u7aef\u548c\u670d\u52a1\u5668\u7aef\uff0c\u4ece\u800c\u5b9e\u73b0\u4e0d\u540c\u811a\u672c\u4e4b\u95f4\u7684\u901a\u4fe1\u3002<\/p>\n<\/p>\n
\u670d\u52a1\u5668\u7aef<\/h4>\n<\/p>\n
\u521b\u5efa\u4e00\u4e2a\u7b80\u5355\u7684\u670d\u52a1\u5668\u7aef\u811a\u672c\uff1a<\/p>\n<\/p>\n
# server.py<\/p>\n
import socket<\/p>\n
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)<\/p>\n
server_socket.bind(('localhost', 65432))<\/p>\n
server_socket.listen()<\/p>\n
print("Server is listening on port 65432")<\/p>\n
conn, addr = server_socket.accept()<\/p>\n
with conn:<\/p>\n
    print('Connected by', addr)<\/p>\n
    while True:<\/p>\n
        data = conn.recv(1024)<\/p>\n
        if not data:<\/p>\n
            break<\/p>\n
        print(f"Received: {data.decode()}")<\/p>\n
        conn.sendall(data)<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u5ba2\u6237\u7aef<\/h4>\n<\/p>\n
\u521b\u5efa\u4e00\u4e2a\u7b80\u5355\u7684\u5ba2\u6237\u7aef\u811a\u672c\uff1a<\/p>\n<\/p>\n
# client.py<\/p>\n
import socket<\/p>\n
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)<\/p>\n
client_socket.connect(('localhost', 65432))<\/p>\n
client_socket.sendall(b'Hello from client')<\/p>\n
data = client_socket.recv(1024)<\/p>\n
print(f"Received: {data.decode()}")<\/p>\n
client_socket.close()<\/p>\n
<\/code><\/pre>\n<\/p>\n
\u4f7f\u7528Sockets\u7684\u65b9\u6cd5\u9002\u7528\u4e8e\u9700\u8981\u5b9e\u65f6\u53cc\u5411\u901a\u4fe1\u7684\u573a\u666f\uff0c\u4f46\u5b9e\u73b0\u8d77\u6765\u76f8\u5bf9\u590d\u6742\u3002<\/p>\n<\/p>\n
\u603b\u7ed3<\/h3>\n<\/p>\n
\u5728\u4e0d\u540cPython\u811a\u672c\u4e4b\u95f4\u8fdb\u884c\u901a\u4fe1\u7684\u65b9\u5f0f\u6709\u591a\u79cd\u9009\u62e9\uff0c\u5177\u4f53\u9009\u62e9\u54ea\u79cd\u65b9\u5f0f\u53d6\u51b3\u4e8e\u5177\u4f53\u7684\u5e94\u7528\u573a\u666f\u548c\u9700\u6c42\u3002\u4f7f\u7528\u6587\u4ef6\u65b9\u6cd5\u7b80\u5355\u4f46\u6548\u7387\u4f4e\u3001\u4f7f\u7528\u6570\u636e\u5e93\u65b9\u6cd5\u53ef\u9760\u4f46\u9700\u8981\u66f4\u591a\u8bbe\u7f6e\u3001\u4f7f\u7528\u6d88\u606f\u961f\u5217\u65b9\u6cd5\u9ad8\u6548\u9002\u5408\u9ad8\u5e76\u53d1\u3001\u4f7f\u7528Sockets\u65b9\u6cd5\u7075\u6d3b\u9002\u5408\u5b9e\u65f6\u53cc\u5411\u901a\u4fe1\u3002<\/strong> \u5176\u4e2d\uff0c\u6d88\u606f\u961f\u5217\u662f\u4e00\u79cd\u9ad8\u6548\u4e14\u7075\u6d3b\u7684\u65b9\u5f0f\uff0c\u9002\u7528\u4e8e\u5927\u591a\u6570\u9700\u8981\u5f02\u6b65\u901a\u4fe1\u7684\u573a\u666f\u3002<\/p>\n<\/p>\n
\u76f8\u5173\u95ee\u7b54FAQs\uff1a<\/strong><\/h2>\n
 \u5982\u4f55\u5728\u4e0d\u540cPython\u811a\u672c\u4e4b\u95f4\u5171\u4eab\u6570\u636e\uff1f<\/strong>
\u6709\u591a\u79cd\u65b9\u6cd5\u53ef\u4ee5\u5728\u4e0d\u540c\u7684Python\u811a\u672c\u4e4b\u95f4\u5171\u4eab\u6570\u636e\uff0c\u5305\u62ec\u4f7f\u7528\u6587\u4ef6\u3001\u6570\u636e\u5e93\u3001\u6216\u7f51\u7edc\u901a\u4fe1\u3002\u6587\u4ef6\u5171\u4eab\u662f\u6700\u7b80\u5355\u7684\u65b9\u6cd5\uff0c\u53ef\u4ee5\u901a\u8fc7\u8bfb\u53d6\u548c\u5199\u5165\u6587\u672c\u6216\u4e8c\u8fdb\u5236\u6587\u4ef6\u5b9e\u73b0\u3002\u5bf9\u4e8e\u66f4\u590d\u6742\u7684\u9700\u6c42\uff0c\u4f7f\u7528SQLite\u6570\u636e\u5e93\u6216Redis\u7b49\u5185\u5b58\u6570\u636e\u5e93\u4e5f\u975e\u5e38\u6709\u6548\u3002\u7f51\u7edc\u901a\u4fe1\u65b9\u9762\uff0c\u53ef\u4ee5\u4f7f\u7528Socket\u7f16\u7a0b\u6216\u8005HTTP API\u6765\u5b9e\u73b0\u811a\u672c\u95f4\u7684\u6570\u636e\u4f20\u9012\u3002<\/p>\n
\u4f7f\u7528\u6d88\u606f\u961f\u5217\u6765\u5b9e\u73b0Python\u811a\u672c\u95f4\u7684\u901a\u4fe1\u6709\u54ea\u4e9b\u4f18\u52bf\uff1f<\/strong>
\u6d88\u606f\u961f\u5217\uff08\u5982RabbitMQ\u3001Kafka\u7b49\uff09\u5728\u5904\u7406\u5f02\u6b65\u4efb\u52a1\u65f6\u975e\u5e38\u6709\u6548\u3002\u5b83\u4eec\u5141\u8bb8\u4e0d\u540c\u7684\u811a\u672c\u4ee5\u975e\u963b\u585e\u7684\u65b9\u5f0f\u76f8\u4e92\u901a\u4fe1\uff0c\u9002\u5408\u4e8e\u9700\u8981\u9ad8\u5e76\u53d1\u6216\u590d\u6742\u5de5\u4f5c\u6d41\u7a0b\u7684\u573a\u666f\u3002\u6b64\u5916\uff0c\u6d88\u606f\u961f\u5217\u63d0\u4f9b\u4e86\u53ef\u9760\u6027\u548c\u6301\u4e45\u6027\uff0c\u786e\u4fdd\u5373\u4f7f\u5728\u7cfb\u7edf\u6545\u969c\u65f6\uff0c\u6d88\u606f\u4e5f\u4e0d\u4f1a\u4e22\u5931\u3002<\/p>\n
\u5728Python\u811a\u672c\u4e2d\u5982\u4f55\u5b9e\u73b0\u8fdc\u7a0b\u8fc7\u7a0b\u8c03\u7528\uff08RPC\uff09\uff1f<\/strong>
\u8fdc\u7a0b\u8fc7\u7a0b\u8c03\u7528\uff08RPC\uff09\u662f\u4e00\u79cd\u4f7f\u5f97\u4e0d\u540c\u811a\u672c\u80fd\u591f\u50cf\u8c03\u7528\u672c\u5730\u51fd\u6570\u4e00\u6837\u8fdb\u884c\u901a\u4fe1\u7684\u65b9\u5f0f\u3002\u53ef\u4ee5\u4f7f\u7528\u591a\u79cd\u5e93\u6765\u5b9e\u73b0RPC\uff0c\u4f8b\u5982Pyro4\u3001gRPC\u6216XML-RPC\u3002\u8fd9\u4e9b\u5e93\u901a\u8fc7\u5c01\u88c5\u7f51\u7edc\u901a\u4fe1\u7ec6\u8282\uff0c\u7b80\u5316\u4e86\u4e0d\u540c\u811a\u672c\u4e4b\u95f4\u7684\u4ea4\u4e92\uff0c\u4f7f\u5f97\u5f00\u53d1\u4eba\u5458\u53ef\u4ee5\u4e13\u6ce8\u4e8e\u4e1a\u52a1\u903b\u8f91\uff0c\u800c\u4e0d\u5fc5\u8fc7\u591a\u5173\u6ce8\u5e95\u5c42\u5b9e\u73b0\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"\u5728\u4e0d\u540cPython\u811a\u672c\u4e4b\u95f4\u8fdb\u884c\u901a\u4fe1\u7684\u65b9\u5f0f\u6709\uff1a\u4f7f\u7528\u6587\u4ef6\u3001\u4f7f\u7528\u6570\u636e\u5e93\u3001\u4f7f\u7528\u6d88\u606f\u961f\u5217\u3001\u4f7f\u7528sockets\u3002 \u5176\u4e2d\uff0c\u4f7f […]","protected":false},"author":3,"featured_media":1030528,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"footnotes":""},"categories":[37],"tags":[],"acf":[],"_links":{"self":[{"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/posts\/1030525"}],"collection":[{"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/comments?post=1030525"}],"version-history":[{"count":"1","href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/posts\/1030525\/revisions"}],"predecessor-version":[{"id":1030530,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/posts\/1030525\/revisions\/1030530"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/media\/1030528"}],"wp:attachment":[{"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/media?parent=1030525"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/categories?post=1030525"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/docs.pingcode.com\/wp-json\/wp\/v2\/tags?post=1030525"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}