从 Laravel 外部推送到 Laravel 队列(NodeJS)

This is the code I successfully used:

var serialize,Class,job,jobUser,jobData,serialized,result;

serialize = require('php-serialization').serialize;
Class = require('php-serialization').Class;

job = new Class("App\Events\NotificationEvent");

job.__addAttr__("name","string","notification","string","protected");

jobData = new Class();
jobData.__addAttr__("testkey","string","testval","string");
jobData.__addAttr__("timestamp","string","2017-02-24 11:07:48","string");
jobData.__addAttr__("event","string","notification","string");
jobData.__addAttr__("class","string","App\Events\NotificationEvent","string");
job.__addAttr__("data","string",jobData,"array","public");

job.__addAttr__("channel","string",null,"null","protected");

jobUser = new Class("Illuminate\Contracts\Database\ModelIdentifier")
jobUser.__addAttr__("class","string","App\User","string","public");
jobUser.__addAttr__("id","string",2,"integer","public");
job.__addAttr__("user","string",jobUser,"object","protected");

job.__addAttr__("socket","string",null,"null","public");

serialized = serialize(job,"object");

result = {
    job:"Illuminate\Broadcasting\BroadcastEvent",
    data:{
        event:serialized
    },
    id:"XuUKRTf8CTSdzaVgp2gRcvmxQqLcpBUG",
    attempts:1
};

queue.rpush('queues:default',JSON.stringify(result));

我还没有弄清楚 ID 的确切用途，我成功地将作业推送到队列中，并且始终具有相同的 ID.我想如果你正在快速推动工作并且它们同时被存储，这可能是一个问题.因为它是一个字符串，你可以用任何你喜欢的随机 ID 替换它(Laravel 生成的随机 ID 是 32 个字符，我认为保持这个长度是个好主意).

{
    "job": "Illuminate\Queue\CallQueuedHandler@call",
    "data": {
        "commandName": "App\Jobs\MyJobClass",
        "command": "O:19:"App\Jobs\MyJobClass"... /* stuff */"
    }
}

{
  "job": "Illuminate\Broadcasting\BroadcastEvent",
  "data": {
    "event": "O:28:"App\Events\NotificationEvent":5:{s:7:"u0000*u0000name";s:12:"notification";s:4:"data";a:4:{s:4:"testkey";s:14:"testval";s:9:"timestamp";s:19:"2017-02-24 11:07:48";s:5:"event";s:12:"notification";s:5:"class";s:28:"App\Events\NotificationEvent";}s:10:"u0000*u0000channel";N;s:7:"u0000*u0000user";O:45:"Illuminate\Contracts\Database\ModelIdentifier":2:{s:5:"class";s:8:"App\User";s:2:"id";i:2;}s:6:"socket";N;}"
  },
  "id": "XuUKRTf8CTSdzaVgp2gRcvmxQqLcpBUG",
  "attempts": 1
}

O:28:"AppEventsNotificationEvent":5:{
    // protected $name = 'notification'
    s:7:" * name";s:12:"notification";

    // public $data = array(...)
    s:4:"data";a:4:{
        // 'testkey => 'testval'
        s:4:"testkey";s:14:"testval";

        // 'timestamp' => '2017-02-24 11:07:48';
        s:9:"timestamp";s:19:"2017-02-24 11:07:48";

        // 'event' => 'notification';
        s:5:"event";s:12:"notification";

        // 'class' => AppEventsNotificationEvent::class;
        s:5:"class";s:28:"AppEventsNotificationEvent";
    }

    // protected $channel = null;
    s:10:"*channel";N;

    // protected $user = (instance of ModelIdentifier)
    s:7:"*user";O:45:"IlluminateContractsDatabaseModelIdentifier":2:{
        // public $class = AppUser::class;
        s:5:"class";s:8:"AppUser";

        // public $id = 2;
        s:2:"id";i:2;
    }

    // public $socket = null;
    s:6:"socket";N;
}