ruby-on-rails - 混合 redis actioncontroller::live - rails 应用程序

Question

我第一次使用 redis 在我的 Rails 应用程序中添加聊天功能，关注 this

我的 javascript 中有`

$(document).ready ->
  source = new EventSource('/messages/events')
  source.addEventListener 'messages.create', (e) ->
    message = $.parseJSON(e.data).message
    console.log(message)
    $(".chat-messages").append "#some code"

在我的消息 Controller 中

def create
    response.headers["Content-Type"] = "text/javascript"
    attributes = params.require(:message).permit(:content, :sender_id, :sendee_id)
    @message = Message.create(attributes)
    respond_to do |format|
      format.js { render 'messages/create.js.erb' }
    end
    $redis.publish('messages.create', @message.to_json)
  end

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

问题是，首先，我的控制台中没有任何记录，其次，我得到了一些随机的 ConnectionTimeoutError 错误。有人知道发生了什么

Answer 1

先决条件:

• ruby 2.0.0+
• rails 4.0.0+
• Redis
• 彪马

---

初始化器:

在config/initializers目录下创建一个redis.rb初始化文件，全局化一个redis实例。设置一个 heartbeat 线程也是个好主意(5 秒到 5 分钟都可以，具体取决于您的要求):

$redis = Redis.new

heartbeat_thread = Thread.new do
  while true
    $redis.publish("heartbeat","thump")
    sleep 15.seconds
  end
end

at_exit do
  # not sure this is needed, but just in case
  heartbeat_thread.kill
  $redis.quit
end

---

Controller :

您需要向您的ChatController 添加两个方法，pub 和sub。 pub的作用是将聊天事件和消息发布到redis，sub订阅这些事件。它应该看起来像这样:

class ChatController < ApplicationController
    include ActionController::Live

    skip_before_filter  :verify_authenticity_token

    def index
    end

    def pub
        $redis.publish 'chat_event', params[:chat_data].to_json
        render json: {}, status: 200
    end

    def sub
        response.headers["Content-Type"] = "text/event-stream"

        redis = Redis.new
        redis.subscribe(['chat_event']) do |on|
            on.message do |event, data|
                response.stream.write "event: #{event}\ndata: #{data}\n\n"
            end
        end
    rescue IOError
        logger.info "Stream Closed"
    ensure
        redis.quit
        response.stream.close
    end
end

在您的路由中，将pub 设为POST 和sub GET，并将路径与 /chat/publish 和 /chat/subscribe 相匹配。

---

CoffeeScript /Javascript:

假设聊天应用程序的实际网页位于 /chat，您需要编写一些 Javascript 来实际发送和接收聊天消息。

为了便于理解，我们假设您的网页只有一个文本框和一个按钮。点击按钮应该将文本框的内容发布到聊天流，我们可以使用 AJAX 来做到这一点:

$('button#send').click (e) ->
    e.preventDefault()
    $.ajax '/chat/publish',
        type: 'POST'
        data: {
            chat_data: {
                message: $("input#message").val(),
                timestamp: $.now()
            }
        }
        error: (jqXHR, textStatus, errorThrown) ->
            console.log "Failed: " + textStatus 
        success: (data, textStatus, jqXHR) ->
            console.log "Success: " + textStatus

现在，您还需要能够订阅和接收聊天消息。为此，您需要使用 EventSource。使用 EventSource，为 SSE 打开一个 channel ，以便您可以接收事件，并使用该数据更新 View 。在这个例子中，我们只会将它们记录到 javascript 控制台。

代码应该是这样的:

$(document).ready ->
    source = new EventSource('/chat/subscribe')
    source.addEventListener 'chat_event', (e) ->
        console.log(e.data)

---

启用并行请求:

在您的开发环境中，您必须通过将这两行添加到您的 config/environments/development.rb 来启用并行请求:

config.preload_frameworks = true
config.allow_concurrency = true

现在启动您的浏览器，浏览至 /chat 并查看魔术。当您键入一条消息并单击该按钮时，该网页的所有实例都会收到该消息。

---

这就是您使用 ActionController::Live 和 Redis 在 rails 中制作基本聊天应用程序的方法。根据您的要求，最终代码显然会有很大不同，但这应该可以帮助您入门。

您应该查看更多资源:

• 温柔的做爱 - Is it Live?
• Railscasts - #401 - ActionController::Live
• SitePoint - Mini Chat with Rails and SSEs
• Github - mohanraj-ramanujam / live-stream
• Thoughtbot - Chat Example using SSEs