{"id":845,"date":"2025-06-12T01:00:13","date_gmt":"2025-06-11T17:00:13","guid":{"rendered":"https:\/\/www.zhaozhao123.cn\/php\/php-application-manual\/laravel\/845.html"},"modified":"2025-06-12T01:00:13","modified_gmt":"2025-06-11T17:00:13","slug":"%e5%9c%a8-laravel-%e4%b8%ad%e4%bd%bf%e7%94%a8-websocket-%e6%9e%84%e5%bb%ba%e5%ae%9e%e6%97%b6%e5%ba%94%e7%94%a8","status":"publish","type":"my1js","link":"https:\/\/www.zhaozhao123.cn\/php\/my1js\/845.html","title":{"rendered":"\u5728 Laravel \u4e2d\u4f7f\u7528 WebSocket \u6784\u5efa\u5b9e\u65f6\u5e94\u7528"},"content":{"rendered":"
\r\n
\r\n
\r\n
\r\n
\r\n
\"Bug编译狮\"<\/figure>\r\n\r\n\r\n\r\n

Bug编译狮<\/h2>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n\r\n\r\n\r\n
\r\n
\r\n

WebSocket 是一种用于在网络应用程序中实现全双工通信的技术。在 Laravel 中使用 WebSocket 可以显著提高用户体验，特别是在需要即时反馈的应用场景中。以下是如何在 Laravel 中使用 WebSocket 的步骤：<\/p>\n

1. 安装 Laravel Echo 和 Laravel Broadcast<\/h3>\n

首先，你需要安装 Laravel Echo 和 Laravel Broadcast。<\/p>\n

composer require pusher\/pusher-php-server<\/code><\/pre>\n
然后，运行以下命令来创建广播服务和通道：<\/p>\n
php artisan make:channel ChatChannel<\/code><\/pre>\n
2. 配置 Pusher<\/h3>\n
在 .env<\/code> 文件中配置 Pusher 的凭据：<\/p>\n
PUSHER_APP_ID=your_app_id\nPUSHER_APP_KEY=your_app_key\nPUSHER_APP_SECRET=your_app_secret\nPUSHER_APP_CLUSTER=mt1<\/code><\/pre>\n
3. 创建 WebSocket 控制器<\/h3>\n
创建一个新的控制器来处理 WebSocket 请求：<\/p>\n
php artisan make:controller SocketController<\/code><\/pre>\n
4. 编写 WebSocket 方法<\/h3>\n
在 SocketController<\/code> 中编写方法来处理连接、消息接收和发送：<\/p>\n
namespace AppHttpControllers;\n\nuse IlluminateHttpRequest;\nuse PusherPusher;\n\nclass SocketController extends Controller\n{\n    private $pusher;\n\n    public function __construct()\n    {\n        $this->pusher = new Pusher(\n            env('PUSHER_APP_KEY'),\n            env('PUSHER_APP_SECRET'),\n            env('PUSHER_APP_CLUSTER')\n        );\n    }\n\n    public function connect(Request $request)\n    {\n        $request->connection->joinChannel('chat');\n    }\n\n    public function chat(Request $request)\n    {\n        $message = $request->input('message');\n\n        $this->pusher->broadcast('chat', [\n            'message' => $message,\n        ]);\n\n        return response()->json([\n            'status' => 'success',\n        ]);\n    }\n}<\/code><\/pre>\n
5. 注册路由<\/h3>\n
在 routes\/web.php<\/code> 文件中注册路由：<\/p>\n
Route::get('\/ws\/socket', 'SocketController@connect')->name('socket.connect');\nRoute::post('\/ws\/chat', 'SocketController@chat')->name('socket.chat');<\/code><\/pre>\n
6. 在前端使用 Laravel Echo<\/h3>\n
在你的前端应用中使用 Laravel Echo 来连接到 WebSocket 并发送消息：<\/p>\n
\/\/ app.js\nimport Echo from 'laravel-echo';\n\nwindow.Pusher = require('pusher-js');\n\nconst echo = new Echo({\n    broadcaster: 'pusher',\n    key: process.env.MIX_PUSHER_APP_KEY,\n    cluster: process.env.MIX_PUSHER_APP_CLUSTER,\n});\n\necho.channel('chat').listen('chat', (event) => {\n    console.log(event.message);\n});<\/code><\/pre>\n
示例代码<\/h3>\n
以下是一个完整的示例代码，展示了如何在 Laravel 中使用 WebSocket：<\/p>\n
1. 安装依赖<\/h4>\n
composer require pusher\/pusher-php-server<\/code><\/pre>\n
2. 配置 Pusher<\/h4>\n
在 .env<\/code> 文件中配置 Pusher 的凭据：<\/p>\n
PUSHER_APP_ID=your_app_id\nPUSHER_APP_KEY=your_app_key\nPUSHER_APP_SECRET=your_app_secret\nPUSHER_APP_CLUSTER=mt1<\/code><\/pre>\n
3. 创建 WebSocket 控制器<\/h4>\n
php artisan make:controller SocketController<\/code><\/pre>\n
4. 编写 WebSocket 方法<\/h4>\n
在 SocketController<\/code> 中编写方法来处理连接、消息接收和发送：<\/p>\n
namespace AppHttpControllers;\n\nuse IlluminateHttpRequest;\nuse PusherPusher;\n\nclass SocketController extends Controller\n{\n    private $pusher;\n\n    public function __construct()\n    {\n        $this->pusher = new Pusher(\n            env('PUSHER_APP_KEY'),\n            env('PUSHER_APP_SECRET'),\n            env('PUSHER_APP_CLUSTER')\n        );\n    }\n\n    public function connect(Request $request)\n    {\n        $request->connection->joinChannel('chat');\n    }\n\n    public function chat(Request $request)\n    {\n        $message = $request->input('message');\n\n        $this->pusher->broadcast('chat', [\n            'message' => $message,\n        ]);\n\n        return response()->json([\n            'status' => 'success',\n        ]);\n    }\n}<\/code><\/pre>\n
5. 注册路由<\/h4>\n
在 routes\/web.php<\/code> 文件中注册路由：<\/p>\n
Route::get('\/ws\/socket', 'SocketController@connect')->name('socket.connect');\nRoute::post('\/ws\/chat', 'SocketController@chat')->name('socket.chat');<\/code><\/pre>\n
6. 在前端使用 Laravel Echo<\/h4>\n
在你的前端应用中使用 Laravel Echo 来连接到 WebSocket 并发送消息：<\/p>\n
\/\/ app.js\nimport Echo from 'laravel-echo';\n\nwindow.Pusher = require('pusher-js');\n\nconst echo = new Echo({\n    broadcaster: 'pusher',\n    key: process.env.MIX_PUSHER_APP_KEY,\n    cluster: process.env.MIX_PUSHER_APP_CLUSTER,\n});\n\necho.channel('chat').listen('chat', (event) => {\n    console.log(event.message);\n});<\/code><\/pre>\n
通过以上步骤，你可以在 Laravel 中成功使用 WebSocket 构建实时应用。<\/p>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n<\/div>
\r\n
\r\n
\r\n
\r\n
\r\n
\"黑板Bug讲师\"<\/figure>\r\n\r\n\r\n\r\n
黑板Bug讲师<\/h2>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n\r\n\r\n\r\n
\r\n
\r\n
介绍<\/h2>
实时交互是现代Web应用程序的重要特性。使用Laravel和laravel-websocket包，PHP开发人员可以轻松构建强大的实时应用。本教程将指导您安装、配置和使用laravel-websocket在您的Laravel应用程序中创建实时功能。<\/p>
设置中<\/h2>
首先，使用 Composer 安装 Laravel-Websocket 包：<\/p>
composer require beyondcode\/laravel-websockets<\/code><\/pre>
发布配置文件：<\/p>
php artisan vendor:publish --provider=\"BeyondCode\nLaravelWebSockets\nWebSocketsServiceProvider\" --tag=\"config\"\n<\/code><\/pre>
配置WebSocket服务器<\/h2>
请修改配置文件 config\/websockets.php，以设置您的WebSocket服务器：<\/p>
'apps' => [\n    [\n        'id' => env('PUSHER_APP_ID'),\n        'name' => env('APP_NAME'),\n        'key' => env('PUSHER_APP_KEY'),\n        'secret' => env('PUSHER_APP_SECRET'),\n        'enable_client_messages' => true,\n        'enable_statistics' => true,\n    ],\n],\n<\/code><\/pre>
运行WebSocket服务器<\/h2>
启动WebSocket服务器，使用Artisan命令：<\/p>
php artisan websockets:serve<\/code><\/pre>
这将启动服务器，你可以使用前端实现，比如Laravel Echo或JavaScript来连接到它。<\/p>
与前端集成<\/h2>
以这种方式为例，我们将使用Laravel Echo与Pusher JS：<\/p>
import Echo from 'laravel-echo';\nwindow.Pusher = require('pusher-js');\n\nwindow.echo = new Echo({\n    broadcaster: 'pusher',\n    key: 'your-pusher-key',\n    wsHost: window.location.hostname,\n    wsPort: 6001,\n    forceTLS: false,\n    disableStats: true,\n});\n<\/code><\/pre>
现在可以在频道上监听事件：<\/p>
window.echo.channel('your-channel')\n    .listen('.YourEvent', (e) => {\n        console.log(e);\n    });\n<\/code><\/pre>
创建事件<\/h2>
在Laravel中创建一个自定义事件，该事件实现ShouldBroadcast接口的示例如下：<\/p>
use IlluminateContractsBroadcastingShouldBroadcast;\n\nclass YourEvent implements ShouldBroadcast\n{\n    public function broadcastOn()\n    {\n        return new Channel('your-channel');\n    }\n}\n<\/code><\/pre>
触发此事件，从应用程序逻辑中实现，它将在前端实时显示。<\/p>
Presence Channels<\/h2>
Laravel WebSocket 支持Presence Channels，可以跟踪用户的在线状态：<\/p>
window.echo.join('presence-channel')\n    .here((users) => {\n        \/\/ Users that are already present.\n    })\n    .joining((user) => {\n        \/\/ User that joins the presence channel.\n    })\n    .leaving((user) => {\n        \/\/ User that leaves the presence channel.\n    });\n<\/code><\/pre>
处理身份验证<\/h2>
Laravel-WebSocket 允许您通过身份验证私有和存在频道，以确保只有授权用户才能访问它们：<\/p>
Broadcast::channel('private-channel', function ($user) {\n    return (int) $user->id === (int) Auth::id();\n});\nBroadcast::channel('presence-channel', function ($user) {\n    return $user;\n});\n<\/code><\/pre>
高级用法：自定义控制器<\/h2>
你可以通过添加自定义的WebSocket控制器来扩展你的WebSocket服务器的功能。<\/p>
use BeyondCodeLaravelWebSocketsWebSocketsWebSocketHandler;\nclass CustomWebSocketController extends WebSocketHandler\n{\n    public function onOpen($connection)\n    { }\n    public function onClose($connection)\n    { }\n}\n<\/code><\/pre>
编辑 websockets.php 配置文件以使用自定义控制器：<\/p>
'handlers' => [\n    'default' => MyCustomWebSocketHandler::class,\n],\n<\/code><\/pre>
确保WebSocket连接的安全性<\/h2>
为了确保安全连接，请使用SSL。在广播配置中设置您的SSL证书：<\/p>
'apps' => [\n    [\n        'id' => env('PUSHER_APP_ID'),\n        \/\/ ...\n        'ssl' => [\n            'local_cert' => env('WEBSOCKETS_SSL_LOCAL_CERT', null),\n            'local_pk' => env('WEBSOCKETS_SSL_LOCAL_PK', null),\n            'passphrase' => env('WEBSOCKETS_SSL_PASSPHRASE', null),\n        ],\n        \/\/ ...\n    ],\n],\n<\/code><\/pre>
调试和监控<\/h2>
Laravel-WebSocket 提供了一个仪表板来监控 WebSocket 连接和消息。您可以通过在您的应用 URL 上访问 \/laravel-websockets 来访问它，这需要您在 .env 文件中调整了仪表板配置设置。<\/p>
结论。<\/h2>
按照这个指南，您已经学会了如何使用laravel-websocket包在Laravel应用中集成实时功能。实时应用程序可以为用户提供增强的用户体验，这对您的项目非常有益。开心编码！<\/p><\/body>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n<\/div>
\r\n
\r\n
\r\n
\r\n
\r\n
\"长工码奴1523\"<\/figure>\r\n\r\n\r\n\r\n
长工码奴1523<\/h2>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n\r\n\r\n\r\n
\r\n
\r\n
在 Laravel 中构建一个基于 WebSocket 的实时应用可以让你轻松地实现异步通信和数据流处理。WebSocket 是一种轻量级的、全双工的协议，允许客户端与服务器之间进行双向传输。以下是如何使用 Laravel 和 WebSocket 实现简单聊天功能的一个例子：<\/p>\n
第一步：安装 Laravel 和 WebSocket<\/h3>\n
首先确保你的系统上已安装了 Composer。接下来，通过运行以下命令安装 Laravel 以及 WebSocket 支持：<\/p>\n
composer require laravel\/framework ^8.0<\/code><\/pre>\n
这将安装 Laravel 8.x 版本，并确保你有一个支持 WebSocket 的版本。<\/p>\n
第二步：创建 WebSocket 配置文件<\/h3>\n
在 app\/Http\/Kernel.php<\/code> 文件中添加 WebSocket 配置：<\/p>\n
protected $middlewareGroups = [\n    'web' => ['IlluminateRoutingMiddlewareThrottleRequests'],\n];\nprotected $routeMiddleware = [\n    \/\/ ...\n    'websocket' => LaravelWebsoketLaravelFacadesWebsocket::class,\n];<\/code><\/pre>\n
这里的 websocket<\/code> 关键字告诉 Laravel 使用 WebSockets。<\/p>\n
第三步：定义 WebSocket 监听器<\/h3>\n
创建一个新的控制器来监听 WebSocket 连接并处理消息：<\/p>\n
<?php\n\nnamespace AppHttpControllers;\n\nuse IlluminateHttpRequest;\nuse IlluminateSupportFacadesHttp;\nuse IlluminateSupportFacadesEvent;\nuse AppEventsMessageReceivedEvent;\n\nclass ChatController extends Controller\n{\n    public function __construct()\n    {\n        event(new MessageReceivedEvent());\n    }\n\n    \/**\n     * Handle incoming WebSocket connections.\n     *\n     * @param  IlluminateHttpRequest  $request\n     * @return IlluminateHttpResponse\n     *\/\n    public function websocket(Request $request)\n    {\n        $request->session()->put('connection', true);\n\n        return $this->respondToClient($request);\n    }\n\n    private function respondToClient(Request $request)\n    {\n        if ($request->has('message')) {\n            $client_id = $request->session()->get('client_id');\n            $data = json_decode($request->getContent(), true);\n\n            $response = Http::withHeaders([\n                'Content-Type' => 'application\/json',\n            ])->post(\n                config('services.websocket.url'),\n                [\n                    'method' => 'POST',\n                    'headers' => [\n                        'Authorization' => 'Bearer ' . config('services.websocket.key'),\n                        'Client-ID' => $client_id,\n                    ],\n                    'json' => $data,\n                ]\n            );\n\n            if ($response->successful()) {\n                return response()->json(['success' => true]);\n            } else {\n                return response()->json(['error' => 'Failed to send message']);\n            }\n        }\n\n        return response()->json(['error' => 'Missing required data'], 422);\n    }\n}<\/code><\/pre>\n
在这个控制器中，我们首先检查是否已经存在 WebSocket 连接。如果存在，我们从会话中获取客户端 ID 并尝试向服务端发送消息。如果没有连接，我们直接返回错误信息。<\/p>\n
第四步：测试 WebSocket<\/h3>\n
为了测试 WebSocket，你可以使用 Postman 或类似的工具。在 Postman 中，你可以模拟一个 WebSocket 请求到服务端：<\/p>\n
    \n
  1. 将 POST 方法设置为 “GET”。<\/li>\n
  2. 在 URL 中加入 \/ws\/<\/code>，这是 WebSocket 的 URL。<\/li>\n
  3. 添加请求体，其中包含 JSON 数据（例如，用户名）。<\/li>\n
  4. 发送请求。<\/li>\n<\/ol>\n
    第五步：部署和部署<\/h3>\n
    在 Laravel 项目中配置 WebSocket 后，你需要将其集成到实际的应用程序中。你可以选择在生产环境中使用 Nginx 或者其他负载均衡器。然后，通过修改配置文件来启用 WebSocket 功能。<\/p>\n
    以上就是如何在 Laravel 中使用 WebSocket 建立实时应用的基本指导。这个例子展示了如何构建简单的聊天应用，但你可以根据需要扩展其功能，比如用户认证、加密等。<\/p>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n<\/div>\n","protected":false},"excerpt":{"rendered":"
    Bug编译狮 WebSocket 是一种用于在网络应用程序中实现&#..<\/p>\n","protected":false},"author":1,"featured_media":0,"menu_order":0,"template":"","meta":{"_acf_changed":false},"tags":[],"my1js2nav":[44],"tuisongtax":[],"class_list":["post-845","my1js","type-my1js","status-publish","hentry","my1js2nav-laravel"],"acf":{"qian_art_seotitle":"","qian_art_seotitle_source":{"label":"SEO\u6807\u9898","type":"text","formatted_value":""},"qian_art_seokws":"","qian_art_seokws_source":{"label":"SEO\u5173\u952e\u8bcd","type":"text","formatted_value":""},"qian_art_stzhong":"","qian_art_stzhong_source":{"label":"\u4e2d | \u77ed\u6807\u9898","type":"text","formatted_value":""}},"_links":{"self":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/my1js\/845","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/my1js"}],"about":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/types\/my1js"}],"author":[{"embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/users\/1"}],"wp:attachment":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/media?parent=845"}],"wp:term":[{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/tags?post=845"},{"taxonomy":"my1js2nav","embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/my1js2nav?post=845"},{"taxonomy":"tuisongtax","embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/tuisongtax?post=845"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}