douba1904
2018-02-16 23:41
浏览 45
已采纳

Laravel Queue如何在作业句柄方法中获取数据

I have created a sequence of messsages to be sent in text messages through twilio.

I have created a controller to put the messages in a queue with the data received in the post request. Here is my controller to make queue:

public function make_queue(Request $request)
    {
        $data = array(
            'phone' => $request->input('phone'),
            'message'=> $request->input('message'),
            'token'=> $request->input('token')',
            'sid'=> $request->input('sid')
        );

        ProcessMessages::dispatch($data)
        ->delay(now()->addSeconds(15));

        return 'message will be sent';
    }

And in handle the job , in the handle function

public function handle()
{
   $token = should_come_from job;
   $sid = should_come_from job;
   $ids = should_come_from job;
   $msg = should_come_from job;
   try{
        //send message
      }
   catch (exception $e)
          {
             handle exception
          }
      }

I am not able to figure out how do I get the values in the handle function to actually send the message....

图片转代码服务由CSDN问答提供 功能建议

我创建了一系列通过twilio在短信中发送的消息。

我创建了一个控制器,将消息放入队列中,并在post请求中接收数据。 这是我的队列控制器:

  public function make_queue(Request $ request)
 {
 $ data = array(
'phone'=> $ request)  - >输入('手机'),
'消息'=> $ request->输入('消息'),
'令牌'=> $ request->输入('令牌')'  ,
'sid'=> $ request-> input('sid')
); 
 
 ProcessMessages :: dispatch($ data)
  - > delay(now() - > addSeconds  (15)); 
 
返回'消息将被发送'; 
} 
   
 
 

并处理作业,在句柄函数中

 公共函数句柄()
 {
 $ token = should_come_from job; 
 $ sid = should_come_from job; 
 $ ids = should_come_from job; 
 $ msg = should_come_from job  ; 
尝试{
 //发送消息
} 
 catch(异常$ e)
 {
处理异常
} 
} 
   
 
 <  p>我无法弄清楚如何获取handle函数中的值来实际发送 消息....  
 
  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 邀请回答

1条回答 默认 最新

  • dqrb4228 2018-02-16 23:55
    已采纳

    You need to add a constructor method in your job handler class (ProcessMessages), for example:

    // namespace and use statements...
    
    class ProcessMessages implements ShouldQueue
    {
        use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
    
        protected $data;
    
        public function __construct(array $data)
        {
            $this->data = $data;
        }
    
        public function handle()
        {
            $token = $this->data['token'];
            // ...
        }
    }
    

    Once you have written your job class, you may dispatch it using the dispatch method on the job itself. The arguments passed to the dispatch method will be given to the job's constructor. Read about dispatching Jobs.

    点赞 评论

相关推荐 更多相似问题