我正在编写一个简单的socket服务器,我想跟踪客户端的状态(身份验证等)。每次调用handle_read()时,我都不知道关于那个特定客户机的任何事情。如果我知道客户的ID什么的话会有帮助的。这是我到目前为止所知道的:
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()发布于 2012-05-16 00:45:56
当您收到来自repr(addr)的连接时,您确实知道客户端的ID。返回的元组是一个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,现在您就知道它来自哪里了。希望这对你有帮助/有用!
发布于 2012-05-16 00:45:31
您可以直接从套接字获得的唯一"id“是对套接字的引用和发送者的地址。其他一切都是基于你接收到的数据--例如,你的客户端可以发送它的id作为前16个字节,在这之后的任何东西都是数据。这意味着有效地实现满足您需求的协议。
更简单、更好的身份验证等解决方案是使用一些库,比如python标准库中的ssl。ssl库以一种易于与python套接字一起使用的形式提供了加密和身份验证机制。如果您有任何安全身份验证的需求,我强烈建议使用现有的解决方案。
https://stackoverflow.com/questions/10605083
复制相似问题