Rails Job 随机丢失对模块的引用

Question

编辑：当我手动分叉一个进程时也会发生同样的事情......
我在 Rails 作业中遇到了一些奇怪的行为，该作业调用了我的一个名为 RedisService 的模块。
我已将lib/modules 添加到我的autoload_paths 中，但调用RedisService 的TextService 模块失去了对它的引用，有时是立即，有时是3 或4 个工作调用...
我什至要求我的 TextService 中的模块无济于事，甚至添加了一些 put 来检查是否始终显示模块已定义并响应我正在调用的方法...！
有什么东西逃过了我... Here's a gist to the backtrace
回购：https://gitlab.com/thomasbromehead/snmp-simulator-ruby-manager。 ruby --version: 2.6.5 rails version: 6.1.3.1

我的“服务”对象： 调用 RedisService 的模块

require_relative 'redis_service'

module TextService
  def self.write_to_file(dataObject, redis, path: "./")
    begin
      file_with_path = path + dataObject.filename
      # Store all lines prior to the one being modified, File.read closes the file
      f = File.read(file_with_path)
      new_content = f.gsub(dataObject.old_set_value, dataObject.new_set_value)
      # File.open closes the file when passed a block
      File.open(file_with_path, "w") { |file| file.puts new_content }
      puts "Redis is: #{redis}"                                    ======> RedisService
      puts "Redis responds to multi: #{redis.respond_to?(:multi)}" ======> true
      redis.multi do
        redis.zrem("#{dataObject.name}-sorted-set", dataObject.old_set_value)
        redis.hset("#{dataObject.name}-offsets", "#{dataObject.start_index}:#{dataObject.oid}:#{dataObject.end_index}", dataObject.new_set_value)
        redis.zadd("#{dataObject.name}-sorted-set", dataObject.start_index, dataObject.new_set_value)
      end
    rescue EOFError
    end
  end

从 VariateJob 调用的变体类

require_relative '../../../lib/modules/redis_service'

module Snmp
  class Variation
    include ActiveModel::Model

    attr_reader :oid, :type, :duration, :to, :from, :filename, :redis

    def initialize(oid:nil, duration:nil, type:nil, to:nil, filename: nil, from:nil)
      @to = to
      @from = from
      @oid = oid
      @type = type
      @filename = filename
      @redis = RedisService
    end

    def run(data)
      current_value, new_set_value, start_index, end_index  = prepare_values(JSON.parse(data))
      transferData = Snmp::TransferData.new({
        filename: @filename,
        old_set_value: current_value,
        new_set_value: new_set_value,
        start_index: start_index,
        end_index: end_index,
        name: @name,
        oid: oid
      })
      TextService.write_to_file(transferData, @redis)
    end

VariateJob

class VariateJob < ApplicationJob
  queue_as :default
  def perform(dumped_variation, data)
    Marshal.load(dumped_variation).run(Marshal.load(data))
  end
end

VariationsController

class VariationsController < ApplicationController
  before_action :set_file_name, only: :start

  def start
    if params["linear"]
      type = :linear
    elsif params["random"]
      type = :random
    end
    data = redis.hscan_each("#@name-offsets", match: "*:#{params["snmp_variation"]["oid"]}*")
    # data is an Enumerator, transform it to an array and dump to JSON
    variation = Snmp::Variation.new(params_to_keywords(params["snmp_variation"]).merge({type: type}))
    VariateJob.perform_later(Marshal.dump(variation), Marshal.dump(JSON.generate(data.to_a.first)))
  end

RedisService

require 'redis'

module RedisService
  include GlobalID::Identification

[...]
  def self.multi(&block)
    @redis.multi { block.call() }
  end
[...]
end

Answer 1

您没有丢失对 RedisService 的引用，而是丢失了 RedisService 中的 Redis。可能是因为你使用了一个 fork 新进程的服务器或 worker，并且你没有在 fork 之后初始化一个新的连接。

为了解决这个问题，我会替换这个方法

def self.start(host,port)
  @redis ||= Redis.new(host: host, port: port)
  self
end

与

def self.redis
  @redis ||= Redis.new(host: ::Snmpapp.redis_config[:host], port: ::Snmpapp.redis_config[:port])
end

然后我会将所有对@redis 的调用替换为对新方法的redis 调用。