概要

Sidekiqのコードをさらっと読んでみる。

準備

1. sidekiqをクローン

• https://github.com/sidekiq/sidekiq

2. redisを起動

• docker run --name redis-server -p 6379:6379 -d redis

3. デバッグしたいところでbinding.pryを仕込む
4. sidekiqを起動

• bundle exec sidekiq -r ./examples/blog.rb

5. ジョブを投入

• bundle exec irb -r ./examples/por.rb

コードリーディング

ジョブの投入

1. perform_asyncを起点に非同期処理を呼び出す

• sidekiq - lib/sidekiq/job.rb#L205

2. ジョブをキューに投入する

• client_push
  • sidekiq - lib/sidekiq/job.rb#L368
• push
  • sidekiq - lib/sidekiq/client.rb#L86
• raw_push
  • sidekiq - lib/sidekiq/client.rb#L239

ジョブの実行

1. sidekiqの起動

• run
  • lib/sidekiq/cli.rb#41
• launch
  • lib/sidekiq/cli.rb#116
• run
  • lib/sidekiq/cli.rb#38

2. ジョブの取得

• run
  • lib/sidekiq/processor.rb#71
• process_one
  • lib/sidekiq/processor.rb#71
• process
  • lib/sidekiq/processor.rb#159 -jobを処理する

3. ジョブの実行

• execute_job
  • lib/sidekiq/processor.rb#185
  • lib/sidekiq/processor.rb#217