[Update] 使用eventlet, websocket支持

coco/app.py

@@ -218,9 +218,11 @@ class Coco:
                 self.run_httpd()
 
             signal.signal(signal.SIGTERM, lambda x, y: self.shutdown())
-            while self.stop_evt.wait(5):
+            while True:
+                if self.stop_evt.is_set():
                     print("Coco receive term signal, exit")
                     break
+                time.sleep(3)
         except KeyboardInterrupt:
             self.stop_evt.set()
             self.shutdown()

coco/httpd.py

@@ -4,6 +4,7 @@
 import os
 import socket
 import uuid
+import eventlet
 from flask_socketio import SocketIO, Namespace, join_room
 from flask import Flask, request, current_app, redirect
 
@@ -16,6 +17,8 @@ BASE_DIR = os.path.dirname(os.path.dirname(__file__))
 
 logger = get_logger(__file__)
 
+eventlet.monkey_patch()
+
 
 class BaseNamespace(Namespace):
     current_user = None
@@ -23,7 +26,7 @@ class BaseNamespace(Namespace):
     def on_connect(self):
         self.current_user = self.get_current_user()
         if self.current_user is None:
-            return redirect(current_app.config['LOGIN_URL'])
+            return redirect(self.socketio.config['LOGIN_URL'])
         logger.debug("{} connect websocket".format(self.current_user))
 
     def get_current_user(self):
@@ -236,8 +239,8 @@ class HttpServer:
         'LOGIN_URL': '/login'
     }
     init_kwargs = dict(
-        # async_mode="gevent",
-        async_mode="threading",
+        async_mode="eventlet",
+        # async_mode="threading",
         ping_timeout=20,
         ping_interval=10
     )

requirements/requirements.txt

@@ -41,3 +41,4 @@ tornado==4.5.2
 urllib3==1.22
 wcwidth==0.1.7
 Werkzeug==0.12.2
+eventlet==0.22