模型回调时Rails控制器中的触发操作

Question

我正试图在Rails中通过服务器发送事件来实现流媒体直播。我有一个Rake任务，用于监听文件更改，从而将记录添加到数据库中。一旦添加，我想发送一个SSE到前端。

但是，模型不能将事件发送到前端，这是由控制器负责的。如何告诉我的控制器向数据库中添加了新记录？

到目前为止，我的（坏的）解决方案是：在模型中使用EventBus，在保存后回调，宣布更改并要求控制器侦听以下消息：

require 'reloader/sse'
class SseController < ApplicationController
  include ActionController::Live

  def index
    response.headers['Content-Type'] = 'text/event-stream'
    sse = Reloader::SSE.new(response.stream)
    EventBus.subscribe(:added) do |payload|
      sse.write({ /* payload */ })
    end
  rescue IOError
  ensure
    sse.close
  end
end

我认为我的请求在收到事件之前就结束了，这意味着它永远不会在取消订阅块中结束。这是正确的方法吗，如果是，我错过了什么？

Answer 1

解决方案1：您可以使用rest\u客户端gem在模型的after\u save回调中向控制器发送请求。

解决方案2：为什么不在控制器中调用一个model方法来创建数据库记录，然后根据是否创建了记录来处理进一步的操作