Laravel5.3和Workerman結合使用（異步）

php?artisan?make:command?SendEmail

namespace?AppConsoleCommands;  use?IlluminateConsoleCommand; use?IlluminateSupportFacadesLog; use?IlluminateSupportFacadesMail; use?IlluminateMailMessage; use?WorkermanWorker;  require?app_path('Workerman/Workerman_Linux/Autoloader.php');  class?SendEmail?extends?Command { ????/** ?????*?The?name?and?signature?of?the?console?command. ?????* ?????*?@var?string ?????*/ ????protected?$signature?=?'send:email?{action}';  ????/** ?????*?The?console?command?description. ?????* ?????*?@var?string ?????*/ ????protected?$description?=?'Command?description';  ????/** ?????*?Create?a?new?command?instance. ?????* ?????*?@return?void ?????*/ ????public?function?__construct() ????{ ????????parent::__construct(); ????}  ????/** ?????*?Execute?the?console?command. ?????* ?????*/ ????public?function?handle() ????{ ????????$mailWorker?=?new?Worker('Text://0.0.0.0:12345'); ????????$mailWorker->count?=?4; ????????$mailWorker->name?=?'MailWorker'; ????????$mailWorker->onMessage?=?function?($connection,?$emailData)?{ ????????????$emailData?=?json_decode($emailData); ????????????$name?=?$emailData->name; ????????????$email?=?$emailData->to; ????????????Mail::raw('注冊成功',?function?(Message?$message)?use?($email)?{ ????????????????$message->to($email)->subject(trans('mail.welcome_register')); ????????????});  ????????????//?寫入日志 ????????????Log::useFiles(storage_path()?.?'/logs/event.log',?'info'); ????????????Log::info("{$name}({$email})注冊成功"); ????????};  ????????Worker::runAll(); ????} }

/** ?????*?Parse?command. ?????*?php?yourfile.php?start?|?stop?|?restart?|?reload?|?status ?????* ?????*?@return?void ?????*/ ????protected?static?function?parseCommand() ????{ ????????global?$argv;  ????????if($argv[0]?==?'artisan')?//?laravel框架下處理 ????????{ ????????????//?Check?argv; ????????????$start_file?=?$argv[1];  ????????????if?(!isset($argv[2]))?{ ????????????????exit("Usage:?php?yourfile.php?{start|stop|restart|reload|status}n"); ????????????}  ????????????//?Get?command. ????????????$command??=?trim($argv[2]); ????????????$command2?=?isset($argv[3])???$argv[3]?:?''; ????????} ????????else ????????{ ????????????//?Check?argv; ????????????$start_file?=?$argv[0]; ????????????if?(!isset($argv[1]))?{ ????????????????exit("Usage:?php?yourfile.php?{start|stop|restart|reload|status}n"); ????????????}  ????????????//?Get?command. ????????????$command?=?trim($argv[1]); ????????????$command2?=?isset($argv[2])???$argv[2]?:?''; ????????} ???? ?????//?只要略修改上面的參數解析部分即可? ?????.......................... }

appListenersSendMailEventListener.php：

<?php namespace AppListeners;  use AppEventsSendMailEvent;class SendMailEventListener extends BaseEventListener {     /**      * Create the event listener.      *      * @return void      */     public function __construct()     {         //     }      /**      * Handle the event.      *      * @param  SendMailEvent $event      * @return void      */     public function handle($event)     {         // 發送郵件通知注冊成功         if ($event->user-&gt;scene?==?'do_register')?{ ????????????$email?=?$event-&gt;user-&gt;email;  ????????????//$ip?=?"mail_worker?的ip"?,本機的話為127.0.0.1 ????????????$socket?=?@stream_socket_client('tcp://127.0.0.1:12345',?$errno,?$errmsg,?5); ????????????if?($socket)?{ ????????????????$mail_data?=?['name'=&gt;$event-&gt;user-&gt;name,'to'?=&gt;?$email,?'content'?=&gt;?trans('mail.welcome_register')]; ????????????????//?注意，Text協議后面"n"換行符是必須的 ????????????????$mail_buffer?=?json_encode($mail_data)?.?"n"; ????????????????//?發送給mail?worker ????????????????fwrite($socket,?$mail_buffer); ????????????}  //????????????$email?=?$event-&gt;user-&gt;email; //????????????Mail::raw('注冊成功',function?(Message?$message)?use?($email)?{ //????????????????$message-&gt;to($email)-&gt;subject(trans('mail.welcome_register')); //????????????}); ????????} ????} }