我有一个Laravel 5.3安装程序，它作为纯API应用程序运行，需要从几个不同的应用程序连接。

一切工作正常（毕竟，我们谈论的是Laravel：P），除了我搞不清楚一件事：

我有一个MQTT服务器，它正在侦听来自多个设备的消息（无关紧要）。这些消息包含有关需要在后端调用的作业类和方法的信息。

我不能直接调用API，设备根本不支持此功能（虽然可以，但是比使用MQTT传输数据要付出更多的努力）。我的想法是将一个新作业推送到队列中，以定义要调用的Laravel作业类（以及哪种方法）。问题是JSON序列化…

MQTT服务器在NodeJS上运行，我的队列在Redis上运行。我记得Taylor的一条推文，他提到理论上可以序列化所需的JSON并从Laravel外部推送到队列，并由Laravel处理工作。

有人知道如何解决这个问题吗？是否有关于JSON结构的文档？

我还应该提到，Laravel工作者消耗的此解决方案NodeJS推送队列对我不起作用。与上面相同的结果，作业被放置在队列上，但是被丢弃而没有被处理或引发任何错误。

Redis中排队事件的示例数据结构如下所示：

"{\"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}"

基于该结构，我认为该对象（需要序列化）应类似于以下内容：

{
"job":"EventClass@method", //<-- Just a name
"data":{
    "event":"EventClass", //<-- Just a name
    "name":"EventName", //<-- Just a name
    "data":{
    "key":"value"
    "event":"EventName" //<-- Same as data.name
    "class":"EventClass@method" //<-- This is actually being called
    }
}

Laravel实际放入队列的内容中还包含其他信息（例如时间戳，用户模型标识符等），但是我认为触发该工作不是必需的。

数据需要在JS中进行序列化，以实现与php
serialize（）类似的输出（或更佳的方法是，获取可以被php的unserialize（）进行非序列化的字符串）。

我通过php-serialization NPM模块实现了这一点（感谢Simon
Svensson），但是Laravel并没有消耗这项工作（被丢弃但未执行）

在此先感谢您的帮助:)

编辑解决方案

感谢Simon的回答，这是有关如何在Javascript中序列化作业数据并将其推送到Laravel队列（并使Laravel自动处理整个事情）的解决方案。

请注意，这是在Redis中使用队列的示例。当使用Beanstalkd或基于数据库的队列时，这看起来可能有所不同（或没有）。

这是我成功使用的代码：

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个字符，我认为保持此长度是个好主意）。

最初推动作业时，尝试次数应设置为1。如果Laravel无法处理该作业，它将把它推回到队列中并增加尝试次数。