rabbitmq 连接数量一直增加

Question

有木有close呢，怎么感觉这个是pythone

Answer 1

有close 用python写的监听代码
    channel.close()
    connection.close(

Answer 2

try:
    config = config()
    mq_server = config.getSignSection('mq_server')
    
    #连接mq信息
    host = mq_server['host']
    user = mq_server['user']
    port = int(mq_server['port'])
    password = mq_server['password']
    queue_name = mq_server['queue_name']    #监听mq
    credentials = pika.PlainCredentials(user, password)
    parameters = pika.ConnectionParameters(host,port,'/',credentials)
    connection = pika.BlockingConnection(parameters)
    channel = connection.channel()    #获取消息
    channel.basic_consume(callback, queue_name, no_ack=True)
    channel.start_consuming()    channel.close()
    connection.close()except Exception, e:
    print e

Answer 3

mysql 运行 show processlist  看看