我需要创建接受多个命令的扭曲 SSH 服务器。但主要特点是服务器应该管理连接。更具体地说,如果持续时间超过 10 分钟(例如),则需要关闭打开的连接。或者如果已经有 10 个打开的连接,它不应该接受新连接。
事实上,我仍然无法完全理解所有这些领域、化身、协议(protocol)和门户等如何相互交互。而且我觉得非常缺乏文档。有几个例子,但没有任何关于每一步究竟发生了什么的评论。
无论如何,尝试和失败我能够将所需命令的执行添加到 twisted simple ssh server example .但是我完全不知道如何拒绝新连接或关闭现有连接或为新连接添加一些时间标志,可用于在达到时间限制时关闭连接。
任何帮助,将不胜感激。请善待我,我从未与 Twisted 合作过,实际上我是 python 的新手 :)
谢谢你。
p.s.对于可能的错误,我很抱歉,英语不是我的母语。
请您参考如下方法:
因此,主要问题是限制连接数。这实际上取决于您要使用的协议(protocol)。假设,您使用 LineOnlyReceiver作为基础协议(protocol)(Prototol 的其他继承者行为方式相同,但是,例如,AMP 的情况会有所不同):
from twisted.internet.protocol import ServerFactory
from twisted.protocols.basic import LineOnlyReceiver
class NoConnectionSlots(Exception):
message = "Sorry, bro. There are no free slots for you. Try again later."
class ExampleProtocol(LineOnlyReceiver):
def connectionMade(self):
try:
self.factory.client_connected(self)
except NoConnectionSlots as e:
self.sendLine("{:}\\n".format(unicode(e)))
self.transport.loseConnection()
def connectionLost(self, reason):
self.factory.client_left(self)
class ExampleServerFactory(ServerFactory):
protocol = ExampleProtocol
max_connections = 10
def __init__(self):
self._connections = []
def client_connected(self, connection):
if len(self._connections) < self.max_connections:
raise NoConnectionSlots()
self._connections.append(connection)
def client_left(self, connection):
try:
self._connections.remove(connection)
except ValueError as e:
pass # place for logging




