mirror of
https://github.com/hastagAB/Awesome-Python-Scripts.git
synced 2024-10-05 20:39:28 +00:00
65 lines
1.8 KiB
Python
Executable File
65 lines
1.8 KiB
Python
Executable File
#!/bin/python
|
|
|
|
#CLIENTE
|
|
|
|
from simplecrypt import encrypt, decrypt #import da biblioteca para encriptar
|
|
|
|
import socket #import da biblioteca para o socket
|
|
import threading #import da biblioteca para thread
|
|
import time #import da biblioteca utilizada para fazer uma pausa com o sleep
|
|
|
|
tLock = threading.Lock() #cria threads para executar o programa
|
|
poweroff = False
|
|
|
|
def receving(name, sock):
|
|
while not poweroff:
|
|
try:
|
|
|
|
tLock.acquire() #faz o teste na thread, se o retorno é true ele \
|
|
#continua, se é false ele exibe um erro de timeout expired
|
|
while True:
|
|
data, addr = sock.recvfrom(2048)
|
|
#print (str(data.decode('utf-8')))
|
|
except:
|
|
pass
|
|
finally:
|
|
tLock.release() #se a thread está no estado travado ele destrava e \
|
|
#passa para a proxima thread, senão ele retorna um erro RunTimeError
|
|
|
|
#definição do IP do cliente
|
|
host = '127.0.0.1'
|
|
port = 0
|
|
|
|
#definição do servidor
|
|
server = ('127.0.0.1', 5000)
|
|
|
|
#criação do socket
|
|
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
|
|
s.bind((host, port))
|
|
s.setblocking(0)
|
|
rT = threading.Thread(target=receving, args=("RecvThread", s))
|
|
rT.start()
|
|
|
|
#definição do nome de usuário (apelido)
|
|
alias = input("Username: ")
|
|
time.sleep(0.2)
|
|
|
|
#criação da mensagem e envio para o server
|
|
message = input(alias + ">>> ")
|
|
while message != 'q':
|
|
cryptmsg = encrypt("Fatec123", message)
|
|
if message != "":
|
|
#s.sendto(str(alias + ": " + cryptmsg).encode('utf-8'), server)
|
|
s.sendto(cryptmsg, server)
|
|
print(cryptmsg)
|
|
tLock.acquire()
|
|
message = input(alias + ">>> ")
|
|
cryptmsg = encrypt("Fatec123", message)
|
|
tLock.release()
|
|
time.sleep(0.2)
|
|
|
|
#finaliza o socket e o programa
|
|
poweroff = True
|
|
rT.join()
|
|
s.close()
|