我试图建立一个反向代理(扭曲)。反向代理侦听端口6000-6099,并将这些端口映射到不同的内部IP地址。与端口建立连接后,它应该进行一些预检查,例如在群集中启动虚拟机。

例:

PublicIP:6000 -> do pre-check -> forward traffic to InternalIP-1:6800
PublicIP:6001 -> do pre-check -> forward traffic to InternalIP-2:6800
...


我修改了一个发现here (section 'Proxies and reverse proxies')的示例。但是我无法正常工作。有人可以帮忙吗?

from twisted.web import proxy, http
from twisted.internet import reactor
from twisted.python import log
import sys
log.startLogging(sys.stdout)

machines = {}

class ProxyFactory(http.HTTPFactory):
    protocol = proxy.ReverseProxy

    def connectionMade(self):
        if not machines.has_key(self.request.port): # self.request.port?!
            # start new machine in cluster
            # machines[self.request.port] = new_machine_ip

        # reverse proxy to machines[self.request.port] on port 6800
        # return proxy.ReverseProxyResource(machines[self.request.port], 6800, '/')

for port in range(6000,6100):
    reactor.listenTCP(port, ProxyFactory())
reactor.run()


编辑:


如何获取当前请求的端口?
如何将流量传递到内部IP?

最佳答案

Twisted实际上为此目的内置了ReverseProxyResource,其中请求对象被传递给render方法。您可以对其进行扩展和修改以进行动态路由。

https://twistedmatrix.com/documents/current/api/twisted.web.proxy.ReverseProxyResource.html

simplest example is here,尽管您可以随意覆盖资源方法以执行您描述的那种检查。

在此示例中,Site是使用常规HTTP协议的工厂。

08-07 17:00