import base64
import threading
from socket import *
import time
def tcplink(car, addr):
#i=0
print("Connected to")
print(addr)
print("Waiting for SmartPhone connection...")
phserv = socket(AF_INET, SOCK_STREAM)
phserv.bind(('', 20000))
phserv.listen(5)
phone,ad_nu=phserv.accept()
print("Phone Connected")
car.settimeout(0.08)
phone.settimeout(0.08)
while True:
try:
ph_msg=phone.recv(10)
except:
ph_msg=None
try:
car_msg=car.recv(10)
except:
car_msg=None
if (ph_msg):
if (ph_msg==b'\xa0'):
car.settimeout(None)
car.send(b'\xa0')
a=car.recv(4)
size=int(a.decode())
fl=open('/home/wwwroot/default/nw.jpg','wb')
while size>0:
data = sock.recv(1024)
fl.write(data)
size=size-len(data)
time.sleep(0.02)
fl.close()
car.settimeout(0.06)
else:
print(ph_msg)
car.send(ph_msg)
if (car_msg):
print(car_msg)
phone.send(car_msg)
car.send(b'\x00')
s = socket(AF_INET, SOCK_STREAM)
s.bind(('', 19999))
s.listen(5)
while True:
sock, addr = s.accept()
t = threading.Thread(target=tcplink, args=(sock, addr))
t.start()
评论1