我试图建立一个反向代理(扭曲)。反向代理侦听端口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协议的工厂。