Laravel结合Pusher实现数据实时推送

composer require pusher/pusher-php-server

'default' => env('BROADCAST_DRIVER', 'pusher'),
'connections' => [

   'pusher' => [
   'driver' => 'pusher',
   'key' => env('PUSHER_APP_KEY'),
   'secret' => env('PUSHER_APP_SECRET'),
   'app_id' => env('PUSHER_APP_ID'),
   'options' => [
       'cluster' => env('PUSHER_APP_CLUSTER','ap3'),
       'useTLS' => true,
       'curl_options' => [
           CURLOPT_SSL_VERIFYHOST => 0,
            CURLOPT_SSL_VERIFYPEER => 0,
        ]
     ],
   ],
]

BROADCAST_DRIVER=pusher
PUSHER_APP_ID=xxxxxxx
PUSHER_APP_KEY=xxxxxxx
PUSHER_APP_SECRET=xxxxxxx
PUSHER_APP_CLUSTER=xxxxxxx

php artisan make:event PusherEvent

<?php

namespace App\Events;

use Illuminate\Broadcasting\Channel;
use Illuminate\Queue\SerializesModels;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Broadcasting\PresenceChannel;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;

class PusherEvent implements ShouldBroadcast
{
    use SerializesModels;

    public $info;

    /**
     * Create a new event instance.
     *
     * @return void
     */
    public function __construct($info)
    {
       $this->info = $info;
    }


    /**
     * 指定广播频道
     * @return string[]
     */
    public function broadcastOn()
    {
        return ['my-channel'];
    }


    /**
     * 指定广播事件
     * @return string
     */
    public function broadcastAs()
    {
        return 'my-event';
    }


    public function  broadcastWith()
    {
        return ['info' => $this->info];
    }
}

<?php

namespace App\Http\Controllers;

use App\Events\PusherEvent;
use Illuminate\Http\Request;

class HomeController extends Controller
{

    public function index()
    {
        return view('index');
    }

    public function test(Request $request)
    {
        try {
            event(new PusherEvent('测试'));
            dd('success');
        } catch (\Exception $exception) {
            dd($exception->getMessage());
        }
    }
}

php artisan make:command PusherEventCommand

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;

class PusherEventCommand extends Command
{

    protected $signature = 'pusher:test {message}';
    protected $description = 'pusher test';

    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        event(new \App\Events\PusherEvent($this->argument('message')));
    }

}

protected $commands = [
      \App\Console\Commands\PusherEventCommand::class,
];

php artisan pusher:test "这是一个命令测试"