php - Laravel 队列和跨类的持久变量

Question

在那里，我潜入了队列的世界及其所有优点，它击中了我:

由于 laravel 的信息序列化，当应用程序将任务推送到队列时， session 数据丢失。

了解了如何将数据发送到队列后，还有一个问题:

鉴于队列将信息推送到单个类，

我如何使该信息在整个任务期间跨其他类持久化(例如 session )？

编码示例:

//Case where the user object is needed by each class
class queueme {
    ...
    //function called by queue
    function atask($job,$data) 
    {
         //Does xyz
         if(isset($data['user_id'])
         {
              //Push user_id to another class
              anotherclass::anothertask($data['user_id']);
         }
    }
}

class anotherclass {
    ...
    function anothertask($user_id)
    {
         //Does abc
         //Yup, that anotherofanother class needs user_id, we send it again.
         anotherofanotherclass::yetanothertask($user_id);
    }
}

上面的代码说明了我的问题。

如果我的类需要此信息，我是否必须传递 $user_id 或 User 对象？

没有更简洁的方法吗？

Answer 1

当您排队作业时，您应该传递作业完成其工作所需的所有数据。因此，如果调整用户头像的大小是一项工作，则所需的必要信息是用户的主键，以便我们可以在工作中拉出他们的模型。就像您在浏览器中查看用户的个人资料页面一样，请求 URI(例如 users/profile/{id})中可能会提供必要的信息(用户的主键)。

session 不适用于队列作业，因为 session 用于从浏览器请求传输状态，而队列作业由系统运行，因此它们根本不存在。不过没关系，因为让每个类都负责查找数据并不是什么好的做法。处理请求的类(HTTP 请求的 Controller ，或队列作业的作业类)可以获取输入并查找模型等，但此后的每次调用都可以传递这些对象。

回到用户头像示例。在排队作业时，您可以将用户 ID 作为原语传递。您可以传递整个用户模型，但如果作业延迟很长时间，该用户的状态可能同时发生变化，因此您将使用不准确的数据。而且，正如您提到的，并非所有对象都可以序列化，因此最好只将主键传递给作业，它可以从数据库中重新提取它。

所以排队你的工作:

Queue::push('AvatarProcessor', [$user->id]);

当你的工作被解雇时，从数据库中提取新的用户，然后你就可以将它传递给其他类，就像在网络请求或任何其他场景中一样。

class AvatarProcessor {

    public function fire($job, $data)
    {
        $user_id = $data[0]; // the user id is the first item in the array

        $user = User::find($user_id); // re-pull the model from the database

        if ($user == null)
        {
            // handle the possibility the user has been deleted since
            // the job was pushed
        }

        // Do any work you like here. For an image manipulation example,
        // we'll probably do some work and upload a new version of the avatar
        // to a cloud provider like Amazon S3, and change the URL to the avatar
        // on the user object. The method accepts the user model, it doesn't need
        // to reconstruct the model again
        (new ImageManipulator)->resizeAvatar($user);

        $user->save(); // save the changes the image manipulator made

        $job->delete(); // delete the job since we've completed it
    }

}