[Rails] À propos d'ActiveJob,!

Qu'est-ce qu'ActiveJob?

Un cadre pour déclarer des travaux et ainsi effectuer différentes opérations de file d'attente sur le backend. En utilisant Active Job, il est possible d'envoyer du courrier et d'exécuter le traitement par lots en arrière-plan.

Contexte de l'emploi actif

queue

Structure de données First In, First Out. Le revers de la pile.

emploi

En commençant par un nettoyage régulier, tous les processus tels que la facturation et la livraison du courrier deviennent des tâches. Il est également possible de diviser ces travaux en unités de travail plus petites et de les exécuter en parallèle.

Objectif du travail actif

• Vous pourrez installer des fonctions de cadre de travail et d'autres joyaux sans vous soucier des différences d'API de diverses fonctions d'exécution de travail telles que Job retardé et Resque.
• Dans le travail de mise en file d'attente back-end, vous n'avez pas à vous soucier d'autre chose que de la méthode d'opération.
• Vous n'êtes pas obligé de réécrire les travaux lorsque vous changez de cadre de gestion des travaux.

Resque

• Vous pouvez déployer du code avec des fuites de mémoire telles que RMagick sans aucun souci.
• L'écosystème est complet.
• Comme il fourche à chaque fois, il convient aux travaux de longue durée. --Redis est requis pour le stockage de la file d'attente.
• La maintenance ne rattrape pas.

Delayed Job --DM doit créer une table dédiée.

• Si vous avez du code qui fuit de la mémoire, vous devez le redémarrer régulièrement.

Sidekiq

• API compatible avec Resque.
• Comme il fonctionne en parallèle, il est pratique à utiliser pour les applications où le taux d'attente d'E / S est important, comme les appels API vers des sites externes.
• Puisqu'il peut être exploité par un seul processus, il utilise moins de mémoire et est économique.
• Faible face à l'élargissement du processus. --Gestion du pool de connexion.
• Manipulation autre que parallèle.

Procédure d'installation d'ActiveJob

1. Exécutez la commande suivante pour installer.

$ brew install redis

2. Ajoutez ce qui suit au Gemfile.

gem 'resque'
gem 'resque-scheduler'

Exécutez également ceci.

$ bundle install

3. Ajoutez le fichier d'initialisation et la tâche de râteau.

config/initializers/resque.rb

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

4. Créez un fichier de paramètres de demande avec le contenu suivant.

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. Créez le fichier d'initialisation suivant et spécifiez Resque comme queue_adapter.

config/initializers/active_job.rb

ActiveJob::Base.queue_adapter = :resque

Exemple d'utilisation réelle

--Envoyer du courrier en arrière-plan en utilisant Active Job

1. Créez un UserMailer avec la commande suivante.

$ rails g mailer user_mailer

2. Ajoutez des méthodes et des vues pour la soumission.

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. Créez un travail avec la commande suivante

$ rails g job user_registered_mailer

4. Modifiez le fichier créé comme suit.

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. Pour utiliser le travail créé, créez une instance du travail sur le contrôleur comme indiqué ci-dessous, spécifiez le temps d'attente et appelez la méthode #perform_later.

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. Ajoutez ce qui suit au Gemfile.

gem 'mailcatcher'

Exécutez également ceci.

$ bundle install

7. Écrivez ce qui suit dans le fichier de paramètres d'environnement.

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. Démarrez mailcatcher avec la commande suivante.

$ mailcatcher

9. Démarrez divers serveurs.

#Démarrez le serveur Redis avec la commande suivante
$ redis-server

#Démarrez Resque worker avec la commande suivante
$ bundle exec rake resque:work

#Lancer Resque Scheduler
$ rake environment resque:scheduler

#Démarrer le serveur Rails
$ rails server

référence

Utilisons Active Job introduit dans Rails 4.2

[Rails, Linux] J'ai résumé "Active Job" et "Job"