使用AMQProxy解决PHP等客户端Connection复用问题

AMQProxy

AMQProxy是Cloud AMQP提供的开源AMQP代理服务。客户端可以通过该代理服务与云消息队列 RabbitMQ 版保持长连接。当您在客户端服务器部署AMQProxy后，客户端和云消息队列 RabbitMQ 版之间的请求都会先发送到AMQProxy，然后由AMQProxy转发到对方。

AMQProxy处理客户端发起的Connection相关请求的逻辑如下：

• 如果客户端发送开启Connection的请求，AMQProxy将根据用户名、密码、Vhost查找当前是否有合适的Connection可以复用，如果有就复用该Connection，如果没有就由AMQProxy代替客户端和云消息队列 RabbitMQ 版开启Connection。

• 如果客户端发送关闭Connection的请求，AMQProxy会直接应答OK，但并不会关闭与云消息队列 RabbitMQ 版的Connection，当该客户端下次再请求开启Connection时，AMQProxy会直接使用该Connection。

更多AMQProxy相关信息，请参见AMQProxy。

部署AMQProxy

1. 执行以下命令下载AMQProxy压缩包。

   wget https://github.com/cloudamqp/amqproxy/releases/download/v0.4.4/amqproxy-0.4.4-1.linux-x86_64-static.tar.gz

   说明

   本文以AMQProxy 0.4.4为例。更多AMQProxy版本，请参见Releases。

2. 执行以下命令解压AMQProxy压缩包。

   tar -xzvf amqproxy-0.4.4-1.linux-x86_64-static.tar.gz

3. 执行以下命令进入AMQProxy文件夹。

   cd amqproxy/

4. 执行以下命令启动AMQProxy。

   ./amqproxy -l LISTEN_ADDRESS -p LISTEN_PORT AMQP_URL

   参数	描述
   LISTEN_ADDRESS	AMQProxy IP地址。由于是在客户端服务器部署AMQProxy，因此您可以直接使用本机地址127.0.0.1。
   LISTEN_PORT	AMQProxy监听端口。客户端请求通过该端口发送到AMQProxy。该端口可以为任何可用的端口，例如5673。
   AMQP_URL	云消息队列 RabbitMQ 版实例的URL。格式为{amqp|amqps}://{endpoint}。 amqp：AMQP协议。不使用SSL连接时使用。 amqps：AMQP/SSL协议。使用SSL连接时使用。 endpoint：云消息队列 RabbitMQ 版实例的接入点。您可以在云消息队列 RabbitMQ 版控制台的实例详情页面查看。更多信息，请参见查看实例详情。

   示例命令如下：

   ./amqproxy -l 127.0.0.1 -p 5673 amqps://188XXX420.mq-amqp.cn-hangzhou-a.aliyuncs.com

   返回示例如下：

   Proxy upstream: 188XXX420.mq-amqp.cn-hangzhou-a.aliyuncs.com:5671 TLS
   Proxy listening on 127.0.0.1:5673
   0 clients                0 upstreams

   参数	描述
   clients	客户端和AMQProxy的Connection数量。
   upstreams	AMQProxy和云消息队列 RabbitMQ 版实例的Connection数量。

5. 在客户端代码中将Host和端口修改为AMQProxy IP地址和监听端口。

   factory.setHost("127.0.0.1");
   factory.setPort(5673);