PushTask.php 513 B

123456789101112131415161718192021222324252627
  1. <?php
  2. namespace App\Tasks;
  3. use App\Module\Chat;
  4. use Hhxsv5\LaravelS\Swoole\Task\Task;
  5. class PushTask extends Task
  6. {
  7. private $lists;
  8. /**
  9. * PushTask constructor.
  10. * @param array $lists [fd, msg]
  11. */
  12. public function __construct($lists)
  13. {
  14. $this->lists = $lists;
  15. }
  16. public function handle()
  17. {
  18. $swoole = app('swoole');
  19. foreach ($this->lists AS $item) {
  20. $swoole->push($item['fd'], Chat::formatMsgSend($item['msg']));
  21. }
  22. }
  23. }