Python Gevent SocketIO утечка памяти отключение не срабатывает
Я боролся с этим в течение нескольких часов сейчас. Это довольно простое приложение, похожее на обычный чат, за исключением того, что сервер отправляет сообщения только клиентам. В основе моей проблемы лежит утечка памяти. Я попытался перефакторизировать приложение, чтобы оно было более безгосударственным. Я следовал этому руководству для отслеживания утечек памяти. Я не мог разобраться в графиках. Позже я мог бы углубиться еще глубже. Во-первых, я заметил, что разъединение не стреляет, и это действительно делает некоторую очистку, такую как убить это. Почему разъединение не срабатывает? Если кто-нибудь может дать мне некоторое представление, это очень ценно.
Https://gist.github.com/a53d1acc83b06b16d263
from gevent import monkey; monkey.patch_all()
import gevent
import redis
import json
import phpserialize
from socketio import socketio_manage
from socketio.server import SocketIOServer
from socketio.namespace import BaseNamespace
from socketio.mixins import BroadcastMixin, RoomsMixin
r = redis.StrictRedis(host='localhost', port=6379)
class ShoutsNamespace(BaseNamespace):
def listener(self, room):
r = redis.StrictRedis()
r = r.pubsub()
r.subscribe(room)
for m in r.listen():
if m['type'] == 'message':
data = json.loads(m['data'])
self.emit("shouts", data)
def initialize(self):
print 'Connected'
def on_join(self, room):
self.emit("shouts", json.loads(r.hget('ffxi.shouts', room)))
self.spawn(self.listener, 'ffxi.shouts:'+room)
return True
def recv_disconnect(self):
print 'Disconnected'
self.disconnect(silent=True)
class PingNamespace(BaseNamespace):
def on_ping(self, message):
print message
class Application(object):
def __init__(self):
self.buffer = []
def __call__(self, environ, start_response):
path = environ['PATH_INFO'].strip('/')
if path.startswith('static/'):
try:
data = open(path).read()
except Exception:
return not_found(start_response)
if path.endswith(".js"):
content_type = "text/javascript"
elif path.endswith(".css"):
content_type = "text/css"
elif path.endswith(".swf"):
content_type = "application/x-shockwave-flash"
else:
content_type = "text/html"
start_response('200 OK', [('Content-Type', content_type)])
return [data]
if path.startswith("socket.io"):
socketio_manage(environ, {'/ping': PingNamespace, '/shouts': ShoutsNamespace })
else:
return not_found(start_response)
def not_found(start_response):
start_response('404 Not Found', [])
return ['<h1>Not Found</h1>']
if __name__ == '__main__':
SocketIOServer(('216.144.246.171', 443), Application(), resource="socket.io", policy_server=False, transports=['xhr-polling']).serve_forever()
1 ответ:
Recv_disconnect запускается пользователем, а не сервером. Либо вы должны заставить пользователя отключиться (добавив ссылку или кнопку?) или использовать такие события, как "beforeunload" или "разгрузить" ее назвать. В обеих ситуациях вам нужно будет вызвать сокет.разъединить().
Пример:
$(window).on('beforeunload',function(){socket.disconnect();});
Надеюсь, это немного помогло вам.
С наилучшими пожеланиями,
Андреас