{"id":2814,"date":"2025-03-16T12:10:26","date_gmt":"2025-03-16T04:10:26","guid":{"rendered":"https:\/\/www.laixuexila.com\/?p=2814"},"modified":"2025-03-16T12:10:26","modified_gmt":"2025-03-16T04:10:26","slug":"python3-%e7%bd%91%e7%bb%9c%e7%bc%96%e7%a8%8b2%ef%bc%9aasyncio-%e5%bc%82%e6%ad%a5%e7%bd%91%e7%bb%9c%e7%bc%96%e7%a8%8b","status":"publish","type":"post","link":"https:\/\/www.laixuexila.com\/index.php\/2025\/03\/16\/python3-%e7%bd%91%e7%bb%9c%e7%bc%96%e7%a8%8b2%ef%bc%9aasyncio-%e5%bc%82%e6%ad%a5%e7%bd%91%e7%bb%9c%e7%bc%96%e7%a8%8b\/","title":{"rendered":"Python3 \u7f51\u7edc\u7f16\u7a0b2\uff1aasyncio \u5f02\u6b65\u7f51\u7edc\u7f16\u7a0b"},"content":{"rendered":"\n<p>Python \u63d0\u4f9b <code>asyncio<\/code> \u8fdb\u884c\u5f02\u6b65\u7f16\u7a0b\uff0c\u9002\u7528\u4e8e\u9ad8\u5e76\u53d1\u7f51\u7edc\u5e94\u7528\uff0c\u5982 <strong>\u804a\u5929\u670d\u52a1\u5668\u3001WebSocket \u670d\u52a1\u5668\u3001\u722c\u866b<\/strong> \u7b49\u3002<\/p>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\"><strong>2.1 <code>asyncio<\/code> \u57fa\u7840<\/strong><\/h2>\n\n\n\n<p>\u5728 <code>asyncio<\/code> \u4e2d\uff1a<\/p>\n\n\n\n<ul class=\"wp-block-list\">\n<li><strong><code>async def<\/code><\/strong> \u5b9a\u4e49\u5f02\u6b65\u51fd\u6570\u3002<\/li>\n\n\n\n<li><strong><code>await<\/code><\/strong> \u7528\u4e8e\u7b49\u5f85\u5f02\u6b65\u64cd\u4f5c\u3002<\/li>\n\n\n\n<li><strong><code>asyncio.run()<\/code><\/strong> \u8fd0\u884c\u4e3b\u4e8b\u4ef6\u5faa\u73af\u3002<\/li>\n<\/ul>\n\n\n\n<p>\u793a\u4f8b\uff1a<\/p>\n\n\n\n<pre class=\"wp-block-code\"><code>import asyncio\n\nasync def hello():\n    print(\"Hello, asyncio!\")\n    await asyncio.sleep(1)\n    print(\"Goodbye, asyncio!\")\n\nasyncio.run(hello())<\/code><\/pre>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\"><strong>2.2 <code>asyncio<\/code> TCP \u670d\u52a1\u5668<\/strong><\/h2>\n\n\n\n<p><code>asyncio<\/code> \u63d0\u4f9b <code>asyncio.start_server()<\/code> \u8f7b\u677e\u521b\u5efa TCP \u670d\u52a1\u5668\u3002<\/p>\n\n\n\n<h3 class=\"wp-block-heading\"><strong>2.2.1 <code>asyncio<\/code> TCP \u670d\u52a1\u5668<\/strong><\/h3>\n\n\n\n<pre class=\"wp-block-code\"><code>import asyncio\n\nasync def handle_client(reader, writer):\n    addr = writer.get_extra_info('peername')\n    print(f\"\u5ba2\u6237\u7aef {addr} \u8fde\u63a5\u6210\u529f\")\n\n    # \u8bfb\u53d6\u5ba2\u6237\u7aef\u6570\u636e\n    data = await reader.read(1024)\n    print(f\"\u6536\u5230\u6570\u636e\uff1a{data.decode()}\")\n\n    # \u53d1\u9001\u54cd\u5e94\n    writer.write(b\"Hello from asyncio server!\")\n    await writer.drain()  # \u786e\u4fdd\u6570\u636e\u53d1\u9001\u5b8c\u6210\n\n    writer.close()\n    await writer.wait_closed()\n\nasync def main():\n    server = await asyncio.start_server(handle_client, \"0.0.0.0\", 12345)\n    print(\"Asyncio TCP \u670d\u52a1\u5668\u5df2\u542f\u52a8\")\n\n    async with server:\n        await server.serve_forever()\n\nasyncio.run(main())<\/code><\/pre>\n\n\n\n<h3 class=\"wp-block-heading\"><strong>2.2.2 <code>asyncio<\/code> TCP \u5ba2\u6237\u7aef<\/strong><\/h3>\n\n\n\n<pre class=\"wp-block-code\"><code>import asyncio\n\nasync def tcp_client():\n    reader, writer = await asyncio.open_connection(\"127.0.0.1\", 12345)\n\n    # \u53d1\u9001\u6570\u636e\n    writer.write(b\"Hello Asyncio Server!\")\n    await writer.drain()\n\n    # \u63a5\u6536\u6570\u636e\n    data = await reader.read(1024)\n    print(f\"\u670d\u52a1\u5668\u54cd\u5e94\uff1a{data.decode()}\")\n\n    writer.close()\n    await writer.wait_closed()\n\nasyncio.run(tcp_client())<\/code><\/pre>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\"><strong>2.3 <code>asyncio<\/code> UDP \u670d\u52a1\u5668<\/strong><\/h2>\n\n\n\n<p>UDP \u9002\u7528\u4e8e\u9ad8\u541e\u5410\u3001\u4f4e\u5ef6\u8fdf\u7684\u573a\u666f\uff0c\u5982 <strong>\u5728\u7ebf\u6e38\u620f\u3001\u76f4\u64ad<\/strong>\u3002<\/p>\n\n\n\n<h3 class=\"wp-block-heading\"><strong>2.3.1 <code>asyncio<\/code> UDP \u670d\u52a1\u5668<\/strong><\/h3>\n\n\n\n<pre class=\"wp-block-code\"><code>import asyncio\n\nclass UDPServerProtocol:\n    def connection_made(self, transport):\n        self.transport = transport\n\n    def datagram_received(self, data, addr):\n        print(f\"\u6536\u5230\u6765\u81ea {addr} \u7684\u6570\u636e\uff1a{data.decode()}\")\n        self.transport.sendto(b\"Hello from asyncio UDP Server!\", addr)\n\nasync def main():\n    loop = asyncio.get_running_loop()\n    listen = await loop.create_datagram_endpoint(\n        lambda: UDPServerProtocol(),\n        local_addr=('0.0.0.0', 12345)\n    )\n    print(\"Asyncio UDP \u670d\u52a1\u5668\u5df2\u542f\u52a8\")\n    await asyncio.sleep(3600)  # \u8ba9\u670d\u52a1\u5668\u8fd0\u884c 1 \u5c0f\u65f6\n\nasyncio.run(main())<\/code><\/pre>\n\n\n\n<h3 class=\"wp-block-heading\"><strong>2.3.2 <code>asyncio<\/code> UDP \u5ba2\u6237\u7aef<\/strong><\/h3>\n\n\n\n<pre class=\"wp-block-code\"><code>import asyncio\n\nasync def udp_client():\n    loop = asyncio.get_running_loop()\n    transport, _ = await loop.create_datagram_endpoint(\n        lambda: asyncio.DatagramProtocol(),\n        remote_addr=(\"127.0.0.1\", 12345)\n    )\n\n    transport.sendto(b\"Hello Asyncio UDP Server!\")\n\nasyncio.run(udp_client())<\/code><\/pre>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<h2 class=\"wp-block-heading\"><strong>2.4 <code>asyncio<\/code> \u5e76\u53d1\u4efb\u52a1<\/strong><\/h2>\n\n\n\n<p>\u591a\u4e2a\u5f02\u6b65\u4efb\u52a1\u5e76\u884c\u6267\u884c\uff1a<\/p>\n\n\n\n<pre class=\"wp-block-code\"><code>import asyncio\n\nasync def task1():\n    await asyncio.sleep(1)\n    print(\"Task 1 \u5b8c\u6210\")\n\nasync def task2():\n    await asyncio.sleep(2)\n    print(\"Task 2 \u5b8c\u6210\")\n\nasync def main():\n    await asyncio.gather(task1(), task2())\n\nasyncio.run(main())<\/code><\/pre>\n\n\n\n<hr class=\"wp-block-separator has-alpha-channel-opacity\"\/>\n\n\n\n<p><strong>\u4e0b\u7bc7\u6587\u7ae0\u6df1\u5165 <code>requests<\/code>\u3001<code>http.server<\/code> \u8fdb\u884c HTTP \u7f51\u7edc\u7f16\u7a0b\uff0c\u5e76\u4ecb\u7ecd WebSocket\uff01<\/strong>\u8bf7\u5173\u6ce8\u4e0b\u7bc7\u6587\u7ae0\uff01<\/p>\n","protected":false},"excerpt":{"rendered":"<p>Python \u63d0\u4f9b asyncio \u8fdb\u884c\u5f02\u6b65\u7f16\u7a0b\uff0c\u9002\u7528\u4e8e\u9ad8\u5e76\u53d1\u7f51\u7edc\u5e94\u7528\uff0c\u5982 \u804a\u5929\u670d\u52a1\u5668\u3001WebSocket \u670d [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":2815,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[79],"tags":[],"class_list":["post-2814","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-python-3-"],"_links":{"self":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts\/2814","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/comments?post=2814"}],"version-history":[{"count":1,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts\/2814\/revisions"}],"predecessor-version":[{"id":2816,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/posts\/2814\/revisions\/2816"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/media\/2815"}],"wp:attachment":[{"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/media?parent=2814"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/categories?post=2814"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.laixuexila.com\/index.php\/wp-json\/wp\/v2\/tags?post=2814"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}