edicao dia 14 /2

ServidorOO.py

@@ -0,0 +1,154 @@
+#!/usr/bin/env python
+# encoding: utf-8
+
+from time import time, sleep
+import socket, os, threading
+
+#Classe onde ficam armazenadas as informações do usuário
+class user:
+    nome = None
+    telefone = 0
+    endereco = None
+    email = None
+    senha = None
+    socket = None
+
+    def __init__(self, nome, telefone, endereco, email, senha):
+        self.nome = nome
+        self.telefone = telefone
+        self.endereco = endereco
+        self.email = email
+        self.senha = senha
+
+    # Registrar usuário em clientes.txt
+    def arquivar_usuario(self):
+        f = open('clientes.txt','a') # Escreve as linhas a partir da útlima linha escrita
+        f.write(self.nome + ',' + self.telefone + ',' + self.endereco + ',' + self.email + ',' + self.senha+'\n')
+
+class controle_usuarios:
+    lista_usuario = []
+
+    def adc_usuario(self,usuario):
+        self.lista_usuario.append(usuario)
+
+    def imprime(self):
+        print 'Dentro do txt tem'
+        for i in self.lista_usuario:
+            print i.nome
+
+    def __init__(self):
+        print 'inicia controle de usuários'
+        try:  # Caso o arquivo 'clientes.txt' não exista, ele abre uma exceção de IOError e passa
+            f = open('clientes.txt')  # Abre o arquivo clientes
+            for linha in f:
+                linha = linha.split(',')
+                usuario = user(str(linha[0]), str(linha[1]), str(linha[2]), str(linha[3]),str(linha[4].strip()))
+                self.lista_usuario.append(usuario)
+            self.imprime()
+        except IOError:
+            pass
+    def checar_nome_existente(self,usuario):
+        resp=0
+        for i in self.lista_usuario:
+            if i.nome==usuario:
+                resp=0
+                break
+
+
+
+
+#Rotina para carregar usuários:
+def carregar_usuarios():
+    try: #Caso o arquivo 'clientes.txt' não exista, ele abre uma exceção de IOError e passa
+        f=open('clientes.txt') #Abre o arquivo clientes
+        for linha in f:
+            linha=linha.split(',')
+            globals()[linha[0]] = user(str(linha[0]), str(linha[1]), str(linha[2]), str(linha[3]), str(linha[4].strip()))
+    except IOError:
+        pass
+
+#Checar se o nome já foi cadastrado
+def checar_nome(usuario):
+    try:
+        if usuario == globals()[usuario].nome:
+            flag = 1
+    except KeyError: #Se o nome não tiver em clientes.txt
+        flag = 0
+    return flag
+
+#Servidor Thread
+def servidor(conn):
+    print 'Conectado por', addr, "\n"
+    global controle
+    while 1:
+        resp = conn.recv(1024)  # Cliente dizendo se quer cadastrar ou fazer login, com seus respectivos parâmetros
+        if not resp: break #Sai do loop caso valor seja nulo ou 0
+        a = resp.split(",") #Informações do usuário separados na lista 'a'
+        #print "Recebi"
+        if a[0] == 'Adiciona_usuario':
+            #print "entrei no if"
+            while 1: #Fica no loop para caso o nome seja repetido, ele tentar registrar novamente
+                flag = controle.checar_nome_existente(a[1]) #Checar se o nome já foi cadastrado
+                #print "Chequei nome"
+                if flag == 1: #Se o nome for repetido, ele manda uma resposta ao cliente
+                    conn.sendall('not_ok')
+                    sleep(1)
+                    conn.sendall('cl_usado')
+
+                else:
+                    nome = user(a[1],a[2],a[3],a[4],a[5]) # crio objeto 'nome' da classe usuário
+                    #print "criei objeto"
+                    nome.arquivar_usuario() # arquivo usuário em clientes.txt
+                    #print "arquivei usuario"
+                    conn.sendall('ok')
+                break
+
+        elif a[0] == 'Faz_login':
+            print 'Faz_loguin acionado'
+            while 1: #Fica no loop para caso a ele erre alguma coisa, tentar novamente
+            #Se o nome que ele digitou for igual ao nome e a senha
+            # forem iguais as que tenho no regsitro, ele faz o login
+               ## print "Entrei login"
+                try:
+                    nome1 = globals()[a[1]].nome #Como fazer a comparação direto?
+                    #print "nome1", nome1
+                    #print "nome2", a[1]
+                    senha1 = globals()[a[1]].senha
+                    #print "senha1", senha1
+                    #print "senha2", a[2]
+                    if (nome1 == a[1]) and (senha1 == a[2]):
+                        globals()[a[1]].socket = addr # Armazena o ip e a porta
+                        print "O socket do cliente foi armazenado:", globals()[a[1]].socket
+                        conn.sendall('ok')
+                    else:
+                        conn.sendall('not_ok')
+                except KeyError:
+                    print ('Usuário não existe')
+                    conn.sendall('not_ok')
+                    # Perguntar se mando essa mensagem para o cliente ou se é só para mandar
+                    # o not_ok
+            break  # sai do 1º while
+
+#Tenho que criar um segundo Thread para o leilao
+
+
+if __name__ == '__main__':  ###Programa principal
+
+    HOST = ''                 # Symbolic name meaning all available interfaces
+    PORT = 50000              # Arbitrary non-privileged port
+    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) #IPv4,tipo de socket (TCP)
+    s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) #forçar que o socket desaloque a porta quando fechar o código
+    s.bind((HOST, PORT)) #liga o socket com IP e porta
+
+    print "Servidor funcionado"
+    print "Esperando pelos clientes\n"
+    controle = controle_usuarios()  # carrega os usuarios que estavam no clientes.txt
+    clientes=0
+
+    while 1:
+        s.listen(1)
+        conn, addr = s.accept()  # Aceita uma conexão
+        clientes += 1
+        print "Número de clientes conectados", clientes
+        t = threading.Thread(target=servidor, args=(conn,))
+        t.start()