我愿意使用queue
发送电子邮件至电子邮件地址列表。不使用队列我的代码工作正常,但是队列显示以下错误:
Exception in Queue.php line 86: Serialization of 'Closure' is not allowed
in /home/hizbul/Development/Projects/Laravel/fastskool/vendor/laravel/framework/src/Illuminate/Queue/Queue.php line 86
at serialize(object(SendMessageToStudent)) in Queue.php line 86
at Queue->createPayload(object(SendMessageToStudent), '') in DatabaseQueue.php line 81
at DatabaseQueue->push(object(SendMessageToStudent)) in Dispatcher.php line 184
at Dispatcher->pushCommandToQueue(object(DatabaseQueue), object(SendMessageToStudent)) in Dispatcher.php line 159
at Dispatcher->dispatchToQueue(object(SendMessageToStudent)) in Dispatcher.php line 73
at Dispatcher->dispatch(object(SendMessageToStudent)) in DispatchesJobs.php line 17
at Controller->dispatch(object(SendMessageToStudent)) in MessageController.php line 49
at MessageController->store(object(Request))
at call_user_func_array(array(object(MessageController), 'store'), array(object(Request))) in Controller.php line 55
at Controller->callAction('store', array(object(Request))) in ControllerDispatcher.php line 44
at ControllerDispatcher->dispatch(object(Route), object(MessageController), 'store') in Route.php line 189
at Route->runController() in Route.php line 144
at Route->run(object(Request)) in Router.php line 653
at Router->IlluminateRouting{closure}(object(Request)) in Pipeline.php line 53
at Pipeline->IlluminateRouting{closure}(object(Request)) in StaffAndAdmin.php line 40
at StaffAndAdmin->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in ModuleManager.php line 29
at ModuleManager->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in SwitchDatabaseConnection.php line 36
at SwitchDatabaseConnection->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in SubstituteBindings.php line 41
at SubstituteBindings->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in VerifyCsrfToken.php line 65
at VerifyCsrfToken->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in ShareErrorsFromSession.php line 49
at ShareErrorsFromSession->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in StartSession.php line 64
at StartSession->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in AddQueuedCookiesToResponse.php line 37
at AddQueuedCookiesToResponse->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in EncryptCookies.php line 59
at EncryptCookies->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in Pipeline.php line 104
at Pipeline->then(object(Closure)) in Router.php line 655
at Router->runRouteWithinStack(object(Route), object(Request)) in Router.php line 629
at Router->dispatchToRoute(object(Request)) in Router.php line 607
at Router->dispatch(object(Request)) in Kernel.php line 268
at Kernel->IlluminateFoundationHttp{closure}(object(Request)) in Pipeline.php line 53
at Pipeline->IlluminateRouting{closure}(object(Request)) in Debugbar.php line 51
at Debugbar->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in CheckForMaintenanceMode.php line 46
at CheckForMaintenanceMode->handle(object(Request), object(Closure)) in Pipeline.php line 137
at Pipeline->IlluminatePipeline{closure}(object(Request)) in Pipeline.php line 33
at Pipeline->IlluminateRouting{closure}(object(Request)) in Pipeline.php line 104
at Pipeline->then(object(Closure)) in Kernel.php line 150
at Kernel->sendRequestThroughRouter(object(Request)) in Kernel.php line 117
at Kernel->handle(object(Request)) in index.php line 68
我正在使用database
作为队列驱动程序。
以下是我的队列作业处理程序代码:
class SendMessageToStudent implements ShouldQueue
{
use InteractsWithQueue, Queueable, SerializesModels;
private $data;
/**
* Create a new job instance.
*
* @param Request $request
*/
public function __construct(Request $request)
{
$this->data = $request;
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
$student = $this->data;
$arrStudent = (new Message())->getEmailAddressList($student);
Mail::to($arrStudent)->send(new MessageSent($student));
}
}
和调度程序代码:
$this->dispatch(new SendMessageToStudent($request));
我期望有可行的解决方案。
您不能序列化请求。只有雄辩的模型才能被序列化且未进行。请参阅:https://laravel.com/docs/5.2/queues#writing-job-classes
您应该使用$request->all()
而不是$request
。由于请求被视为关闭。
尝试从构造函数中删除这一行:
$this->message = new Message();
,在手柄中直接初始化。
$student = $this->data;
$arrStudent = (new Message())->getEmailAddressList($student);
Mail::to($arrStudent)->send(new MessageSent($student));
它发生在我的Laravel 5.6中。我刚刚添加了:
use IlluminateSupportFacadesMail;
一切都很好。
您可以在请求类中实现可序列化接口。我为此做了BaseRequest课,并从中继承了所有请求。
class BaseRequest extends FormRequest implements Serializable
{
/** @inheritDoc */
public function serialize()
{
return json_encode($this->all());
}
/** @inheritDoc */
public function unserialize($serialized)
{
$data = json_decode($serialized, true);
$this->initialize($data);
}
}