2

私はこれに何時間も苦労してきました。サーバーがクライアントにのみメッセージを送信することを除いて、基本的なチャットに似た非常にシンプルなアプリです。私の問題の根本はメモリリークです。アプリをリファクタリングして、よりステートレスにしようとしました。このガイドに従って、メモリ リークを追跡しました。グラフの意味がよくわかりませんでした。後でもっと深く掘り下げるかもしれません。最初に、切断が発火していないことに気付きました。グリーンレットを殺すなどのクリーンアップが行われます。 切断が起動しないのはなぜですか? 誰かが私に洞察を与えることができれば、それは大歓迎です。

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()
4

1 に答える 1

3

recv_disconnect は、サーバーではなくユーザーによって起動されています。ユーザーを切断する (リンクまたはボタンを追加する) か、「beforeunload」や「unload」などのイベントを使用して呼び出す必要があります。どちらの状況でも、socket.disconnect() を呼び出す必要があります。

例：

$(window).on('beforeunload',function(){socket.disconnect();});

これが少しお役に立てば幸いです。

よろしくお願いします、

アンドレアス

于 2012-09-17T10:57:11.170 に答える