1

我最近使用新的ObjectSpace.dump_all方法分析了一堆 Ruby 2.1.2 代码。我取回了一些有用的数据（使用@tmm1 在该链接中建议的脚本）：

 931 /app/vendor/bundle/ruby/2.1.0/gems/polyglot-0.3.5/lib/polyglot.rb:65:ARRAY
1015 /app/vendor/bundle/ruby/2.1.0/gems/activemodel-4.1.5/lib/active_model/attribute_methods.rb:385:ARRAY
1015 /app/vendor/bundle/ruby/2.1.0/gems/activemodel-4.1.5/lib/active_model/attribute_methods.rb:385:DATA
1015 /app/vendor/bundle/ruby/2.1.0/gems/activemodel-4.1.5/lib/active_model/attribute_methods.rb:385:NODE
1054 ::REGEXP
1075 ::ICLASS
1095 /app/vendor/ruby-2.1.2/lib/ruby/2.1.0/psych/class_loader.rb:32:STRING
1753 /app/vendor/cache/aws-sdk-core-ruby-99f5012f1162/aws-sdk-core/lib/seahorse/client/net_http/connection_pool.rb:49:ARRAY
1753 /app/vendor/cache/aws-sdk-core-ruby-99f5012f1162/aws-sdk-core/lib/seahorse/client/net_http/connection_pool.rb:49:STRING
1969 /app/vendor/bundle/ruby/2.1.0/gems/polyglot-0.3.5/lib/polyglot.rb:65:NODE
2036 /app/vendor/bundle/ruby/2.1.0/gems/polyglot-0.3.5/lib/polyglot.rb:65:DATA
2507 /app/vendor/bundle/ruby/2.1.0/gems/pg-0.17.1/lib/pg/result.rb:10:STRING
3227 /app/vendor/bundle/ruby/2.1.0/gems/polyglot-0.3.5/lib/polyglot.rb:65:STRING
4592 ::OBJECT
5291 ::CLASS
15623 ::NODE
19227 ::ARRAY
25977 ::DATA
27162 ::HASH
140490 ::STRING

我的问题是：为什么在我们看不到文件名或行号（最后六行）的地方分配了这么多对象？似乎我的问题与很多字符串有关，考虑到这个应用程序的功能，这绝对是有道理的。但不知道这些字符串是从哪里构建的意味着我无能为力。

当应用程序启动时，我正在运行ObjectSpace.trace_object_allocations_start，远在我尝试分析的操作之前。我肯定会GC.start在每次调用ObjectSpace.dump_all. 我正在调用.dump_all一些 Sidekiq 中间件，该中间件以类似于@krasnoukhov 的帖子的方式转储每 100 个工作。

我想我真正的问题是，这里是否有人足够了解 Ruby 对象分配来解释为什么ObjectSpace可能不知道这些对象的来源STRINGs？

谢谢！

编辑：我使用的代码与@Krasnoukhov 的博客中的代码几乎相同

if ENV["PROFILE"]
  require "objspace"
  ObjectSpace.trace_object_allocations_start
  Sidekiq.logger.info "allocations tracing enabled"

  module Sidekiq
    module Middleware
      module Server
        class Profiler
          # Number of jobs to process before reporting
          JOBS = 100
      class << self
        mattr_accessor :counter
        self.counter = 0

        def synchronize(&block)
          @lock ||= Mutex.new
          @lock.synchronize(&block)
        end
      end

      def call(worker_instance, item, queue)
        begin
          yield
        ensure
          self.class.synchronize do
            self.class.counter += 1

            if self.class.counter % JOBS == 0
              Sidekiq.logger.info "reporting allocations after #{self.class.counter} jobs"
              GC.start
              ObjectSpace.dump_all(output: File.open("heap.json", "w"))
              Sidekiq.logger.info "heap saved to heap.json"
            end
          end
        end
      end
    end
  end
end


Sidekiq.configure_server do |config|
  config.server_middleware do |chain|
      chain.add Sidekiq::Middleware::Server::Profiler
    end
  end
end
4

0 回答 0