我正在尝试将下面的echo server IRC聊天终端转换为asyncio，但我不认为太多关于trio的信息，因为它是新的，但是这个到asyncio的翻译是什么？: data = await self.stream.receive_some(BUFSIZE)
print("echo_serverr}".for
浏览 51提问于2021-05-14得票数 0
2回答
我使用的是一个asyncio.Protocol服务器，其目的是客户端调用服务器，但在停止客户端循环之前等待服务器响应并返回数据。根据经验，使用loop.run_until_complete(coroutine)调用RuntimeError: Event loop is running.失败
在服务器的asyncio.sleep(n)方法中运行data_received()也没有任何效果。yield from asyncio.sleep(n)和data_received(
浏览 1提问于2014-09-05得票数 4
回答已采纳
我有大约200个ip控制的电源线，我需要连接到TCP套接字并控制它们。到目前为止，我可以连接到一个单一的电源，并控制它没有问题。我的问题在于如何连接、打乒乓球，以及在一个客户端中发送和接收所有200个命令。
我已经研究了，希望是详尽的，我能找到的最多的是指向或的指针-但只针对连接到单个服务器的多个客户端(而我需要相反的情况)。我真正需要的只是一个正确的方向。我可以为所有的200创建
浏览 0提问于2018-11-06得票数 0
我想使用asyncio协程而不是多线程来重新实现我的代码。:我知道有一些合适的异步网络库可以做到这一点。但我只想在这种情况下使用asyncio核心库，以便更好地理解它。def handle_client(client</
浏览 1提问于2018-01-30得票数 31
回答已采纳
() import asyncio
reader, writer = await asyncio.open_connection()
loop
浏览 3提问于2019-09-30得票数 0
回答已采纳
1回答
我不明白为什么server.py版本1允许客户机被键盘中断并重新启动，而server.py版本2不允许：import asyncio
loop.create_task(main())
lo
浏览 0提问于2018-06-05得票数 1
回答已采纳
1回答
有没有办法记住所有的客户端实例(例如，在字典中)，并按需向任何需要的客户端发送消息/通信？import asyncio
def connection_made(self, transportprint('Lost connection of {}'.format(self.peername))
loop
浏览 10提问于2020-07-08得票数 1
回答已采纳
我使用异步运行一个简单的服务器和一个客户端。服务器是一个简单的回显服务器，由客户端发送两个“特殊”命令，“退出”和"timer"。退出命令关闭连接，timer命令启动一个计时器，该定时器将每秒钟在控制台(服务器和客户端)中打印一条消息。当客户端发送“退出”命令时，定时器将停止。 await asyncio.sleep(1)
async def handle
浏览 3提问于2022-11-10得票数 1
回答已采纳
我是Python3的新手，正在使用asyncio。因此，我在以下服务器端代码中遇到了一种奇怪的行为：
def handle_client(reader, writer):client_connected = False
asyncio.async(asy
浏览 0提问于2015-04-24得票数 9
回答已采纳
我正在开发Python服务器/客户端应用程序，其中服务器从客户端接收一些数据，并根据这些数据从嵌入式k/v存储中收集字典列表并将其流式传输回来。我在这里放了一个重现错误的代码。这就是为什么我把所有东西都放在服务器端的单独函数中(客户端发送不同的请求)的原因。 问题是服务器发送的速度比客户端可以使用的速度快，客户端一次读取几个响应，有时只是消息的一部分被截断。写/排出也会重载套接字，一旦读取了多个结果，客户
浏览 6提问于2020-07-20得票数 0
回答已采纳
我们试图使用异步运行一个简单的客户机/服务器。该服务器是一个回显服务器，具有客户端发送的两个可能的命令，即“退出”和"timer"。timer 命令启动一个计时器，它每秒钟(在服务器和客户端)在控制台中打印一条消息，退出命令关闭连接。当我们运行服务器和客户端，并启动定时器时，定时器的结果不会发送给客户机。:
'''Handle the echo protocol# This calla
浏览 18提问于2022-11-16得票数 0
回答已采纳
我想用python中的asyncio.start_server在一个套接字中侦听ipv4和ipv6，现在我给这个函数一个元组，但实际上它使用2个套接字来侦听。我的朋友告诉我用C语言可以在一个套接字中监听ipv4和ipv6，我应该如何处理python异步 #logging.info('start holosocket= config['
浏览 54提问于2017-08-28得票数 0
我一直试图用下面的代码在多进程模式下使用aiomysql运行龙卷风def get_mysql_connection(loop): server = tornado.httpserver.HTTPServer(app)
server.listen(options.portrun in multiple processes: IOLoop instance h
浏览 3提问于2017-03-13得票数 1
回答已采纳
1回答
我有一个类，它包含一个函数，我想通过调用一个烧瓶响应的端点来调用这个函数。是否有一种方法可以定义等待/订阅要调用的这个端点的异步函数？我只能使用基本的Anaconda3.7库，并且没有安装或可用的任何附加消息代理。(process_signal) # do stuff with signal
对于上下文来说，这不是这个过程的主要目标。我只想能够使用它远程地告诉我的进程，或者通过UI关闭工作进程，不管是优雅的还是强制的。我想
浏览 1提问于2020-10-28得票数 0
1回答
= asyncio.new_event_loop() def get_instance():我需要在自己的线程中运行的两个服务器并行处理请求如何
浏览 0提问于2018-11-04得票数 2
回答已采纳
使用asyncio，可以在超时的情况下执行协程，这样在超时之后它就会被取消：def coro():loop.run_until_complete(asyncio.wait_for(coro(), 5))@asyncio.coro
浏览 2提问于2015-02-19得票数 10
回答已采纳
是否可以在等待asyncio.sleep时更新对象的状态(即成员变量的值)？ await server.serve_forever()
client.py
import asyncio_cnt
浏览 5提问于2021-04-28得票数 0
回答已采纳
1回答
，谢谢# Código baseado em https://docs.python.org/3.6/library/asyncio-stream.html#tcp-echo-client-using-streamsasyncio.get_event_loop()
loop.run_until_complete(tcp_echo_client())run_
浏览 0提问于2018-10-13得票数 1
我得到了一个处理websockets工作的基本脚本(表A)。此脚本在等待输入时锁定，这不是我想要的。我设想的解决方案是，我可以启动两个异步任务-一个处理输入，另一个处理输出-并在一个次要事件循环中启动它们。我不得不做一些关于协同机制的研究，我想出了表B作为在事件循环中同时运行两件事情的概念的证明。现在，我所坚持的是表C。当我试图在websockets包的实际场景中使用它时，我发现websocket.
浏览 3提问于2016-06-06得票数 7
我有一个看似简单的任务，但我不能完全理解它。这是我需要做的。使用套接字模块，启动服务器，使用客户端启动连接，停止服务器，返回连接数据-所有这些都在一个脚本中。当我从两个终端运行这两个脚本时，我可以做到这一点，但我需要将服务器和客户端代码都放在一个脚本中，以便实现自动化。我的问题是socket.accept()是一个阻塞调用，并且脚本在我可以调用客户端之前挂起。已尝试使用socket.setblocking(False)，但它仍然阻塞。我直觉上觉得我可以用asyncio模
浏览 1提问于2019-06-03得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
腾讯会议活动推荐
腾讯云开发者
