Python asyncio:关闭套接字并释放等待sock_read()
Python asyncio是Python标准库中用于编写异步代码的模块。它提供了一种基于协程的方式来处理并发任务，使得编写高效的异步程序变得更加简单和直观。
在使用Python asyncio进行网络编程时，关闭套接字并释放等待sock_read()的操作可以通过以下步骤完成：
- 首先，创建一个异步套接字对象，可以使用
asyncio.open_connection()函数来创建一个异步TCP连接。该函数返回一个StreamReader和一个StreamWriter对象，分别用于读取和写入数据。 - 在需要关闭套接字的时候，可以调用
StreamWriter.close()方法来关闭写入流。这将发送一个EOF信号给对端，表示不再发送数据。 - 接着，可以调用
StreamReader.read()方法来读取对端发送的数据。在读取完所有数据后，该方法将返回一个空字节串。 - 最后，可以调用
StreamWriter.close()方法来关闭读取流。这将触发StreamReader.read()方法返回一个空字节串，表示不再接收数据。
下面是一个示例代码，演示了如何关闭套接字并释放等待sock_read()的操作：
import asyncio
async def main():
reader, writer = await asyncio.open_connection('host', port)
# 关闭写入流
writer.close()
# 读取对端发送的数据
data = await reader.read()
# 关闭读取流
writer.close()
# 处理接收到的数据
process_data(data)
asyncio.run(main())在上述示例代码中，host和port分别表示对端的主机名和端口号。process_data()函数用于处理接收到的数据。
对于Python asyncio的更多详细信息和使用方法，可以参考腾讯云的相关文档和示例代码：
相关·内容
2回答
我试图对异步套接字服务器进行单元测试，并使用pytest-asyncio使pytest与异步代码库兼容。服务器一旦启动，总是要通过while循环发送回复，并且可能会花费大部分时间在client_loop()中等待传入的消息。问题是，在单元测试框架终止事件循环并发出此警告之前，无法取消此任务：
任务已被销毁，但仍未完成！
任务：<任务挂起的coro=< Server.new_client()完成，定义在/.path./server.py:16> wait_for=<未来待决cb=< TaskWakeupMethWrapper对象at 0x106d7cbe8>
浏览 1提问于2018-03-22得票数 2
回答已采纳
我是Python3的新手，正在使用asyncio。因此，我在以下服务器端代码中遇到了一种奇怪的行为：
import asyncio
@asyncio.coroutine
def handle_client(reader, writer):
print('Client connected.')
client_connected = True
while client_connected:
print('Waiting for client event.')
line = yield from reader
浏览 0提问于2015-04-24得票数 9
回答已采纳
1回答
最小演示示例：
import asyncio
async def main():
c1_reader, c1_writer = await asyncio.open_connection(host='google.com', port=80)
c1_socket = c1_writer.get_extra_info('socket')
c1_socket.close()
c2_reader, c2_writer = await asyncio.open_connection(host='google.com',
浏览 0提问于2019-07-25得票数 1
回答已采纳
1回答
我正在使用paramiko来启动ssh连接。看来，当运行我的脚本时，一旦建立了连接，它们就不会关闭。相反，在连接终止之前，需要直到TIME_WAIT运行完。据我所知，TIME_WAIT表示等待足够的时间过去，以确保远程TCP接收到其连接终止请求的确认。
这是我的代码：
#!/usr/local/bin/python2.7
import sys, os, string, threading
import paramiko
paramiko.util.log_to_file("paramiko.log")
cmd = "hostname"
outlock =
浏览 2提问于2016-02-24得票数 0
回答已采纳
我正在使用客户机/服务器套接字处理Python脚本。在寻找替代方案之后，我不确定我的解决方案是正确的还是最好的。
我读过这些帖子：
他们的解决方案对我不管用，但我有以下几点，我不确定这是正确的还是干净的。
try:
# See if client has disconnected.
try:
data = (await asyncio.wait_for(client_reader.readline(),timeout=0.01))
except ConnectionResetError, ConnectionAbortedError) as e:
break
浏览 2提问于2016-04-25得票数 5
回答已采纳
3回答
我在Python3.4中使用Asyncio，我将尝试解释我正在做什么，以及我(认为)是什么导致了这个问题。
一方面，我有一个具有阻塞操作的UDP连接框架，我从这个流中获取数据并创建json，然后以SSE格式传递给客户机。一切都很好。
我遇到的问题是，如果我什么都不做，客户端断开连接，我就无法让它正确地处理客户端断开连接，我将开始得到这个错误：
WARNING [selector_events:613] socket.send() raised exception.
由于循环仍然在运行，所以我一直在研究如何彻底地中断循环并触发.close()，但是我发现的例子遇到了问题，在线资源也不多。
一个实
浏览 22提问于2014-11-17得票数 7
回答已采纳
1回答
是否有某种编程模式使我能够检测异步事件循环何时处于空闲状态？假设我的执行路径以某种复杂的方式分支，比如使用asyncio.gather()，但是我知道每个分支最终都在等待一些空闲的协同线，例如套接字或子进程。假设我知道这些协同机制实际上永远不会产生，所以事件循环将执行它能够执行的任何python代码，但最终只会等待那些空闲的协同器。是否有一种可编程的方法来检测这样的状态并停止循环？
浏览 1提问于2017-11-18得票数 7
回答已采纳
1回答
我目前正在使用这个lib来对我设置的kafka服务器进行压力测试：
import kafka
import time
def test_kafka_server(n=1):
for i in range(0,n):
producer = kafka.producer.Producer('test',host='10.137.8.192')
message = kafka.message.Message(str(time.time()))
producer.send(message)
pro
浏览 1提问于2012-11-08得票数 5
回答已采纳
1回答
我在Fedora 26工作站上使用Python 3.6.2。
下面是一些剪贴簿代码，它演示了我的问题：
编辑:将Sam Hartman的建议添加到代码中。
import asyncio, json
from autobahn.asyncio.websocket import WebSocketClientProtocol, WebSocketClientFactory
class MyClientProtocol(WebSocketClientProtocol):
def onConnect(self, response):
print(response.peer)
浏览 2提问于2017-11-04得票数 2
在下面的例子中：
loop = asyncio.get_event_loop()
loop.create_task(client()) # Does no start until run_server ends
await server()
# await f()
..。对服务器的调用导致客户端被阻塞。特别是，它被卡在了
await loop.sock_accept(sock)
直到server()退出，client()才会启动。为什么？
用不同的异步函数替换await server()：
#await server()
await f(
浏览 3提问于2022-05-19得票数 1
回答已采纳
我有多个使用websocket的任务。我想检测websocket的连接关闭，然后重新连接websocket，如果它是真的话，我将通过一个名为break_task的变量进行连接关闭检测，在代码下面和我得到的错误异常下面(我使用python3.6)：
break_task = False
async def value_1():
global break_task
msg_dict = deepcopy(MESG)
async with websockets.connect('wss://api.xxxxx') as ws:
await ws
浏览 0提问于2018-05-23得票数 0
2回答
我使用asyncio事件循环，它是一种在Python3.x中执行异步/并发任务的方法。
在asyncio (异步/等待)或coroutines在上是否有任何等价的内容，只有线程？
注意事项
不是parallelism + concurrency (多处理)模式。
更新
下面是一个在Python中使用asyncio的异步事件循环，以获得更好的感觉：
import asyncio
import time
async def async_say(delay, msg):
await asyncio.sleep(delay)
print(msg)
async def main(
浏览 1提问于2018-11-11得票数 4
回答已采纳
我有一个关于StreamReader/StreamWriter的问题。
为了简化我的实际代码，就像下面的代码一样(它们可以运行)。运行服务器后，运行客户端来请求它。服务器不会读取任何数据。
服务器代码：
import asyncio
loop = asyncio.get_event_loop()
async def log(reader: asyncio.StreamReader, writer: asyncio.StreamWriter):
print("Wait read")
data = await reader.read(-1)
print
浏览 0提问于2018-11-02得票数 0
回答已采纳
我正在使用带有uvicorn的Django通道，我有以下类型的代码： async def connect(self):
"""Accept connect if user has been provided by middleware"""
self.user = self.scope.get('user')
if self.user:
await self.accept()
else:
await self.close() 基本上，如果在使用中间件之
浏览 66提问于2019-05-21得票数 3
2回答
在许多TCPIP和Web调优指南中，建议在获得错误“打开的文件太多”时增加文件描述符的最大数量。
但是，我在"lsof -i“的输出中看不到-i
有人知道TIME_WAIT使用文件描述符吗？或者不是
浏览 0提问于2010-09-10得票数 10
回溯
我正在从Python调用一个可执行文件，并且需要将一个变量传递给可执行文件。但是，可执行文件需要一个文件，不能从stdin读取。
在使用子流程模块时，我通过简单地调用可执行文件从/dev/stdin读取该可执行文件，避免了这个问题，方法是：
# with executable 'foo'
cmd = ['foo', '/dev/stdin']
input_variable = 'bar'
with subprocess.Popen(
cmd,
stdin=subprocess.PIPE,
stdou
浏览 4提问于2022-01-07得票数 5
回答已采纳
2回答
因此，我试图使用这个python库连接到一个资源。这个库使用python3.4，我已经安装并设置了3.4作为解释器来使用它(Im在Windows 7 btw上)。在执行clientGET.py文件时，我仍然会收到此错误消息。服务器文件也是如此。
C:\Python34\python.exe C:/Learning/PyCoap/aiocoap/clientGET.py
Traceback (most recent call last):
File "C:/Learning/PyCoap/aiocoap/clientGET.py", line 34, in <modul
浏览 21提问于2015-07-12得票数 1
回答已采纳
不确定这是否可以实现。我想从脚本中触发一个HTTP请求，而不是等待响应。相反，我想马上回来。
我试着做一些这样的事情：
#!/usr/bin/env python3
import asyncio
import aiohttp
async def fire():
await client.post('http://httpresponder.com/xyz')
async def main():
asyncio.ensure_future(fire())
if __name__ == '__main__':
loop = async
浏览 0提问于2018-09-26得票数 15
回答已采纳
在将客户端连接到服务器后，我无法解决错误问题。以下是Python 3.7.7的服务器代码： #!/usr/bin/env python3
# WS server example
import asyncio
import websockets
#======================================================================
#Register
#======================================================================
async def Register(w
浏览 272提问于2020-03-24得票数 0
我有一个小型服务器，编写如下：
async def handle_client(reader, writer):
request = (await reader.read()).decode('utf8') # should read until end of msg
print(request)
response = "thx"
writer.write(response.encode('utf8'))
await writer.drain()
writer.close()
loop = as
浏览 0提问于2020-12-11得票数 3
回答已采纳
2回答
程序连接到服务器，当连接被服务器关闭时，如果我试图重新连接它，它会说：socket.error: [Errno 9] Bad file descriptor。
如果我关闭客户端中的套接字，然后尝试重新连接，它会写为：socket.error: [Errno 106] Transport endpoint is already connected。
有没有办法在管道破裂后重新连接，而不创建新的套接字？
import socket
host = '127.0.0.1'
port = 1337
s = socket.socket(socket.AF_INET, socket.SOC
浏览 1提问于2011-09-20得票数 9
回答已采纳
考虑以下代码，如何在listen()中停止执行？在sock.close()被调用之后，它似乎挂起了。不产生例外情况。
#!/usr/bin/env python3.5
import asyncio, socket
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.bind(('localhost', 8080))
sock.listen()
sock.setblocking(0)
async def listen():
print('listen')
try:
浏览 8提问于2016-10-11得票数 0
回答已采纳
我一直在阅读read(2)的手册页，根据手册页，read(2)的返回值在出错时为-1，在EOF时为0，在读取的字节数时大于0。
如何判断客户端上的write(2)何时完成？
我这样问是因为我正在编写一个服务器和一个客户端来测试它，但是当我第一次读取(2)并循环检查更多时，读取(2)块并等待来自客户端的另一次写(2)(它不会到来，因为我的客户端只有一次写(2))。
如果我只是遗漏了一些简单的东西，有人可以指出它或给我一个好的参考资料吗？
浏览 0提问于2010-02-27得票数 1
回答已采纳
我正在用java swing编写一个应用程序，它使用套接字连接到python代理，通过套接字发送和接收数据并关闭
现在，当我尝试重新打开套接字时，它给出了错误，
我尝试在套接字关闭后检查套接字状态，但仍然存在以下问题
clientSocket //is my java socket,
clientSocket.isConnected() //returns true
clientSocket.isBound() //returs true
clientSocket.isClosed() //return true
有人可以帮助我吗?我如何确保我的套接字的状态？
浏览 2提问于2011-02-02得票数 1
2回答
这可能是错误的做法，所以请原谅我，但是当python以非telnet异常或非paramiko ( SSH )异常结束时，SSH或Telnet连接会自动关闭吗？另外，sys.exit()会关闭脚本使用的所有连接吗？
浏览 2提问于2015-10-08得票数 1
回答已采纳
我们有一个C#服务器，它使用套接字接收TCP消息。通常的流程是调用socket.Accept()，使用socket.BeginReceive()和socket.EndReceive()来接收消息，然后使用socket.Send()发送响应。这个很好用。
但是，当一次收到太多请求时，我们希望立即拒绝溢出，这样我们就不会淹没服务器。在Accept()之后直接关闭套接字是很容易的；但这不允许我们向客户端发送一条有意义的“太忙”消息。
我想做的只是简单地调用Accept()，然后调用Send()，而不接收传入的消息。我尝试过这样做，服务器声称发送我的数据，但是我的客户端只收到一个空的响应。我尝试过使用
浏览 3提问于2015-03-25得票数 3
回答已采纳
1回答
我试图以异步的方式在python3.5上使用原始套接字。
我找到了asyncore库，在那里我们可以使用原始套接字，但它似乎已经被弃用了，asyncio库是可行的。
然而，在阅读文档后，似乎asyncio并不支持原始套接字。
您是否知道其他库或其他实现此目标的方法？
浏览 7提问于2015-12-06得票数 2
2回答
在我开发的测试应用程序中，重用服务器套接字时遇到了一些问题。基本上，我有一个实现客户端和服务器端的程序。为了测试目的，我运行这个程序的两个实例，一个实例开始宿主，另一个实例连接。这是监听代码：
private void Listen_Click(object sender, EventArgs e)
{
try
{
server = new ConnectionWrapper();
HideControls();
alreadyReset = false;
int port = int.Parse(PortHos
浏览 2提问于2010-05-12得票数 4
回答已采纳
目前正在构建一个使用Node、Express和Socket.io运行Heroku Socket.io dyno的项目。该应用程序的前提相当简单:人们从客户端搜索项目(存储在引擎盖下，如下所示)：
['Item':'Coffee',
'Id':0247508725,
'Location': 'Baker Street']
并选择它们，然后将项键值推送到Node服务器并存储在列表中。该列表比其他客户端在“实时”中检索的要多。客户端都是内置的Swift iOS应用程序
我第一次用大约60个用户运
浏览 3提问于2016-09-10得票数 2
回答已采纳
3回答
我需要使用python将字符串发送到本地主机上的特定端口。
我可以在命令行上使用这样的套接字来实现这一点：
cat <text file containing string to send> | socat stdin tcp-connect:127.0.0.1:55559
我不想将socat命令作为子命令运行，所以我想知道如何使用python模块来实现这个功能。
我使用套接字的尝试失败了。下面是我使用的一个脚本，它没有达到预期的效果。
import socket
HOST, PORT = "127.0.0.1", 55559
jsonStr
浏览 8提问于2016-10-04得票数 5
回答已采纳
我有一些使用asyncio并启动“普通”连接的python代码片段：
loop = asyncio.get_event_loop()
coro = loop.create_connection(lambda: MyCustomClassProtocol(loop), sock=client_socket)
loop.run_until_complete(coro)
关键是，一旦发生了一些交换，我的普通连接切换到tls连接。按照传统的方式，人们会这样做：
ssl_sock = ssl.wrap_socket(client_socket, do_handshake_on_connect=False
浏览 2提问于2015-06-15得票数 4
回答已采纳
1回答
异步不通过tcp发送整个图像数据
、、、、
我正试图使用带有TCP协议的异步通信协议，从本地计算机向云中的计算机发送图像。有时我得到整个图像被发送，有时只有部分图像被发送。
客户端代码
import os
os.environ['PYTHONASYNCIODEBUG'] = '1'
import asyncio
import logging
logging.basicConfig(level=logging.ERROR)
async def tcp_echo_client(data, loop):
reader, writer = await asyncio.open_connection(&l
浏览 0提问于2018-06-11得票数 5
回答已采纳
2回答
所以用Java创建一个服务器端应用程序。
在关闭连接方面，我只是想知道如果我在读者之前关闭套接字会发生什么。
例如，服务器端
//imports
public static void main(String[] args) {
Socket socket = null;
try {
ServerSocket servsocket = new ServerSocket(8080);
socket = servsocket.accept();
//connection established
BufferedReader re
浏览 4提问于2017-06-01得票数 0
回答已采纳
1回答
我正在尝试在两个主机之间设置一个命令提示聊天。为了同时支持打字和打印，我使用了threading。将一台PC设置为服务器，代码如下：
def recvfun():
for i in range(5):
print c.recv(1024)
return
def sendfun():
for i in range(5):
c.send(raw_input())
return
s = socket.socket() # Create a socket object
host = socket.gethostname
浏览 0提问于2016-04-09得票数 0
回答已采纳
我正在尝试用shutDownGracefully()关闭我的UDT服务器(Netty4.0.5.Final)，然后在同一端口上重新打开它。不幸的是，我总是得到下面的套接字异常，尽管它会等到将来完成。我还添加了套接字选项SO_REUSEADDR。
这样做的正确方法是什么？
Exception in thread "main" com.barchart.udt.ExceptionUDT: UDT Error : 5011 : another socket is already listening on the same UDP port : listen0:listen [id:
浏览 1提问于2013-08-01得票数 0
我试图使用异步和Unix域套接字在Python中构建一个内存中的玩具Redis服务器。
我的最小示例只返回每个请求的值baz：
import asyncio
class RedisServer:
def __init__(self):
self.server_address = "/tmp/redis.sock"
async def handle_req(self, reader, writer):
await reader.readline()
writer.write(b"$3\r\nbaz\r\
浏览 2提问于2020-10-15得票数 2
回答已采纳
1回答
我正在尝试使用asyncio sock_recv异步接收数据。我从服务器以不同的速度将数据发送到两个不同的端口:每10ms数据X和每100ms数据Y。
当使用阻塞套接字recvfrom函数时，我会每隔100ms接收一次X和Y，因为它阻塞了Y的recvfrom，所以我尝试使用asyncio，这样在Y等待的时候，我会收到10个X和一个Y。
为此，我编写了这些函数：
async def recv_data(socket):
data = await loop.sock_recv(socket, 2048)
print(len(data))
async def main()
浏览 9提问于2019-11-29得票数 1
回答已采纳
我是python的新手，我已经被这个问题困扰了很长一段时间。
基本上，我正在制作的模块将在游戏中使用(使用模块pygame)，但是，我希望通过网络接收通过UDP发送的这些键，而不是使用Pygame模块接收从键盘按下的键。
我已经创建了一个模块，它将在一个单独的线程上侦听已定义的UDP端口，并在需要调用的任何地方返回要在游戏中使用的按键。
我写的代码工作了一段时间，但是当它非常慢的时候，然后一段时间后，我得到了以下错误消息：
Traceback (most recent call last):
File "game.py", line 164, in <module&g
浏览 3提问于2013-03-05得票数 2
回答已采纳
1回答
我最近一直在使用一些套接字，在使用侦听套接字编写一些单元测试用例时，我反复得到error: [Errno 98] Address already in use。
这是一些显示错误的示例代码。
import unittest
import socket
class TestUnit(unittest.TestCase):
def setUp(self):
self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.socket.bind((socket.gethostname(
浏览 2提问于2012-10-16得票数 2
回答已采纳
3回答
在我们的一个客户系统中，我们遇到了打开文件太多的错误，目前FD限制设置为最大值，并且这种情况每周发生一次。
在看到lsof和netstat o/p之后，我能够看到太多的Socket处于绑定状态(20K)。据我所知，这种状态是暂时的，我找不到它实际泄漏的地方。当我在heapDump中看到一个有界套接字时，我看到以下GC引用
>java.net.InetSocketAddress
>> sun.nio.ch.SocketChannelImpl
>>>sun.nio.ch.SocketAdaptor
>>>>java.net.S
浏览 1提问于2012-07-25得票数 1
1回答
我想通过本地网络套接字向C#服务器发送一些JSON中的小测试数据。它必须接近实时(最大)。5毫秒/圈)。服务器运行良好，处理传入数据时没有问题。
，我的问题是: Python端很好地完成了他的循环。但是经过几个循环(有时100圈，有时20.000圈，有时100.000圈)，它就结冰了！
然后在30-120秒之间运行，然后继续循环(应用程序被完全阻塞，甚至ALT+F4或Taskmanager也会而不是关闭应用程序，而它被阻塞)。
看起来，本地网络冻结了我的套接字，并且有一个I/O阻塞操作，整个python客户机都在等待这个I/O阻塞操作，直到它完成，然后继续。
如果您检查输出，有4倍相同的循环时
浏览 0提问于2018-07-11得票数 0
回答已采纳
我正在尝试创建一个独立的SCTP using客户端。我所使用的jar库是jdiameter 1.5.9.0-build538-快照和jdiameter 1.5.9.0-build538-快照。
但是，在127.0.0.1:55555 (org.mobicents.protocols.api.AssociationListener)中，无法为LocalPeer 'client.test.com‘创建服务器套接字。
它与TCP很好地工作。我试着调试，但找不出问题。请帮我这个忙。
浏览 5提问于2016-01-27得票数 1
1回答
我想知道如何在断开套接字后从网络接口解除绑定。
例如：
procedure Testing_TCPSocket;
var lsock:TTCPBlockSocket;
begin
lsock := TTCPBlockSocket.Create;
lsock.bind('192.168.1.33','1234');
lsock.connect('192.168.1.44','4321');
lsock.closesocket;
//how do you unbind here
l
浏览 1提问于2014-01-14得票数 0
1回答
SSL套接字释放和关闭
、、、、
对于SSL连接，从接收呼叫接收到的FD可以做什么？可以重复使用吗？
我真正想知道的是：
一旦我接受了一个连接，我就得到了FD。我使用SSL*创建一个SSL句柄( SSL_new )。使用FD将SSL_set_fd添加到此句柄。我用SSL_accept进行握手。现在，如果我在SSL*上调用SSL*，FD会关闭吗？那SSL_free呢？
如果上述问题的答案是否定的，那么我是否可以将FD与另一个SSL*一起使用？
为了确切地解释我想要什么，如果我们使用句柄SSL*从连接SSL*读取一些数据，那么我们可以释放或关闭SSL*，我们可以使用一个新的SSL*从FD读取其余的数据吗？
浏览 5提问于2014-01-17得票数 2
回答已采纳
1回答
当收到发送或接收错误时，我使用此代码重置套接字。
try {
socket.Shutdown(SocketShutdown.Both);
socket.Close();
socket.Dispose();
} catch(Exception) {
}
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socket.Connect(ep)
我想知道我是否可以跳过关机、关闭和处理，这样我就可以更快地重新连接？垃圾收集器最终会打电话给他们，对吧？
浏览 1提问于2017-09-25得票数 0
1回答
如何从服务器优雅地关闭套接字
、、、、
在服务器端，我试图优雅地关闭一个连接的套接字。我知道套接字上适当的事件顺序应该是：
使用optionloop/wait关闭套接字，直到套接字接收到0字节的套接字关闭为止。
我有几个问题：
如果从来不返回(0字节)，怎么办？如果我们试图关闭我在服务器上调用的forever?whenever套接字，客户端总是会收到“现有连接被远程主机强制关闭”的异常。如何通知客户端这个关闭的"gracefully"?on (服务器)，如果我使用异步Begin/EndReceive调用，每当我在套接字上调用close时，它总是在Begin/EndReceive线程上产生一个ObjectDispose
浏览 2提问于2011-10-21得票数 5
回答已采纳
我看到asyncio.to_thread()方法被添加到@python 3.9+中，它的描述说它在一个单独的线程上运行阻塞代码以立即运行。见下面的例子：
def blocking_io():
print(f"start blocking_io at {time.strftime('%X')}")
# Note that time.sleep() can be replaced with any blocking
# IO-bound operation, such as file operations.
time.sleep(1)
浏览 6提问于2020-12-16得票数 13
回答已采纳
我最近看到了一些类似这样的代码(当然，sock是一个套接字对象)：
sock.shutdown(socket.SHUT_RDWR)
sock.close()
在套接字上调用shutdown然后关闭它的目的到底是什么？如果有所不同，则此套接字用于非阻塞IO。
浏览 0提问于2009-01-03得票数 146
回答已采纳
1回答
我已经构建了一个代理服务器，它可以在多个节点之间实现平衡。我还让它可以在零停机的情况下重新装载。问题是，大多数节点都保持了活动连接，而我不知道如何处理这些连接。有时，服务器无法关闭不关闭的1或2个打开的连接。
我的第一个观点是在关机时设置一个超时，但这并不能保证每个连接都被正确终止。我想到了一个需要几分钟才能完成的下载。
有人能给我一些好的建议吗？
浏览 1提问于2014-09-18得票数 1
回答已采纳
我只是在摆弄sqlalchemy ORM功能 我能够让它在我的主应用程序上工作，但当我创建了一个单独的文件test.py来测试某些东西时，我一直收到事件循环关闭的错误： Exception ignored in: <function Connection.__del__ at 0x7f7041c07310>
Traceback (most recent call last):
File "/home/krypt/Documents/Projects/app/env/lib/python3.9/site-packages/aiomysql/connection.py&#
浏览 41提问于2021-06-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
