Question

我想利用Redis pubsub的特征来实施,但是,如果我使用<代码>ps.listen(,那么即使客户接近浏览器,也会阻止。

绿色骑士团在启蒙进程时有一个时间特征,但我不知道如何将他们结合起来。

Flask s pseudo Code:

@app.route( / )
def comet():
    rc = redis.Redis()
    ps = rc.pubsub()
    ps.subscribe( foo )
    for item in ps.listen():
        if item[ type ] ==  message :
            return item[ data ]
    # ps.listen() will block, so how to make it timeout after 30 s?

Answer 1

由于你不读(我假定这是蓄意的,有时是明智的),你必须使用某种中断。信号是“团结”系统中断的一种类型,使你能够在可以阻挡的电话中回击。

公开档案的这个例子永远不会回过来,符合你想要做的事情。摘自

但警告。由于Adhury利用全球口译人员洛克来进行处理,因此它受到一些稳定问题的影响。这些问题通常很少。

import signal, os

def handler(signum, frame):
    print  Signal handler called with signal , signum
    raise IOError("Couldn t open device!")

# Set the signal handler and a 5-second alarm
signal.signal(signal.SIGALRM, handler)
signal.alarm(5)

# This open() may hang indefinitely
fd = os.open( /dev/ttyS0 , os.O_RDWR)

signal.alarm(0)          # Disable the alarm

Answer 2

p = redis.pubsub(
     ignore_subscribe_messages=True
)

p.subscribe(
    DB_PREFIX + CHANEL_KEY
)

message = None
timeout = 20
stop_time = time.time() + timeout

# little hack for setting get_message polling timeout
# because redis-py have bug and first call this method processed
# without timeout
while time.time() < stop_time:
    message = p.get_message(timeout=stop_time - time.time())
    if message:
        break

if message:
    data = json.loads(message["data"])
else:
    raise HTTPRequestTimeout

友情链接