XiaoMo/anyproxy
1
0
Fork 0
mirror of https://github.com/alibaba/anyproxy.git synced 2025-04-23 23:31:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

rewrite webServer using child_process

Browse Source
This commit is contained in:
加里 2014-09-18 17:42:01 +08:00
parent f5448677ac
commit 172b6ac455
3 changed files with 140 additions and 88 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@ -226,7 +226,7 @@ var options = {
rule : require("path/to/my/ruleModule.js"),
webPort : 8002, // port for web interface
socketPort : 8003, // internal port for web socket, replace this when it is conflict with your own service
webConfigPort : 8080 // internal port for web config(beta), replace this when it is conflict with your own service
webConfigPort : 8088 // internal port for web config(beta), replace this when it is conflict with your own service
};
new proxy.proxyServer(options);

111
proxy.js
View File

@ -21,12 +21,11 @@ var http = require('http'),
Recorder = require("./lib/Recorder"),
inherits = require("util").inherits,
util = require("./lib/util"),
entities = require("entities"),
express = require("express"),
path = require("path"),
juicer = require('juicer'),
events = require("events"),
WebSocketServer = require('ws').Server;
express = require("express"),
fork = require("child_process").fork;
GLOBAL.recorder = new Recorder();
@ -35,7 +34,7 @@ var T_TYPE_HTTP = 0,
DEFAULT_PORT = 8001,
DEFAULT_WEB_PORT = 8002,
DEFAULT_WEBSOCKET_PORT = 8003,
DEFAULT_CONFIG_PORT = 8080,
DEFAULT_CONFIG_PORT = 8088,
DEFAULT_HOST = "localhost",
DEFAULT_TYPE = T_TYPE_HTTP;
@ -55,10 +54,10 @@ if(fs.existsSync(process.cwd() + '/rule.js')){
//option.type : 'http'(default) or 'https'
//option.port : 8001(default)
//option.hostname : localhost(default)
//option.rule : ruleModule
//option.rule : ruleModule
//option.webPort : 8002(default)
//option.socketPort : 8003(default)
//option.webConfigPort : 8080(default)
//option.webConfigPort : 8088(default)
function proxyServer(option){
option = option || {};
@ -71,12 +70,6 @@ function proxyServer(option){
socketPort = option.socketPort || DEFAULT_WEBSOCKET_PORT, //port for websocket
proxyConfigPort = option.webConfigPort || DEFAULT_CONFIG_PORT; //port to ui config server
var portList = {
proxyWebPort : proxyWebPort,
socketPort : socketPort,
proxyConfigPort : proxyConfigPort
};
requestHandler.setRules(proxyRules); //TODO : optimize calling for set rule
self.httpProxyServer = null;
@ -113,8 +106,25 @@ function proxyServer(option){
//start web interface
function(callback){
var webServer = new proxyWebServer(portList);
var wss = webServer.wss;
//web interface
var child_webServer = fork(path.join(__dirname,"./webServer.js"),[proxyWebPort, socketPort , proxyConfigPort,requestHandler.getRuleSummary()]);
child_webServer.on("message",function(data){
if(data.type == "reqBody" && data.id){
child_webServer.send({
type : "body",
id : data.id,
body : GLOBAL.recorder.getBody(data.id)
})
}
});
GLOBAL.recorder.on("update",function(data){
child_webServer.send({
type: "update",
body: data
});
});
var configServer = new UIConfigServer(proxyConfigPort);
configServer.on("rule_changed",function() {
@ -225,79 +235,6 @@ function UIConfigServer(port){
inherits(UIConfigServer, events.EventEmitter);
function proxyWebServer(portList){
var self = this;
portList = portList || {};
port = portList.proxyWebPort || DEFAULT_WEB_PORT;
webSocketPort = portList.socketPort || DEFAULT_WEBSOCKET_PORT;
proxyConfigPort = portList.proxyConfigPort;
//web interface
var app = express();
app.use(function(req, res, next) {
res.setHeader("note", "THIS IS A REQUEST FROM ANYPROXY WEB INTERFACE");
return next();
});
app.get("/summary",function(req,res){
GLOBAL.recorder.getSummaryList(function(err,docs){
if(err){
res.end(err.toString());
}else{
res.json(docs.slice(docs.length -500));
}
});
});
app.get("/body",function(req,res){
var reqQuery = url.parse(req.url,true);
var id = reqQuery.query.id;
res.setHeader("Content-Type","text/html");
res.writeHead(200);
var body = GLOBAL.recorder.getBody(id);
res.end(entities.encodeHTML(body));
});
app.use(function(req,res,next){
var indexHTML = fs.readFileSync(__dirname + "/web/index.html",{encoding:"utf8"});
if(req.url == "/"){
res.setHeader("Content-Type", "text/html");
res.end(util.simpleRender(indexHTML, {
rule : requestHandler.getRuleSummary(),
webSocketPort : webSocketPort,
proxyConfigPort : proxyConfigPort
}));
}else{
next();
}
});
app.use(express.static(__dirname + '/web'));
app.listen(port);
var tipText = "web interface started at port " + port;
//web socket interface
var wss = new WebSocketServer({port: webSocketPort});
wss.on("connection",function(ws){});
wss.broadcast = function(data) {
for(var i in this.clients){
this.clients[i].send(data);
}
};
GLOBAL.recorder.on("update",function(data){
wss.broadcast( JSON.stringify(data) );
});
self.app = app;
self.wss = wss;
}
module.exports.proxyServer = proxyServer;
module.exports.generateRootCA = certMgr.generateRootCA;

115
webServer.js Normal file
View File

@ -0,0 +1,115 @@
// var process = require("child_process")
var express = require("express"),
url = require('url'),
fs = require("fs"),
util = require("./lib/util"),
events = require("events"),
inherits = require("util").inherits,
entities = require("entities"),
WebSocketServer = require('ws').Server;
function proxyWebServer(port,webSocketPort,proxyConfigPort,ruleSummary,recorder){
var self = this;
if(arguments.length < 3){
throw new Error("please assign ports");
}
//web interface
var app = express();
app.use(function(req, res, next) {
res.setHeader("note", "THIS IS A REQUEST FROM ANYPROXY WEB INTERFACE");
return next();
});
// app.get("/summary",function(req,res){
// recorder.getSummaryList(function(err,docs){
// if(err){
// res.end(err.toString());
// }else{
// res.json(docs.slice(docs.length -500));
// }
// });
// });
app.get("/body",function(req,res){
var reqQuery = url.parse(req.url,true);
var id = reqQuery.query.id;
res.setHeader("Content-Type","text/html");
res.writeHead(200);
fetchBody(id,function(body){
res.end(entities.encodeHTML(body));
});
});
app.use(function(req,res,next){
var indexHTML = fs.readFileSync(__dirname + "/web/index.html",{encoding:"utf8"});
if(req.url == "/"){
res.setHeader("Content-Type", "text/html");
res.end(util.simpleRender(indexHTML, {
rule : ruleSummary || "",
webSocketPort : webSocketPort,
proxyConfigPort : proxyConfigPort
}));
}else{
next();
}
});
app.use(express.static(__dirname + '/web'));
app.listen(port);
var tipText = "web interface started at port " + port;
//web socket interface
var wss = new WebSocketServer({port: webSocketPort});
wss.on("connection",function(ws){});
wss.broadcast = function(data) {
for(var i in this.clients){
this.clients[i].send(data);
}
};
self.on("update",function(data){
wss.broadcast( JSON.stringify(data) );
})
self.app = app;
self.wss = wss;
}
inherits(proxyWebServer, events.EventEmitter);
var param = process.argv.slice(2),
server = new proxyWebServer(param[0],param[1],param[2],param[3]),
cbMap = {}; // id body cb
process.on("message",function(data){
if(data.type == "update"){
server.emit("update",data.body);
}else if( data.type == "body"){
try{
var key = data.id + "";
cbMap[key].body = data.body;
cbMap[key].cb.call(null,data.body);
}catch(e){}
}
});
function fetchBody(id,cb){
var key = id + "";
if(cbMap[key]){
cb(cbMap[key].body);
}else{
cbMap[key] = {
cb : cb
};
process.send({type : "reqBody", id: id});
}
}