2

我正在按照 Mitmproxy github示例中的建议运行代理：

from libmproxy import proxy, flow

class MitmProxy(flow.FlowMaster):
    def run(self):
        try:
            flow.FlowMaster.run(self)
        except KeyboardInterrupt:
            self.shutdown()

  
    def handle_request(self, r):
        f = flow.FlowMaster.handle_request(self, r)

        if f:
            r.reply()
        return f

    def handle_response(self, r):
        f = flow.FlowMaster.handle_response(self, r)
 
        if f:
            r.reply()
        return f



config = proxy.ProxyConfig(
    cacert = os.path.expanduser("~/.ssl/mitmproxy.pem")
)
state = flow.State()
server = proxy.ProxyServer(config, 8083)
m = MitmProxy(server, state)
try:
    m.run()
except Exception, e:
    print e.message
    m.shutdown()

我想在不阻塞其他请求/响应的情况下处理每个请求/响应，因为我需要使用并发装饰器和脚本

我的问题是：如何将脚本加载和卸载到在此配置中运行的代理？

4

2 回答 2

3

您可以在脚本加载中使用并发模式。
这是这种用法的示例

我更喜欢在流级别实现 mitmproxy 逻辑。
您可以使用此代码

def handle_response(self, r):
    reply = f.response.reply
        f.response.reply = controller.DummyReply()
        if hasattr(reply, "q"):
            f.response.reply.q = reply.q
        def run(): 
            pass
        threading.Thread(target=run)
于 2014-06-11T12:07:36.060 回答
0

您基本上必须复制 handle_concurrent_reply 在libmproxy.script中的工作方式

f = flow.FlowMaster.handle_request(self,r)
if f:
        def run():
           request.reply() #if you forget this you'll end up in a loop and never reply
threading.Thread(target=run).start()  #this will start run
于 2014-08-18T21:10:45.760 回答