[Rails] Über ActiveJob!

Was ist ActiveJob?

Ein Framework zum Deklarieren von Jobs und damit zum Ausführen verschiedener Warteschlangenoperationen im Backend. Mit Active Job ist es möglich, E-Mails zu senden und die Stapelverarbeitung im Hintergrund auszuführen.

Aktiver Jobhintergrund

Warteschlange

First-In-First-Out-Datenstruktur. Die Rückseite des Stapels.

Job

Zu den Jobs gehören regelmäßige Bereinigungen, Rechnungsstellung und E-Mail-Zustellung. Es ist auch möglich, diese Jobs in kleinere Arbeitseinheiten aufzuteilen und parallel auszuführen.

Zweck des aktiven Jobs

• Sie können Job-Framework-Funktionen und andere Juwelen installieren, ohne sich über die API-Unterschiede verschiedener Jobausführungsfunktionen wie Delayed Job und Resque Gedanken machen zu müssen.
• In der Back-End-Warteschlange müssen Sie sich nur um die Operationsmethode kümmern.
• Beim Wechseln des Jobverwaltungs-Frameworks müssen keine Jobs neu geschrieben werden.

Resque

• Sie können Code mit Speicherlecks wie RMagick ohne Sorgen bereitstellen.
• Das Ökosystem ist vollständig.
• Da es sich jedes Mal gabelt, ist es für Langzeitjobs geeignet. --Redis ist für die Warteschlangenspeicherung erforderlich.
• Die Wartung holt nicht auf.

Delayed Job --DM muss eine dedizierte Tabelle erstellen.

• Wenn Sie Code haben, der Speicher verliert, müssen Sie ihn regelmäßig neu starten.

Sidekiq --Resque kompatible API.

• Da es parallel arbeitet, ist es praktisch für Anwendungen zu verwenden, bei denen das Verhältnis der E / A-Wartezeiten groß ist, z. B. API-Aufrufe an externe Sites.
• Da es mit einem Prozess betrieben werden kann, benötigt es weniger Speicher und ist wirtschaftlich.
• Schwach gegen Prozesserweiterung.
• Umgang mit dem Verbindungspool.
• Andere als parallele Handhabung.

ActiveJob-Installationsverfahren

1. Führen Sie zum Installieren den folgenden Befehl aus.

$ brew install redis

2. Fügen Sie der Gemfile Folgendes hinzu.

gem 'resque'
gem 'resque-scheduler'

Führen Sie dies auch aus.

$ bundle install

3. Fügen Sie die Initialisierungsdatei und die Rechenaufgabe hinzu.

config/initializers/resque.rb

Resque.redis = Redis.new(host: 'localhost', post: 6379)
Resque.after_fork = Proc.new { ActiveRecord::Base.establish_connection }

4. Erstellen Sie eine Anforderungseinstellungsdatei mit den folgenden Inhalten.

lib/tasks/resque.rake

require 'resque/tasks'
require 'resque/scheduler/tasks'

namespace :resque do
  task setup: :environment do
    ENV['TERM_CHILD'] ||= '1'
    ENV['QUEUE'] ||= '*'
    require 'resque'
    require 'resque-scheduler'
  end
end

5. Erstellen Sie die folgende Initialisierungsdatei und geben Sie Resque als queue_adapter an.

config/initializers/active_job.rb

ActiveJob::Base.queue_adapter = :resque

Beispiel für die tatsächliche Verwendung

• Senden Sie E-Mails im Hintergrund mit Active Job

1. Erstellen Sie einen UserMailer mit dem folgenden Befehl.

$ rails g mailer user_mailer

2. Fügen Sie Methoden und Ansichten zur Übermittlung hinzu.

app/mailers/user_mailer.rb

class UserMailer < ActionMailer::Base
  default from: "[email protected]"

  def registered(user)
    mail(to: user.email, subject: 'Welcome to Rdaily!')
  end
end

app/views/user_mailer/registered.text.erb

Dear. <%= @user.name %>

Welcome to Rdaily!

3. Erstellen Sie einen Job mit dem folgenden Befehl

$ rails g job user_registered_mailer

4. Bearbeiten Sie die erstellte Datei wie folgt.

app/jobs/user_registered_mailer_job.rb

class UserRegisteredMailerJob < ActiveJob::Base
  queue_as :email

  def perform(user)
    UserMailer.registered(user).deliver_now
  end
end

5. Um den erstellten Job zu verwenden, erstellen Sie eine Instanz des Jobs auf dem Controller wie unten gezeigt, geben Sie die Wartezeit an und rufen Sie die Methode #perform_later auf.

class Account::UsersController < ApplicationController
  ...

  def create
    @user = User.new(user_params)
    if @user.save
      UserRegisteredMailerJob.perform_later(@user)
      flash.notice = "User is successfully created."
      redirect_to account_path
  ...
end

6. Fügen Sie der Gemfile Folgendes hinzu.

gem 'mailcatcher'

Führen Sie dies auch aus.

$ bundle install

7. Schreiben Sie Folgendes in die Umgebungseinstellungsdatei.

config/environments/development.rb

Rails.application.configure do
  ...
  config.action_mailer.delivery_method = :smtp
  config.action_mailer.smtp_settings = { address: 'localhost', port: 1025 }
  ...
end

8. Starten Sie den Mailcatcher mit dem folgenden Befehl.

$ mailcatcher

9. Starten Sie verschiedene Server.

#Starten Sie den Redis-Server mit dem folgenden Befehl
$ redis-server

#Starten Sie Resque Worker mit dem folgenden Befehl
$ bundle exec rake resque:work

#Starten Sie den Resque Scheduler
$ rake environment resque:scheduler

#Starten Sie den Rails-Server
$ rails server

Referenz

Verwenden wir den in Rails 4.2 eingeführten aktiven Job

[Rails, Linux] Ich habe "Active Job" und "Job" zusammengefasst