Laravel 队列反序列化问题

【问题标题】：Laravel Queue Unserializing IssueLaravel 队列反序列化问题
【发布时间】：2016-04-14 11:08:48
【问题描述】：

我很难弄清楚我的 Laravel 应用到底发生了什么。它在本地功能齐全（Mac，php 5.5.26），所以我一直在通过 forge（php 5.6.15）在我的数字海洋水滴上测试该应用程序。

我正在使用this package 向使用我的 Laravel api 的前端应用程序发送推送通知。为了使 api 调用更快，我将推送通知委托给 Laravel 队列，这些队列在本地工作得很好，但是当我在数字海洋上测试时收到了这个错误。

[2016-01-09 20:34:09] stage.ERROR: exception 'ErrorException' with message 'Erroneous data format for unserializing 'ArrayIterator'' in {path}/{project}/vendor/laravel/framework/src/Illuminate/Queue/CallQueuedHandler.php:74

我正在使用数据库驱动程序。这是我的本地数据库作业表中的序列化作业行...

{"job":"Illuminate\\Queue\\CallQueuedHandler@call","data":{"command":"O:28:\"App\\Jobs\\Push\\SendPushFollow\":4:{s:34:\"\u0000App\\Jobs\\Push\\SendPushFollow\u0000push\";O:27:\"App\\Helpers\\Push\\PushFollow\":5:{s:14:\"\u0000*\u0000ios_devices\";O:50:\"Sly\\NotificationPusher\\Collection\\DeviceCollection\":1:{s:7:\"\u0000*\u0000coll\";C:13:\"ArrayIterator\":21:{x:i:0;a:0:{};m:a:0:{}}}s:16:\"\u0000*\u0000android_count\";i:2;s:12:\"\u0000*\u0000ios_count\";i:0;s:18:\"\u0000*\u0000android_devices\";O:50:\"Sly\\NotificationPusher\\Collection\\DeviceCollection\":1:{s:7:\"\u0000*\u0000coll\";C:13:\"ArrayIterator\":953:{x:i:0;a:2:{s:162:\"APA91bGCWGMQlh6kMYVVPUjnkDKtgLmYBiHxv1WY4r3zPjmXO3C0_UcvBCoOWkiiiC8lBc4JRILBDo29K0BtGNQKKQAA46tCvJocklTp3u7_x4q8Nz9CubNuqJN_OaMRBys_HWUqNXPLzIbodjEHV_bTc-CUKurnRQ\";O:35:\"Sly\\NotificationPusher\\Model\\Device\":2:{s:42:\"\u0000Sly\\NotificationPusher\\Model\\Device\u0000token\";s:162:\"APA91bGCWGMQlh6kMYVVPUjnkDKtgLmYBiHxv1WY4r3zPjmXO3C0_UcvBCoOWkiiiC8lBc4JRILBDo29K0BtGNQKKQAA46tCvJocklTp3u7_x4q8Nz9CubNuqJN_OaMRBys_HWUqNXPLzIbodjEHV_bTc-CUKurnRQ\";s:13:\"\u0000*\u0000parameters\";a:0:{}}s:162:\"APA91bEUPnqR3t8KDhE0YTsc_HnkoxFvw4WyUpRxISm2A_2Ep7orCySVKsh2oRVSQTVOhSZS_yYjP7gup5vEnuwz2JPXcxHCc19P98E2QVNyjhTP_NvDkcfkogVIHAHpgelyGRuvm8aQ-SAs9uirxd3iBHPlZb16zA\";O:35:\"Sly\\NotificationPusher\\Model\\Device\":2:{s:42:\"\u0000Sly\\NotificationPusher\\Model\\Device\u0000token\";s:162:\"APA91bEUPnqR3t8KDhE0YTsc_HnkoxFvw4WyUpRxISm2A_2Ep7orCySVKsh2oRVSQTVOhSZS_yYjP7gup5vEnuwz2JPXcxHCc19P98E2QVNyjhTP_NvDkcfkogVIHAHpgelyGRuvm8aQ-SAs9uirxd3iBHPlZb16zA\";s:13:\"\u0000*\u0000parameters\";a:0:{}}};m:a:0:{}}}s:10:\"\u0000*\u0000message\";O:36:\"Sly\\NotificationPusher\\Model\\Message\":2:{s:42:\"\u0000Sly\\NotificationPusher\\Model\\Message\u0000text\";s:32:\"John Smith is now following you!\";s:10:\"\u0000*\u0000options\";a:12:{s:5:\"badge\";i:1;s:5:\"sound\";s:12:\"example.aiff\";s:12:\"actionLocKey\";s:20:\"Action button title!\";s:6:\"locKey\";s:13:\"localized key\";s:7:\"locArgs\";a:2:{i:0;s:14:\"localized args\";i:1;s:14:\"localized args\";}s:11:\"launchImage\";s:9:\"image.jpg\";s:5:\"title\";s:21:\"InMyBag: New Follower\";s:6:\"custom\";a:0:{}s:5:\"notId\";i:7;s:5:\"style\";s:5:\"inbox\";s:8:\"ledColor\";a:4:{i:0;i:0;i:1;i:0;i:2;i:255;i:3;i:0;}s:16:\"vibrationPattern\";a:3:{i:0;i:500;i:1;i:250;i:2;i:500;}}}}s:5:\"queue\";N;s:5:\"delay\";N;s:6:\"\u0000*\u0000job\";N;}"}}

这是来自服务器表的行条目...

{"job":"Illuminate\\Queue\\CallQueuedHandler@call","data":{"command":"O:28:\"App\\Jobs\\Push\\SendPushFollow\":4:{s:34:\"\u0000App\\Jobs\\Push\\SendPushFollow\u0000push\";O:27:\"App\\Helpers\\Push\\PushFollow\":5:{s:14:\"\u0000*\u0000ios_devices\";O:50:\"Sly\\NotificationPusher\\Collection\\DeviceCollection\":1:{s:7:\"\u0000*\u0000coll\";O:13:\"ArrayIterator\":0:{}}s:16:\"\u0000*\u0000android_count\";i:2;s:12:\"\u0000*\u0000ios_count\";i:0;s:18:\"\u0000*\u0000android_devices\";O:50:\"Sly\\NotificationPusher\\Collection\\DeviceCollection\":1:{s:7:\"\u0000*\u0000coll\";O:13:\"ArrayIterator\":2:{s:162:\"APA91bGCWGMQlh6kMYVVPUjnkDKtgLmYBiHxv1WY4r3zPjmXO3C0_UcvBCoOWkiiiC8lBc4JRILBDo29K0BtGNQKKQAA46tCvJocklTp3u7_x4q8Nz9CubNuqJN_OaMRBys_HWUqNXPLzIbodjEHV_bTc-CUKurnRQ\";O:35:\"Sly\\NotificationPusher\\Model\\Device\":2:{s:42:\"\u0000Sly\\NotificationPusher\\Model\\Device\u0000token\";s:162:\"APA91bGCWGMQlh6kMYVVPUjnkDKtgLmYBiHxv1WY4r3zPjmXO3C0_UcvBCoOWkiiiC8lBc4JRILBDo29K0BtGNQKKQAA46tCvJocklTp3u7_x4q8Nz9CubNuqJN_OaMRBys_HWUqNXPLzIbodjEHV_bTc-CUKurnRQ\";s:13:\"\u0000*\u0000parameters\";a:0:{}}s:162:\"APA91bEUPnqR3t8KDhE0YTsc_HnkoxFvw4WyUpRxISm2A_2Ep7orCySVKsh2oRVSQTVOhSZS_yYjP7gup5vEnuwz2JPXcxHCc19P98E2QVNyjhTP_NvDkcfkogVIHAHpgelyGRuvm8aQ-SAs9uirxd3iBHPlZb16zA\";O:35:\"Sly\\NotificationPusher\\Model\\Device\":2:{s:42:\"\u0000Sly\\NotificationPusher\\Model\\Device\u0000token\";s:162:\"APA91bEUPnqR3t8KDhE0YTsc_HnkoxFvw4WyUpRxISm2A_2Ep7orCySVKsh2oRVSQTVOhSZS_yYjP7gup5vEnuwz2JPXcxHCc19P98E2QVNyjhTP_NvDkcfkogVIHAHpgelyGRuvm8aQ-SAs9uirxd3iBHPlZb16zA\";s:13:\"\u0000*\u0000parameters\";a:0:{}}}}s:10:\"\u0000*\u0000message\";O:36:\"Sly\\NotificationPusher\\Model\\Message\":2:{s:42:\"\u0000Sly\\NotificationPusher\\Model\\Message\u0000text\";s:32:\"John Smith is now following you!\";s:10:\"\u0000*\u0000options\";a:12:{s:5:\"badge\";i:1;s:5:\"sound\";s:12:\"example.aiff\";s:12:\"actionLocKey\";s:20:\"Action button title!\";s:6:\"locKey\";s:13:\"localized key\";s:7:\"locArgs\";a:2:{i:0;s:14:\"localized args\";i:1;s:14:\"localized args\";}s:11:\"launchImage\";s:9:\"image.jpg\";s:5:\"title\";s:21:\"InMyBag: New Follower\";s:6:\"custom\";a:0:{}s:5:\"notId\";i:10;s:5:\"style\";s:5:\"inbox\";s:8:\"ledColor\";a:4:{i:0;i:0;i:1;i:0;i:2;i:255;i:3;i:0;}s:16:\"vibrationPattern\";a:3:{i:0;i:500;i:1;i:250;i:2;i:500;}}}}s:5:\"queue\";N;s:5:\"delay\";N;s:6:\"\u0000*\u0000job\";N;}"}}

我运行了一个在线文本差异，发现该 blob 的序列化数据部分在 ArrayIterator 部分中存在一些差异（如错误日志指出的那样）。看起来差异来自我的本地计算机和服务器上的 PushNotification::DeviceCollection 对象的序列化方式不同。在我的测试中，我在本地和服务器上使用相同的 POST 数据访问 api 端点，以确保序列化的输出应该相同，但事实并非如此。

我不确定如何解决这个问题。我不知道这在技术上是否是 PushNotification 包的错误（我没有看到任何与此问题相关的错误报告），或者这只是我在掩饰的其他问题。

另外，顺便说一句，我正在使用另一个队列来发送 KeenIO 事件，它使用与此 Push 结构类似的类结构并且它没有任何问题，所以我真的觉得这肯定是 PushNotification 包的问题不知怎的……有什么想法吗？？

已解决

所以事实证明这是 PHP 版本的问题。我的服务器运行的是 5.6，当我在 PHP 7.0 上制作另一个 droplet 并克隆服务器时，一切都开始工作了。我让原始服务器保持启动并运行，因此它可以用作使用 beanstalkd 的推送通知的队列处理器，它的工作就像一个冠军。

编辑

我正在使用主管运行 queue:work 命令。我跑了

php artisan queue:restart

并且我已经确保在运行新测试时通过命令行执行 kill 命令完全停止工匠进程。再次，队列工作人员对我在服务器上的 KeenIO 作业没有任何问题，只是 PushNotification 作业。

这是工作类别：

<?php namespace App\Jobs\Push;

use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Bus\SelfHandling;
use Illuminate\Contracts\Queue\ShouldQueue;
use App\Jobs\SendPushEvent;
use App\Helpers\Push\PushFollow;

class SendPushFollow extends SendPushEvent implements SelfHandling, ShouldQueue {
    use InteractsWithQueue, SerializesModels;
    private $push;
    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($follower, $followee)
    {
        $this->push = new PushFollow($follower, $followee);
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle(){
        $this->push->send();
    }
}

这是 PushFollow 类，其中包含所有 PushNotification 逻辑。

<?php namespace App\Helpers\Push;

use PushNotification;
use App\Helpers\Push\Push;
use Log;

class PushFollow extends Push {
    /**
     * This builds the default notification.
     * @param array  $data the passed in data array
     * @param [type] $type android or iOS
     */
    public function __construct ($follower, $followee) {
        $_ios_devices = [];
        $_android_devices = [];
        $this->ios_count = 0;
        $this->android_count = 0;

        foreach($followee->devices as $_device){
            if($_device->platform == "ios"){
                $_ios_devices[] = PushNotification::Device($_device->identifier);
                $this->ios_count++;
            } elseif ($_device->platform == "android") {
                $_android_devices[] = PushNotification::Device($_device->identifier);
                $this->android_count++;
            }
        }

        Log::info('FINISHED BUILDING THE LISTS!!!');

        $this->ios_devices = PushNotification::DeviceCollection($_ios_devices);
        $this->android_devices = PushNotification::DeviceCollection($_android_devices);

        Log::info('SET THE DEVICE COLLECTIONS');

        $this->message = PushNotification::Message($follower->profile->name.' is now following you!',[
            'badge' => 1,
            'sound' => 'example.aiff',
            'actionLocKey' => 'Action button title!',
            'locKey' => 'localized key',
            'locArgs' => array(
                'localized args',
                'localized args',
            ),
            'launchImage' => 'image.jpg',
            'title' => env('APP_NAME').': New Follower',
            'custom' => [],
            'notId' => rand(1, 20),
            'style' => 'inbox',
            /*
            'actions' => [
                ['icon' => "emailGuests", 'title' => "EMAIL GUESTS", 'callback' => "app.emailGuests"],
                [ 'icon' => "snooze", 'title' => "SNOOZE", 'callback' => "app.snooze"],
            ],
            */
            'ledColor' => [0, 0, 255, 0],
            'vibrationPattern' => [500, 250, 500],

        ]);

        Log::info('SET THE MESSAGE');
    }

    public function send () {
        Log::info('CALLING THE SEND METHOD');
        if($this->android_count) {
            PushNotification::app(env('ANDROID_PUSH_NAME'))
                ->to($this->android_devices)
                ->send($this->message);
        }

        if($this->ios_count){
            PushNotification::app(env('IOS_PUSH_NAME'))
                ->to($this->ios_devices)
                ->send($this->message);
        }
    }
}

这是我所有不同的推送类扩展的推送类。

<?php namespace App\Helpers\Push;

abstract class Push {
    protected $ios_devices;
    protected $android_count;
    protected $ios_count;
    protected $android_devices;
    protected $message;
}

哦，这也是堆栈跟踪。

#0 [internal function]: Illuminate\Foundation\Bootstrap\HandleExceptions->handleError(2, 'Erroneous data ...', '/home/forge/def...', 74, Array)
#1 {path_to_project}/vendor/laravel/framework/src/Illuminate/Queue/CallQueuedHandler.php(74): unserialize('O:28:"App\\Jobs\\...')
#2 {path_to_project}/vendor/laravel/framework/src/Illuminate/Queue/Jobs/Job.php(212): Illuminate\Queue\CallQueuedHandler->failed(Array)
#3 {path_to_project}/vendor/laravel/framework/src/Illuminate/Queue/Worker.php(261): Illuminate\Queue\Jobs\Job->failed()
#4 {path_to_project}/vendor/laravel/framework/src/Illuminate/Queue/Worker.php(201): Illuminate\Queue\Worker->logFailedJob('database', Object(Illuminate\Queue\Jobs\DatabaseJob))
#5 {path_to_project}/vendor/laravel/framework/src/Illuminate/Queue/Worker.php(159): Illuminate\Queue\Worker->process('database', Object(Illuminate\Queue\Jobs\DatabaseJob), '5', 0)
#6 {path_to_project}/vendor/laravel/framework/src/Illuminate/Queue/Worker.php(111): Illuminate\Queue\Worker->pop(NULL, 'keen,push_notif...', 0, 3, '5')
#7 {path_to_project}/vendor/laravel/framework/src/Illuminate/Queue/Worker.php(87): Illuminate\Queue\Worker->runNextJobForDaemon(NULL, 'keen,push_notif...', 0, 3, '5')
#8 {path_to_project}/vendor/laravel/framework/src/Illuminate/Queue/Console/WorkCommand.php(103): Illuminate\Queue\Worker->daemon(NULL, 'keen,push_notif...', 0, 128, 3, '5')
#9 {path_to_project}/vendor/laravel/framework/src/Illuminate/Queue/Console/WorkCommand.php(71): Illuminate\Queue\Console\WorkCommand->runWorker(NULL, 'keen,push_notif...', 0, 128, true)
#10 [internal function]: Illuminate\Queue\Console\WorkCommand->fire()
#11 {path_to_project}/vendor/laravel/framework/src/Illuminate/Container/Container.php(507): call_user_func_array(Array, Array)
#12 {path_to_project}/vendor/laravel/framework/src/Illuminate/Console/Command.php(150): Illuminate\Container\Container->call(Array)
#13 {path_to_project}/vendor/symfony/console/Command/Command.php(256): Illuminate\Console\Command->execute(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#14 {path_to_project}/vendor/laravel/framework/src/Illuminate/Console/Command.php(136): Symfony\Component\Console\Command\Command->run(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#15 {path_to_project}/vendor/symfony/console/Application.php(837): Illuminate\Console\Command->run(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#16 {path_to_project}/vendor/symfony/console/Application.php(189): Symfony\Component\Console\Application->doRunCommand(Object(Illuminate\Queue\Console\WorkCommand), Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#17 {path_to_project}/vendor/symfony/console/Application.php(120): Symfony\Component\Console\Application->doRun(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#18 {path_to_project}/vendor/laravel/framework/src/Illuminate/Foundation/Console/Kernel.php(107): Symfony\Component\Console\Application->run(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#19 {path_to_project}/artisan(36): Illuminate\Foundation\Console\Kernel->handle(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#20 {main}

【问题讨论】：

  • 您是否在守护进程？如果您使用的是 Upstart 或 Supervisord 之类的东西，您是否尝试过重置守护程序？我知道如果你在运行 daemon 命令后更改脚本，你需要重置它，否则它不会接受更改。
  • @maiorano84 查看我的编辑。

标签： php laravel serialization push-notification laravel-5


【解决方案1】：

所以事实证明这是 PHP 版本的问题。我的服务器运行的是 5.6，当我在 PHP 7.0 上制作另一个 droplet 并克隆服务器时，一切都开始工作了。我让原始服务器保持启动并运行，因此它可以用作使用 beanstalkd 的推送通知的队列处理器，它的工作就像一个冠军。

【讨论】：

  • Laravel 使用了serialize()，它在 PHP 7 中发生了重大变化。这就是您遇到问题的原因。我希望你已经吸取了教训，并且在开发和生产过程中不会使用不同的主要版本。
【解决方案2】：

很抱歉听到您使用的所有 php 版本的工作，但我也经常遇到这个问题，而且您似乎只需要通过运行来清除缓存：

php artisan route:cache

在 Laravel 生成缓存后尝试安装 composer 包时，这种情况很常见。

【讨论】：

  • 谢谢，我在同样的问题上疯了一个小时——但这解决了它。
猜你喜欢
  • 1970-01-01
  • 1970-01-01
  • 2013-12-25
  • 2021-12-03
  • 2011-04-05
  • 1970-01-01
  • 2015-03-24
相关资源
最近更新 更多
热门标签
Java Python linux javascript Mysql C# Docker 算法 前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库 数据结构 大数据 js 机器学习 微服务 Android Go 程序员 面试 JVM ASP.net core 云原生 人工智能 后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习 多线程 React 架构 devops 爬虫 云计算 Spring Boot LeetCode