异步pika的连接池包装器
pooled-pika的Python项目详细描述
注意
现在只需支持扭曲连接
用法
示例：
# with connectionfrompikaimportURLParametersfrompooled_pikaimportPooledConnAMQP_PARAM=URLParameters('amqp://user:pwd@amqpserver')pooled_conn=PooledConn(AMQP_PARAM)d=pooled_conn.acquire()d.addCallbacks(_on_conn,_on_err_conn)# you will get a TwistedProtocolConnection objectd.addErrback(_on_err)d.addBoth(pooled_conn.release)# must release what acquired anyway
或：
# with channelfrompikaimportURLParametersfrompooled_pikaimportPooledConnAMQP_PARAM=URLParameters('amqp://user:pwd@amqpserver')pooled_conn=PooledConn(AMQP_PARAM)d=pooled_conn.acquire(channel=True)d.addCallbacks(_on_channel,_on_err_channel)# you will get a TwistedChannel objectd.addErrback(_on_err)d.addBoth(pooled_conn.release)# must release what acquired anyway
欢迎加入QQ群-->： 979659372
