import socketserver
import os
def execCmd(cmd):
r = os.popen(cmd)
text = r.read()
r.close()
return text
# 自定義類來實(shí)現(xiàn)通信循環(huán)
class MyTCPHandler(socketserver.BaseRequestHandler):
# 必須寫入handle方法，建立鏈接時(shí)會(huì)自動(dòng)執(zhí)行handle方法
def handle(self):
while True:
try:
data = self.request.recv(1024)
if not data: break
print('->client:', data)
#os.system(data.decode('utf-8'))
macd = execCmd(data.decode('utf-8'))
self.request.send(macd.encode('utf-8'))
except ConnectionResetError:
break
self.request.close()
if __name__ == '__main__':
server = socketserver.ThreadingTCPServer(('127.0.0.1', 8080), MyTCPHandler)
server.serve_forever() # 鏈接循環(huán)