Laravel 5.3+Passport通过Socket.io实现广播频道授权问题咨询

嘿，针对你用Laravel 5.3 + Passport做API后端、Angular前端，还要给Laravel广播事件做授权的需求，我整理了一套适配你技术栈的完整方案，一步步来：

先把你提到的boot方法补全，重点是注册频道授权逻辑，确保只有认证用户能访问对应频道：

public function boot()
{
    // 给广播路由加上api认证中间件
    Broadcast::routes(['middleware' => ['auth:api']]);

    // 注册动态频道的授权回调
    Broadcast::channel('notifications.{userId}', function ($user, $userId) {
        // 验证当前用户是否有权订阅该用户的通知频道
        return (int) $user->id === (int) $userId;
    });

    require base_path('routes/channels.php');
}

这里的notifications.{userId}是动态私有频道，回调里的$user是通过auth:api中间件认证后的用户实例，对比ID确保用户只能订阅自己的通知频道。

前端用Socket.io连接时，默认不会携带Passport的Bearer Token，所以需要修改Socket服务器代码，在握手阶段验证Token有效性：

const io = require('socket.io')(server);
const axios = require('axios');

// Socket.io的握手认证中间件
io.use(async (socket, next) => {
    // 从握手参数里获取前端传的Token
    const token = socket.handshake.query.token;
    if (!token) {
        return next(new Error('请先登录'));
    }

    try {
        // 调用Laravel的API验证Token
        const response = await axios.get('http://你的LaravelAPI域名/api/user', {
            headers: {
                'Authorization': `Bearer ${token}`
            }
        });

        // 把验证后的用户信息挂载到socket对象上
        socket.user = response.data;
        next();
    } catch (error) {
        next(new Error('Token无效，请重新登录'));
    }
});

// 用户连接成功后，自动加入自己的通知频道
io.on('connection', (socket) => {
    console.log('用户已连接:', socket.user.id);
    socket.join(`notifications.${socket.user.id}`);
});

对应的Angular前端Socket客户端代码，要在连接时带上Token：

import * as io from 'socket.io-client';

// 从本地存储获取Passport的Access Token
const token = localStorage.getItem('access_token');
// 连接Socket服务器并携带Token
const socket = io('http://你的Socket服务器域名', {
    query: {
        token: token
    }
});

// 监听通知事件
socket.on('notification', (data) => {
    console.log('收到新通知:', data);
    // 这里写你的通知展示逻辑
});

创建一个广播事件类，指定它要发送到私有频道：

namespace App\Events;

use App\User;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;

class NewNotification implements ShouldBroadcast
{
    use Dispatchable, InteractsWithSockets;

    public $notificationContent;

    public function __construct($notificationContent)
    {
        $this->notificationContent = $notificationContent;
    }

    // 指定广播到的私有频道
    public function broadcastOn()
    {
        // 这里假设你要给某个用户发通知，传入对应的user实例
        return new PrivateChannel('notifications.' . auth()->user()->id);
    }

    // 自定义广播事件名称（可选，默认是类名）
    public function broadcastAs()
    {
        return 'notification';
    }
}

1. 用户通过Angular登录，获取Passport的Access Token并存入本地存储；
2. Angular用Token连接Socket.io服务器，服务器验证通过后让用户加入自己的通知频道；
3. 在Laravel后端触发广播事件：

event(new \App\Events\NewNotification(['title' => '新消息', 'content' => '你有一条未读通知']));

4. 对应的用户就能在Angular端实时收到通知，其他用户无法订阅该频道，保证了授权安全性。

• 确保Laravel的广播驱动配置为Redis，在.env里设置：BROADCAST_DRIVER=redis；
• 启动Redis服务，同时运行Laravel队列worker：php artisan queue:work（广播事件默认会进入队列处理）；
• Socket.io服务器要和Laravel共享同一个Redis实例，这样Laravel广播的事件才能被Socket.io接收并推送给客户端。

内容的提问来源于stack exchange，提问作者Mohammad_Hosseini