SSE / EventSource在传输第一批数据后关闭（Rails 4 + Puma + Nginx）

Question

我遵循了401-ActionController-Live Railscast和这篇Blog Post关于Server-Sent-Events的内容，在我的Rails应用程序中设置了类似的东西。当我只使用puma时，它可以完美地工作，但是使用puma + nginx时，连接在发送第一个数据块后就会关闭。

我还尝试了按照以下问题提供的解决方案，但对我不起作用：

• ActionController::Live Streaming dies after first chunk sent
• EventSource / Server-Sent Events through Nginx

这就是我得到的结果：

这是如何设置我的服务器，这是我当前的nginx配置：

upstream puma {
  server unix:///home/deploy/apps/outy/shared/tmp/sockets/outy-puma.sock;
  keepalive 16;
}

server {
  listen 80 default_server deferred;

  root /home/deploy/apps/outy/current/public;
  access_log /home/deploy/apps/outy/current/log/nginx.access.log;
  error_log /home/deploy/apps/outy/current/log/nginx.error.log info;

  location ^~ /assets/ {
    gzip_static on;
    expires max;
    add_header Cache-Control public;
  }

  try_files $uri/index.html $uri @puma;
  location @puma {
    proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
    proxy_set_header Host $http_host;
    proxy_redirect off;

    proxy_pass http://puma;

    proxy_http_version 1.1;
    proxy_set_header Connection "";
    proxy_buffering off;
    proxy_cache off;
  }

  error_page 500 502 503 504 /500.html;
  client_max_body_size 10M;
  keepalive_timeout 10;
}

- Sheharyar

---

你用它解决了你的问题吗？ - arturtr

@arturtr 不好意思，我仍然无法解决这个问题。 - Sheharyar

Answer 1

我将分享一个可行的配置。

nginx

upstream app_server {
    server unix:/var/tmp/sockets/puma.sock
    fail_timeout=0;
}

server {
    listen 80 default_server;
    listen 443 ssl;
    client_max_body_size 8m;
    server_tokens off;

    server_name localhost;

    keepalive_timeout 5;

    location / {
        try_files @uri @app;
    }

    location @app {
      proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
      proxy_set_header X-Forwarded-Proto $http_x_forwarded_proto;
      proxy_set_header Host $http_host;
      proxy_redirect off;

      proxy_http_version 1.1;
      chunked_transfer_encoding off;

      proxy_buffering off;

      proxy_pass http://app_server;
    }
}

控制器

class StreamController < ActionController::Base
  include ActionController::Live

  def hello
    response.headers["Content-Type"] = "text/event-stream" #; charset=utf-8"

    10.times {
      response.stream.write("data: Hello World!!\n\n")
      sleep 1
    }
  rescue IOError
    puts "Stream IO Error"
    logger.info "Stream IO Error"
  ensure
    puts "Stream closed"
    logger.info "Stream closed"
    response.stream.close
  end
end

curl

$ curl -i -N http://localhost/stream/hello
HTTP/1.1 200 OK
Server: nginx
Date: Wed, 29 Jul 2015 09:15:43 GMT
Content-Type: text/event-stream
Transfer-Encoding: chunked
Connection: keep-alive
X-Frame-Options: SAMEORIGIN
X-XSS-Protection: 1; mode=block
X-Content-Type-Options: nosniff
Cache-Control: no-cache
X-Request-Id: 41e80567-d792-4a48-9ec3-c661aa056081
X-Runtime: 0.062282
Vary: Origin

data: Hello World!!

data: Hello World!!

data: Hello World!!

data: Hello World!!

data: Hello World!!

data: Hello World!!

data: Hello World!!

data: Hello World!!

data: Hello World!!

data: Hello World!!

- atomita

---

在这个答案中，nginx 配置文件中的关键行是 "proxy_http_version 1.1;"，其余部分是可选的，至少在我的设置中是这样的。 - american-ninja-warrior