复制import redis,使用s实术 time  rc = redis.Redis()  def wait( wait_for ):   ps = rc.pubsub()   ps.subscribe( wait_for )   ps.get_message()   wait_msg = None   while True:   msg = ps.get_message()   if msg and msg[type] == message:   wait_msg = msg    break  time.sleep(0.001)   ps.close()   return wait_msg  def signal_broadcast( wait_in, data ):   wait_count = rc.publish(wait_in, data)   return wait_count  1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.

(责任编辑：系统运维)