как реализовать комету через событие Gevent - PullRequest
Новая
       22

как реализовать комету через событие Gevent

0 голосов
/ 08 октября 2011

демо о том, как реализовать комету с помощью gevent + flask. 

#coding:utf-8
'''
Created on Aug 6, 2011

@author: Alan Yang
'''
import time
from gevent import monkey
monkey.patch_all()

from gevent.event import Event
from gevent.pywsgi import WSGIServer

from flask import Flask,request,render_template,jsonify

app = Flask('FlaskChat')
app.event = Event()
app.cache = []
app.cache_size = 12

@app.route('/')
def index():
    return render_template('index.html',messages=app.cache)

@app.route('/put',methods=['POST'])
def put_message():
    message = request.form.get('message','')
    app.cache.append('{0} - {1}'.format(time.strftime('%m-%d %X'),message.encode('utf-8')))
    if len(app.cache) >= app.cache_size:
        app.cache = app.cache[-1:-(app.cache_size):-1]
    app.event.set()
    app.event.clear()
    return 'OK'

@app.route('/poll',methods=['POST'])
def poll_message():
    app.event.wait()
    return jsonify(dict(data=[app.cache[-1]]))


if __name__ == '__main__':
    #app.run(debug=True)
    WSGIServer(('0.0.0.0',5000),app,log=None).serve_forever()

он использует класс событий gevent. если кто-либо опубликует сообщение, любой в чате будет получать сообщение.

что если я просто хочу, чтобы кто-то получил сообщение? я должен использовать gevent.event.AsyncResult? если да, то как это сделать?

1 Ответ

0 голосов
/ 08 октября 2011

Использовать gevent.queue.Queue .

Чтение из очереди удаляет сообщение, и, если имеется несколько читателей, каждое сообщение будет доставлено ровно одному из них (хотя оно и не определено, здесь нет случайности или справедливости, оно просто произвольно).

...