如何在Laravel中实现实时通知-Laravel-PHP中文网

如何在Laravel中实现实时通知

小老鼠

发布： 2025-07-02 18:42:02

原创

189人浏览过

laravel中实现实时通知的核心是利用websocket技术配合事件广播系统。首先选择pusher作为websocket服务器并安装其php sdk；接着配置.env文件中的pusher凭据；创建实现shouldbroadcast接口的neworder事件，通过broadcaston()指定私有频道，并在broadcastwith()中定义广播数据；在routes/channels.php中编写授权逻辑；在控制器中触发事件；前端引入pusher库并订阅频道绑定事件处理函数。如何选择合适的websocket服务器？需考虑成本、可扩展性、易用性和功能集，pusher配置简单但成本高，socket.io灵活但配置复杂，自建服务器适合有技术实力团队。如何处理高并发下的实时通知？可通过水平扩展websocket服务器、优化数据库查询、使用消息队列异步处理事件、以及代码优化减少性能瓶颈。如何保证实时通知的安全性？应使用https、私有频道、验证用户输入、限制广播敏感数据并定期审查代码。

如何在Laravel中实现实时通知

Laravel 中实现实时通知，核心在于利用 WebSocket 技术，配合 Laravel 强大的事件广播系统。简而言之，就是当特定事件发生时，服务器主动推送消息给客户端，无需客户端轮询。

解决方案

首先，你需要选择一个 WebSocket 服务器。比较流行的选择是 Pusher 或者 Socket.IO。这里我们以 Pusher 为例，因为它集成起来相对简单。

安装 Pusher PHP SDK:

composer require pusher/pusher-php-server

登录后复制

配置 Pusher:

在 .env 文件中配置 Pusher 的 credentials:
```
PUSHER_APP_ID=your-app-id
PUSHER_APP_KEY=your-app-key
PUSHER_APP_SECRET=your-app-secret
PUSHER_APP_CLUSTER=your-app-cluster
```
登录后复制
这些信息可以在 Pusher 的 dashboard 上找到。

创建事件:

创建一个事件，例如 NewOrder，当有新订单产生时触发。

php artisan make:event NewOrder

登录后复制

在 app/Events/NewOrder.php 中，你需要实现 ShouldBroadcast 接口。这个接口告诉 Laravel 这个事件需要被广播。

<?php

namespace AppEvents;

use IlluminateBroadcastingChannel;
use IlluminateBroadcastingInteractsWithSockets;
use IlluminateBroadcastingPresenceChannel;
use IlluminateBroadcastingPrivateChannel;
use IlluminateContractsBroadcastingShouldBroadcast;
use IlluminateFoundationEventsDispatchable;
use IlluminateQueueSerializesModels;
use AppModelsOrder; // 假设你有 Order 模型

class NewOrder implements ShouldBroadcast
{
    use Dispatchable, InteractsWithSockets, SerializesModels;

    public $order;

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

    /**
     * Get the channels the event should broadcast on.
     *
     * @return Channel|array
     */
    public function broadcastOn()
    {
        return new PrivateChannel('orders'); // 使用私有频道，确保安全性
    }

    // 自定义广播数据
    public function broadcastWith()
    {
        return [
            'order_id' => $this->order->id,
            'customer_name' => $this->order->customer_name,
            // 添加你需要的其他数据
        ];
    }
}

登录后复制

注意 broadcastOn() 方法返回一个 PrivateChannel，这意味着只有经过授权的用户才能接收到这个事件。你也可以使用 PublicChannel，但通常不推荐，除非你的数据是公开的。

授权频道:

因为我们使用了 PrivateChannel，所以需要在 routes/channels.php 中定义授权逻辑。

Broadcast::channel('orders', function ($user) {
    return true; // 允许所有登录用户订阅
    // 或者更细粒度的控制，例如：
    // return $user->hasRole('admin');
});

登录后复制

触发事件:

在你的控制器或者任何需要的地方，触发 NewOrder 事件。

use AppEventsNewOrder;
use AppModelsOrder;

public function store(Request $request)
{
    $order = Order::create($request->all());

    broadcast(new NewOrder($order)); // 触发事件

    return response()->json(['message' => 'Order created!'], 201);
}

登录后复制

前端配置:

在前端，你需要引入 Pusher 的 JavaScript 库。

<script src="https://js.pusher.com/7.x/pusher.min.js"></script>
<script>
  var pusher = new Pusher('your-app-key', {
    cluster: 'your-app-cluster'
  });

  var channel = pusher.subscribe('private-orders'); // 注意前缀 private-
  channel.bind('App\Events\NewOrder', function(data) {
    alert('New order received: ' + data.order_id);
    // 在这里处理接收到的数据，例如更新 UI
  });
</script>

登录后复制

记得替换 your-app-key 和 your-app-cluster 为你的 Pusher credentials。

如何选择合适的 WebSocket 服务器？

选择 WebSocket 服务器，需要考虑几个关键因素：成本、可扩展性、易用性和功能集。Pusher 简化了配置，但可能成本较高。Socket.IO 更灵活，但需要更多配置。考虑你的项目规模和预算，权衡利弊。有时，自建 WebSocket 服务器（例如使用 Ratchet）可能更划算，但需要更多技术投入。