cloudamqp/amqproxy

AMQProxy

镜像概述与主要用途

AMQProxy是一款智能AMQP代理，核心功能为连接和通道池化/复用。它允许客户端（如PHP客户端）与上游AMQP服务器保持长连接，显著提升消息发布速度；同时，通过通道池化技术，可使大量客户端在秒级内完成连接（传统方式可能需数十分钟），有效解决短连接场景下的性能瓶颈。

核心功能与特性

连接与通道复用

• 连接复用：客户端断开连接后，代理会保持与上游AMQP服务器的连接，供后续相同凭证的客户端复用，避免重复建立TCP连接的开销。
• 通道复用：仅对“安全”通道进行复用（即仅执行Basic Publish或Basic Get（带no_ack）操作的通道），确保数据安全性；订阅队列的通道在客户端断开时会关闭。

性能优化

• 降低延迟：通过复用连接和通道，减少AMQP协议中连接建立（7个TCP包）、通道打开（2个TCP包）等过程的TCP交互（传统短连接需15个TCP包，AMQPS/TLS则需18个），显著降低消息发布延迟。
• 提升吞吐量：针对无法保持长连接的客户端，可大幅提升消息发布速度（基准测试显示提速可达50倍以上）。

工作原理

在AMQP协议中，客户端与服务器建立连接需交换7个TCP包，打开通道需2个，发布消息至少1个，关闭连接需4个，总计15个TCP包（AMQPS/TLS为18个），短连接场景下延迟显著。
AMQProxy部署在客户端本地时，客户端连接代理后，代理使用客户端提供的凭证连接上游服务器并转发流量；客户端断开时，代理拦截Channel Close命令，保持上游通道打开（若安全）。下次相同凭证的客户端连接时，直接复用上游连接和通道，无需重复建立，从而节省全部TCP交互开销。

使用场景

• 短连接客户端：如PHP等无法保持长连接的客户端，解决频繁建立/关闭连接导致的高延迟问题。
• 高并发连接场景：需快速处理大量客户端连接的系统（如分布式消息发布系统），通过通道池化减少上游连接数，实现秒级连接。
• 低延迟需求场景：实时数据传输、高频消息发布等对延迟敏感的应用，通过减少TCP交互提升响应速度。

使用方法

Docker部署示例

bash
docker run --rm -it -p 5673:5673 cloudamqp/amqproxy amqp://SERVER:5672

• 参数说明：
  • -p 5673:5673：将容器的5673端口映射到主机5673端口（代理默认监听端口）。
  • cloudamqp/amqproxy：AMQProxy镜像名称。
  • amqp://SERVER:5672：上游AMQP服务器地址（格式为协议://主机名:端口，默认端口：AMQP为5672，AMQPS为5671）。

客户端配置

• 客户端需连接到代理地址localhost:5673。
• 上游服务器的用户名、密码、vhost由客户端提供（代理忽略AMQP_URL中的凭证信息）。

基准测试

在往返延迟50ms、使用TLS的环境中，客户端单次连接发布1条消息：

• 通过AMQProxy：平均耗时0.01秒。
• 不使用代理：平均耗时0.50秒。
  更多详情