Python Asyncore отслеживать клиентов

Question

Я пишу простой сокет-сервер и хочу отслеживать состояние клиентов (аутентификация и прочее). Каждый раз, когда handle_read() вызывается, я ничего не знаю об этом конкретном клиенте. Это помогло бы, если бы я знал идентификатор клиента или что-то. Вот что у меня так далеко:

import asyncore
import socket

class EchoHandler(asyncore.dispatcher_with_send):

    def handle_read(self):
        data = self.recv(8192)
        self.send(data)

class EchoServer(asyncore.dispatcher):

    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.set_reuse_addr()
        self.bind((host, port))
        self.listen(5)

    def handle_accept(self):
        pair = self.accept()
        if pair is None:
            pass
        else:
            sock, addr = pair
            print 'Incoming connection from %s' % repr(addr)
            handler = EchoHandler(sock)

server = EchoServer('localhost', 8080)
asyncore.loop()

Answer 1

Вы знаете идентификатор клиента, когда получаете соединение от repr(addr), Возвращенный кортеж - это IP-адрес и уникальный номер этого клиента, который можно использовать, когда вы хотите отправить данные обратно этому клиенту. Если вы хотите сохранить список клиентов, вам следует рассмотреть словарь, в котором при получении входящего соединения хранятся данные этого клиента.

Если вы хотите, чтобы эта информация передавалась в функцию handle_read, ваш код выглядел бы примерно так:

class EchoHandler(asyncore.dispatcher_with_send):
    def setAddr(self, addr):
        self.addr = addr

    def handle_read(self):
        data = self.recv(8192)
        print '%s from %s' % (data, self.addr)
        self.send(data)

class EchoServer(asyncore.dispatcher):

    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.set_reuse_addr()
        self.bind((host, port))
        self.listen(5)

    def handle_accept(self):
        pair = self.accept()
        if pair is None:
            pass
        else:
            sock, addr = pair
            print 'Incoming connection from %s' % repr(addr)
            handler = EchoHandler(sock)
            handler.setAddr(addr) #Set the address of the sender in the EchoHandler

Просто отправьте адрес клиента в EchoHandler, и теперь вы знаете, откуда он. Надеюсь, что это помогает / работает!

Answer 2

Единственный "идентификатор", который вы можете получить непосредственно из сокетов, - это ссылка на сокет и адрес отправителя. Все остальное основано на данных, которые вы получаете - ваш клиент может, например, отправить свой идентификатор в качестве первых 16 байтов, все, что после этого будет данными. Это означает эффективную реализацию протокола, который соответствует вашим требованиям.

Более простым и лучшим решением для аутентификации и т. Д. Является использование некоторой библиотеки, такой как ssl в стандартной библиотеке Python. ssl библиотека предоставляет механизмы шифрования и аутентификации в форме, которую можно легко использовать с сокетами python. Если вам нужна безопасная аутентификация, я настоятельно рекомендую использовать существующие решения.