小编BG *_*ian的帖子

我只是在学习rabbitMQ而且遇到了一个问题.

使用http://pecl.php.net/package/amqp 1.4版(现在最新版)和RabbitMQ 3.3.1版.我们必须使用php5-fpm和与amqp-> pconnect()的持久连接.

过了一会儿(我想65500个请求)会出现问题,停止所有写入"

无法创建频道.连接没有剩余的开放信道插槽

"

从我在源中读到的是因为每个tcp连接都有一个自动增量通道ID达到其最大值.这是因为每个请求都必须使用该通道,并且无法使用相同的通道(我无法找到进入php-amqp通道类的方法使其持久化)并且脚本无法通信(使用相同的实例)通道作为php对象).

降低php-fpm生命周期不是一个选项,要么通过另一个技术/库等解耦application-rabbitmq通信.

有没有简单的方法来解决这个问题？

从理论上讲,它应该是每个线程一个通道(在这种情况下是php5-fpm worker)但是如何使用这个库来实现呢？

我现在使用的代码(类似)

$this->con = new AMQPConnection(array(
    'host'          => $this->con_params['host'],
    'port'          => $this->con_params['port'],
    'vhost'         => $this->con_params['vhost'],
    'login'         => $this->con_params['user'],
    'password'      => $this->con_params['pass'],
    'read_timeout'  => 1,//seconds
    'write_timeout' => 1,//seconds
'connect_timeout' => 1,//seconds
));
$this->con->pconnect();
$channel = new AMQPChannel($this->con);
$queue = new AMQPQueue($channel);
$queue->setName($queueName);
$queue->setFlags(AMQP_DURABLE);
//$queue->declareQueue();//make sure it exists
$exchange = new AMQPExchange($channel);
$exchange->setName($exchangeName);
$exchange->setFlags(AMQP_DURABLE);
$exchange->setType(AMQP_EX_TYPE_DIRECT);
//$exchange->declareExchange();
$this->queues[$queueName]->bind($exchangeName);

谢谢 !!