0

我正在关注这个 railscast，它解释了如何实现聊天应用程序。我一步一步地遵循了一切，它似乎一直在工作，直到我开始使用 redis 发布/订阅版本以使其更快，但我的应用程序现在没有更新聊天。每次收到新消息时，我都必须刷新页面！

这是我的代码：

class MessagesController < ApplicationController
    include ActionController::Live

  def index
    @messages = Message.all
  end

  def create
    response.headers["Content-Type"] = "text/javascript"
    @message = Message.create!(params[:message].permit(:content, :name))
    $redis.publish('messages.create',@message.to_json)
  end

  def events   
    response.headers["Content-Type"] = "text/event-stream"
    redis=Redis.new
    redis.psubscribe('messages.create') do |on|
      on.pmessage do |pattern, event, data|
       response.stream.write("event: #{event}\n")
      end
    end
    rescue IOError
      logger.info "Stream closed"
    ensure
      redis.quit
      response.stream.close  
    end
end

在消息/index.html.erb

<h1>Chat</h1>

<ul id="chat">
  <%= render @messages %>
</ul>

<%= form_for Message.new, remote: true do |f| %>
  <%= f.text_field :name, placeholder: "Name" %>
  <%= f.text_field :content %>
  <%= f.submit "Send" %>
<% end %>

我在 assets/javascript 文件夹中有一个 .js 文件，它负责监听服务器事件。

var evnt = new EventSource('/messages/events');

evnt.addEventListener('messages.create', function(e){
  var message;
  message = $.parseJSON(e.data).message;
  return $('#chat').append($('<li>').text("" + message.name + ": " + message.content));
});

我正在像这样的单独终端上启动 redis-server

$: redis-server

我没有使用 brew 安装 redis，只是下载了一个 tar 文件并解压缩了它。它被系统识别，所以应该没问题。

当我尝试应用程序时，它不会使用新消息更新聊天。我需要刷新页面以使它们显示。有什么帮助吗？

4

1 回答 1

3

似乎您没有将任何数据写入流，只有事件类型。

redis.psubscribe('messages.*') do |on|
  on.pmessage do |pattern, event, data|
    response.stream.write("event: #{event}\n")
    response.stream.write("data: #{data}\n\n") # You are missing this line.
  end
end
于 2013-01-25T16:05:30.247 回答