Symfony 5集成Pusher实现私聊时会话消息隔离问题求解

解决方案 #

方案一：无需私有频道，快速实现会话消息隔离

你之前拼接messaging_id不生效的核心原因是前后端使用的频道名没有完全对齐，只要统一按会话ID拆分公共频道即可解决串消息问题：

1. 后端Controller修改触发事件的频道名，拼接当前会话ID：

// 把原来的my-channel替换为带会话ID的频道名
if ($pusher->trigger('chat-' . $messaging->getId(), 'my_event', $data)) {
    echo 'success';
} else {
    header('', true, 403);
    echo 'error';
}

2. 前端渲染页面时把当前会话的messaging_id注入到全局变量，修改JS订阅逻辑：

// 示例：Twig模板里输出当前会话ID，你可以根据自己的模板引擎调整
const CURRENT_MESSAGING_ID = {{ messaging.id }};

var pusher = new Pusher('ba75523bee28d7c644f2', {
    cluster: 'eu',
});
// 订阅对应会话的专属频道
var channel = pusher.subscribe('chat-' + CURRENT_MESSAGING_ID);

这个方案不需要做鉴权，只要前后端频道名完全一致，即可实现每个会话的消息仅在对应频道下发，不会串到其他会话。

方案二：使用私有频道+鉴权，保证会话安全性

如果你需要限制只有会话参与成员才能接收消息，就需要使用带private-前缀的私有频道，按以下步骤完成鉴权配置：

1. 前端修改Pusher初始化配置，新增鉴权接口地址：

var pusher = new Pusher('ba75523bee28d7c644f2', {
    cluster: 'eu',
    authEndpoint: '/pusher/auth', // 替换为你自己的Symfony鉴权路由
    auth: {
        headers: {
            'X-CSRF-Token': '{{ csrf_token('pusher_auth') }}' // 可选，添加CSRF校验提升安全性
        }
    }
});
// 订阅带private前缀的私有频道
var channel = pusher.subscribe('private-chat-' + CURRENT_MESSAGING_ID);

2. Symfony新增Pusher鉴权路由与逻辑：

/**
 * @Route("/pusher/auth", name="pusher_auth")
 */
public function pusherAuth(Request $request)
{
    // 校验用户登录状态
    $user = $this->getUser();
    if (!$user) {
        return new JsonResponse([], 403);
    }

    // 初始化Pusher实例
    $options = [
        'cluster' => 'eu',
        'useTLS' => true
    ];
    $pusher = new Pusher(
        'ba75523bee28d7c644f2',
        '9597b6daf0fb4e20fda2',
        '1266737',
        $options
    );

    // 获取Pusher鉴权请求参数
    $channelName = $request->request->get('channel_name');
    $socketId = $request->request->get('socket_id');

    // 解析频道名中的会话ID，校验当前用户是否为会话成员
    $messagingId = str_replace('private-chat-', '', $channelName);
    $messaging = $this->getDoctrine()->getRepository(Messaging::class)->find($messagingId);
    // 注意：hasMember为示例方法，你需要替换为自己的业务逻辑，判断用户是否属于该会话
    if (!$messaging || !$messaging->hasMember($user)) {
        return new JsonResponse([], 403);
    }

    // 生成鉴权签名返回给前端
    $auth = $pusher->socket_auth($channelName, $socketId);
    return new JsonResponse(json_decode($auth, true));
}

3. 后端触发事件时同步修改频道名为私有格式：

if ($pusher->trigger('private-chat-' . $messaging->getId(), 'my_event', $data)) {
    echo 'success';
}

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