ruby-on-rails - Rails 和 ActionCable 本地主机上的 1.8 小时网络请求时间 / Heroku 上的高响应时间
问题描述
Chrome 中的 Network 选项卡显示在 localhost 上在几秒和几小时/cable
之间波动的请求:
...然后是这个疯狂的多米诺骨牌堆栈“待处理”请求:
在带有 Puma 服务器和 512 MB 测功机的 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
应在几毫秒内处理请求。
实际行为:一些/cable
请求在 80 年后被处理,然后其他数百个请求被卡在一个pending
状态。
系统配置: Ruby版本:2.5.0,Rails版本:5.2.0,Puma版本:4.3.1
频道/application_cable/channel.rb
module ApplicationCable
class Channel < ActionCable::Channel::Base
end
end
频道/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
频道/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)
模型/消息.rb
class Message < ApplicationRecord
after_create_commit { MessageBroadcastWorker.perform_async self.id }
end
工人/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
解决方案
解决方案是关闭 Heroku logentries 上的警报。该/cable
请求不是轮询服务器以获取更新,而是建立一个请求,然后保持打开状态,直到用户退出或离开站点。
推荐阅读
- spring-boot - 如何将代码从 Spring Security 迁移到 Reactive Spring Security?
- php - PHP Imap:从 Gmail 中获取不重复的主题
- google-api - Google 地理编码 API 安全性
- java - Java 执行。是否可以强制冲洗?
- c++ - bitset<32> 大小为 8 个字节?
- algorithm - 总是选择第二小的元素作为子列表中的枢轴时的快速排序时间复杂度
- c# - 如何在 D:\myfolder\ 中使用 C# 获取名为 something-* 的直接目录列表
- php - 使用 simplehtmldom 进行抓取给了我空的结果
- android-gradle-plugin - 无法解析 ':app@debug/compileClasspath' 的依赖关系:无法解析 com.android.support:multidex:1.0.2
- python - 引用 python 包中的文件