希望有人可以帮助解决这个问题:
def non_block_read(output):
fd = output.fileno()
fl = fcntl.fcntl(fd, fcntl.F_GETFL)
fcntl.fcntl(fd, fcntl.F_SETFL, fl | os.O_NONBLOCK)
try:
return output.read()
except:
return ''
def trace(stdout):
while True:
output = non_block_read(stdout).strip()
if output:
defaults.app.logger.info(output)
defaults.socketio.emit("traceroute", {"Data": output})
tracerouteHost = '127.0.0.1'
hops = data['hops'] if data['hops'] else 32
if re.match('^[a-zA-Z0-9.-]{2,200}$', data['host']):
tracerouteHost = data['host']
p = Popen(["traceroute", tracerouteHost, "-m", str(hops)], stdout=PIPE, stderr=PIPE)
thread = threading.Thread(target=trace, args=[p.stdout])
thread.daemon = True
thread.start()
问题是这个“似乎”可以工作,但是 traceroute 命令的所有输出都没有被捕获,只是其中的一部分。
我在网上找到了大部分内容,所以不完全理解。
基本上我正在努力做到这一点,所以我在后台运行了一个 traceroute 命令,当我从中获得输出时,我想将它从我的网络套接字(socketio)发送到浏览器。
但我不希望它阻止其他操作。
如果这对任何人有帮助,我正在使用 Python Flask/Gevent。