3

現在、Djangoを使用してサイトをセットアップしています。チャット機能を追加するためにGeventSocketioを追加しました。すでにサイトにかなりの数のユーザーがいて、そうする方法を見つけることができないので、私はそれを拡大縮小する必要があります。

https://github.com/abourget/gevent-socketio/tree/master/examples/django_chat/chatを試しました

私はGunicornとsocketio.sgunicorn.GeventSocketIOWorkerワーカークラスを使用しているので、最初はワーカー数を増やすことを考えました。残念ながら、これは断続的に失敗するようです。見つけたいくつかのソースからのredisを使用するように書き直し始め、各サーバーに1人のワーカーがいて、現在負荷分散されています。ただし、これには同じ問題があるようです。gevent socketioコード自体に、スケーリングできない問題があるかどうか疑問に思っています。

これが私が始めた方法です。これは単なる送信メッセージコードです。

def redis_client():
    """Get a redis client."""
    return Redis(settings.REDIS_HOST, settings.REDIS_PORT, settings.REDIS_DB)

class PubSub(object):
    """
    Very simple Pub/Sub pattern wrapper
    using simplified Redis Pub/Sub functionality.

    Usage (publisher)::

        import redis

        r = redis.Redis()

        q = PubSub(r, "channel")
        q.publish("test data")


    Usage (listener)::

        import redis

        r = redis.Redis()
        q = PubSub(r, "channel")

        def handler(data):
            print "Data received: %r" % data

        q.subscribe(handler)

    """
    def __init__(self, redis, channel="default"):
        self.redis = redis
        self.channel = channel

    def publish(self, data):
        self.redis.publish(self.channel, simplejson.dumps(data))

    def subscribe(self, handler):
        redis = self.redis.pubsub()
        redis.subscribe(self.channel)

        for data_raw in redis.listen():
            if data_raw['type'] != "message":
                continue

            data = simplejson.loads(data_raw["data"])
            handler(data)


from socketio.namespace import BaseNamespace
from socketio.sdjango import namespace
from supremo.utils import redis_client, PubSub
from gevent import Greenlet

@namespace('/chat')
class ChatNamespace(BaseNamespace):
    nicknames = []
    r = redis_client()
    q = PubSub(r, "channel")

    def initialize(self):
        # Setup redis listener
        def handler(data):
            self.emit('receive_message',data)

        greenlet = Greenlet.spawn(self.q.subscribe, handler)

    def on_submit_message(self,msg):
        self.q.publish(msg)
4

1 に答える 1

2

rc2の代わりにhttps://github.com/fcurella/django-push-demoとgevent-socketio0.3.5rc1のコードの一部を使用しましたが、現在、複数のワーカーと負荷分散で機能しています。

于 2013-03-28T09:20:14.573 に答える