通过 Nginx 的 RabbitMQ 连接

Question

我正在尝试设置 rabbitmq 它可以通过 nginx 从外部（从非本地主机）访问。

nginx-rabbitmq.conf:

server {
    listen       5672;
    server_name  x.x.x.x;
    location / {
        proxy_pass http://localhost:55672/;
    }
}

rabbitmq.conf文件：

[
 {rabbit,
  [
   {tcp_listeners, [{"127.0.0.1", 55672}]}
  ]
 }
]

默认情况下，来宾用户只能从本地主机进行交互，因此我们需要创建另一个具有所需权限的用户，如下所示：

sudo rabbitmqctl add_user my_user my_password
sudo rabbitmqctl set_permissions my_user ".*" ".*" ".*"

但是，当我尝试通过pika连接到Rabbitmq时，我得到了ConntionClo的异常

import pika
credentials = pika.credentials.PlainCredentials('my_username', 'my_password')
pika.BlockingConnection(
    pika.ConnectionParameters(host=ip_address, port=55672, credentials=credentials)
)

--[引发连接关闭异常]--

如果我使用相同的参数，但将主机更改为localhost并将端口更改为5672，那么我连接ok：pika。连接参数（主机=ip_address，端口=55672，凭据=凭据）

我已经在GCE web控制台上打开了5672端口，通过nginx进行通信：nginx访问。日志文件显示

[30/Apr/2014:22:59:41 0000]“AMQP\x00\x00\x09\x01”400 172“-”-“-”

显示 400 状态代码响应（错误请求）。

所以从表面上看，请求在通过ngin x时失败，但当我们直接请求Rabbitmq时有效。

有没有其他人有过类似的问题/通过nginx让rabbitmq为外部用户工作？有没有一个rabbitmq日志文件可以让我看到每个请求并帮助我进一步排除故障？

Answer 1

您可以尝试代理到tcp，为nginx安装一个tcp代理模块以与AMQP一起工作。

https://github.com/yaoweibin/nginx_tcp_proxy_module

试一试。

Answer 2

您已经将nginx配置为HTTP反向代理，但是rabbitmq配置为使用AMQP协议（请参阅https://www.rabbitmq.com/configure.html)

为了让ngin x做任何有意义的事情，你需要重新配置Rabbitmq以使用HTTP——例如http://www.rabbitmq.com/web-stomp.html.

当然，这可能会产生连锁反应，因为任何通过AMQP访问rabbitmq的客户端都必须重新配置/重新设计以使用HTTP。

Answer 3

从nginx 1.9开始，就有了tcp或udp的流模块(默认情况下没有编译)。

我用ssl流配置了我的nginx (1.13.3)

stream {
    upstream rabbitmq_backend {
        server rabbitmq.server:5672
    }

    server {
        listen      5671 ssl;

        ssl_protocols           TLSv1.2 TLSv1.1 TLSv1;
        ssl_ciphers             RC4:HIGH:!aNULL:!MD5;
        ssl_handshake_timeout   30s;

        ssl_certificate       /path/to.crt;
        ssl_certificate_key   /path/to.key;

        proxy_connect_timeout 1s;
        proxy_pass rabbitmq_backend;
    }
}

https://docs.nginx.com/nginx/admin-guide/security-controls/terminating-ssl-tcp/