Merge pull request Tencent#200 from tarotlwei/dev

feat(websocket): optimize report log

Author: huangyoukun

bin/proxy/http.proxy.js

@@ -200,10 +200,6 @@ function requestHandler(req, res) {
         // 发者模式清除缓存
         cleanCache();
     }
-    if (req.headers.connection === 'upgrade' && req.headers.upgrade === 'websocket') {
-        // websocket
-        return;
-    }
     res.flush = res.flush || empty;
     parseGet(req);  // 解析get参数
     doRoute(req, res); // HTTP路由

bin/proxy/websocket.js

@@ -34,6 +34,7 @@ function wsFiller(ws, req) {
     ws.logReportTimer = null;
     ws.__tempSend = ws.send;
     ws.reportIndex = 1;
+    ws.messageTriggerCount = 0;
 
     ws.send = function(message) {
         if (ws.readyState == WebSocket.OPEN) {
@@ -49,19 +50,26 @@ function wsFiller(ws, req) {
     ws.logKey = req.headers['sec-websocket-key'] || Math.random();
 }
 
+function emitReportLog(ws, type) {
+    ws.upgradeReq.emit(type);
+    ws.messageTriggerCount = 0;
+}
+
 function reportWebSocketLog(ws, isEnd) {
     // 这里触发log上报
     const logLength = logger.getTextLength();
     // 每次上报log时，先看下Log多不多，不多的话，延迟上报下
     clearTimeout(ws.logReportTimer);
     if (isEnd) {
-        ws.upgradeReq.emit('reportLog');
+        emitReportLog('reportLog');
     } else if (logLength > 30) {
         // 立即上报
-        ws.upgradeReq.emit('reportLogStream');
+        emitReportLog('reportLogStream');
+    } else if (ws.messageTriggerCount > 9) {
+        emitReportLog('reportLogStream');
     } else {
         ws.logReportTimer = setTimeout(function() {
-            ws.upgradeReq.emit('reportLogStream');
+            emitReportLog('reportLogStream');
         }, 5000);
     }
 }
@@ -186,6 +194,7 @@ function bind_listen(server) {
             };
 
             ws.on('message', function(message) {
+                ws.messageTriggerCount++;
                 logger.debug('server get message : ${message}', {
                     message
                 });