Rails＆ActionCable 1.8hr在本地主机上的网络请求时间/在Heroku上的高响应时间

Question

bounty到期在5天内。该问题的答案有资格获得+ 150声望赏金。calyxofheld想要引起更多关注对此问题。

Chrome中的“网络”标签显示/cable请求在本地主机上的秒和小时之间波动：

...然后是这个疯狂的“待定”请求的多米诺骨牌堆栈：

[在具有Puma服务器和512 MB dyno的Heroku上，我在/cable端点上收到高响应时间警告。这是日志条目的示例：

25 Dec 2019 14:13:31.061299 <158>1 2019-12-25T22:13:28.421009+00:00 heroku router - - at=info method=GET path="/cable" host=www.######.com request_id=#### fwd="####" dyno=web.1 connect=1ms service=531114ms status=101 bytes=174 protocol=https High Response Time

在所有情况下，我都是唯一使用该应用程序的人。我已经看到最多有3-4个其他人在使用ActionCable时遇到此问题，但他们似乎都没有任何解决方案，我不知所措。我研究了AnyCable和Iodine，但是AnyCable无法正常工作，并且Iodine无法解决我的问题。还有什么可能导致这种情况？

预期的行为： /cable请求应在几毫秒内处理。

实际行为： 80年后，正在处理某些/cable请求，然后又有成百上千的其他请求处于pending状态。

系统配置： Ruby版本：2.5.0，Rails版本：5.2.0，Puma版本：4.3.1

channels / application_cable / channel.rb

module ApplicationCable
 class Channel < ActionCable::Channel::Base
 end
end

channels / application_cable / connection.rb

module ApplicationCable
 class Connection < ActionCable::Connection::Base
  identified_by :current_user

  def connect
   self.current_user = find_verified_user
   logger.add_tags 'ActionCable', current_user.username
  end

  protected
  def find_verified_user
   if verified_user = User.find_by(id: cookies.signed['user.id'])
    verified_user
   else
    reject_unauthorized_connection
   end  
  end
 end
end

channels / messages_channel.rb

class MessagesChannel < ApplicationCable::Channel
 def subscribed
  stream_from "user_#{current_user.id}_messages_channel"
 end

 def unsubscribed
  stop_all_streams
 end

 def speak(data)
  Message.create! body: data['message'], conversation_id: data['conversation_id'], user_id: current_user.id
 end
end

javascripts / channels / messages.coffee

App.messages = App.cable.subscriptions.create "MessagesChannel",
 connected: ->
  console.log 'Connected'

 disconnected: ->
  console.log 'Disconnected'

 received: (data) ->
  console.log 'Received'
  $("[data-conversation-id='" + data.conversation_id + "']").append(data.message)
  console.log 'Received'
  $("#messages").append(data.message)

 speak: (message, conversation_id) ->
  @perform 'speak', message: message, conversation_id: conversation_id

$(document).on 'turbolinks:load', ->
 submit_message()
 scroll_bottom()

submit_message = () ->
 $('#response').on 'keydown', (event) ->
  if event.keyCode is 13
   message = event.target.value
   conversation_id = $("#messages").data("conversation-id")
   App.messages.speak(message, conversation_id)
   event.target.value = ""
   event.preventDefault()

scroll_bottom = () ->
 if $('#messages').length > 0
 $('#messages').scrollTop($('#messages')[0].scrollHeight)

models / messages.rb

class Message < ApplicationRecord
 after_create_commit { MessageBroadcastWorker.perform_async self.id }
end

workers / message_broadcast_worker.rb

class MessageBroadcastWorker
 include Sidekiq::Worker

 def perform(message_id)
  message = Message.find message_id
  user = message.user
  ActionCable.server.broadcast("user_#{user.id}_messages_channel", message: render_message(message, user))
 end

 private
 def render_message(message, user)
  ApplicationController.renderer.render(partial: 'messages/message', locals: { message: message, user: user })
 end
end

Answer 1

我认为我已将问题缩小到connection.rb