Новая версия работы с сетью.

main
none 9 months ago
parent 3e853ddb79
commit 826235676f

@ -26,16 +26,14 @@ def reverse_proxy():
elif name == "nt": elif name == "nt":
system(f"bore.exe local {port} --to jetwork.404.mn --port {dest}") system(f"bore.exe local {port} --to jetwork.404.mn --port {dest}")
'''
# Стартуем проброс порта # Стартуем проброс порта
rp = Thread(target = reverse_proxy) rp = Thread(target = reverse_proxy)
rp.start() rp.start()
sleep(0.5)
'''
print(f"\nВаш порт: {dest}") print(f"\nВаш порт: {dest}")
from network import * from network import *
#server(8001) #server(8000)
client(8001) pport = int(input())
client(pport, "is_t")

@ -30,56 +30,24 @@ def server(port = 8000):
break break
if op == "ping": if op == "ping":
conn.send("Pinged success".encode()) conn.send("pong".encode())
elif op[:3] == "is_":
check = op[3:]
if os.path.exists(f'cached/{check}'):
conn.send("exist".encode())
else:
conn.send("not exist".encode())
conn.close() conn.close()
'''
sock = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
sock.bind (('127.0.0.1', port))
while 1 :
data , addres = sock.recvfrom(1024)
#print (addres[0], addres[1])
op = data.decode('utf-8')
print(op)
if op == "ping":
sock.sendto("Pinged success".encode('utf-8'), addres)
elif op[:3] == "is_":
check = op[3:]
if os.path.exists(f'cached/{check}'):
sock.sendto("exist".encode('utf-8'), addres)
else:
sock.sendto("not exist".encode('utf-8'), addres)
else:
sock.sendto(data, addres)
'''
# op = operation # op = operation
def client(port, op = "ping"): def client(port, op = "ping"):
host = 'jetwork.404.mn' host = 'jetwork.404.mn'
s = socket.socket() s = socket.socket()
s.connect((host, port)) s.connect((host, port))
s.send("ping".encode()) s.send(op.encode())
data = s.recv(1024).decode() data = s.recv(1024).decode()
print('Received from server: ' + data) print('Received from server: ' + data)
s.close() s.close()
return data
'''
server = 'jetwork.404.mn', port
sor = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
sor.sendto((op).encode('utf-8'), server)
sor.settimeout(5)
# try:
if True:
data = sor.recv(1024)
res = data.decode('utf-8')
return res
# except:
# print(f"[:{dest_port}] Недоступен.")
# return None
'''

Loading…
Cancel
Save