這篇文章主要介紹“Laravel如何快速創(chuàng)建簡單事件流”的相關(guān)知識，小編通過實際案例向大家展示操作過程，操作方法簡單快捷，實用性強，希望這篇“Laravel如何快速創(chuàng)建簡單事件流”文章能幫助大家解決問題。

10年積累的做網(wǎng)站、成都網(wǎng)站設(shè)計經(jīng)驗，可以快速應(yīng)對客戶對網(wǎng)站的新想法和需求。提供各種問題對應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識你，你也不認(rèn)識我。但先網(wǎng)站設(shè)計后付款的網(wǎng)站建設(shè)流程，更有寧武免費網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

先決條件

在開始之前，你需要在機器上安裝 Laravel。

我將在這個演示中使用 DigitalOcean Ubuntu Droplet 。如果你愿意，你可以使用我的會員代碼獲得免費 $100 DigitalOcean 積分來啟動你自己的服務(wù)器！

如果你還沒有，可以按照本教程中的步驟進(jìn)行操作：

• How to Install Laravel on DigitalOcean with 1-Click

或者可以使用這個很棒的腳本進(jìn)行安裝：

• LaraSail

創(chuàng)建一個 Controller

讓我們從創(chuàng)建一個處理事件流的控制器開始。

使用以下命令：

php artisan make:controller EventStreamController

這將在 App\Http\Controllers 目錄中創(chuàng)建一個新控制器。

添加事件流方法

一旦我們創(chuàng)建了我們的控制器，我們需要向它添加 stream 方法。 該方法將用于發(fā)送事件流。

打開 EventStreamController.php 文件并添加以下代碼：

<?php

namespace App\Http\Controllers;use Carbon\Carbon;use App\Models\Trade;class StreamsController extends Controller{
    /**
     * 事件流代碼
     *
     * @return \Illuminate\Http\Response
     */
    public function stream(){
        return response()->stream(function () {
            while (true) {
                echo "event: ping\n";
                $curDate = date(DATE_ISO8601);
                echo 'data: {"time": "' . $curDate . '"}';
                echo "\n\n";

                $trades = Trade::latest()->get();
                echo 'data: {"total_trades":' . $trades->count() . '}' . "\n\n";

                $latestTrades = Trade::with('user', 'stock')->latest()->first();
                if ($latestTrades) {
                    echo 'data: {"latest_trade_user":"' . $latestTrades->user->name . '", "latest_trade_stock":"' . $latestTrades->stock->symbol . '", "latest_trade_volume":"' . $latestTrades->volume . '", "latest_trade_price":"' . $latestTrades->stock->price . '", "latest_trade_type":"' . $latestTrades->type . '"}' . "\n\n";
                }

                ob_flush();
                flush();

                // 如果客戶端中止連接，則中斷循環(huán)（關(guān)閉頁面）
                if (connection_aborted()) {break;}
                usleep(50000); // 50ms
            }
        }, 200, [
            'Cache-Control' => 'no-cache',
            'Content-Type' => 'text/event-stream',
        ]);
    }}

這里要注意的主要事項是：

• 我們使用 response()->stream() 方法來創(chuàng)建事件流。

• 然后我們有一個無限循環(huán)，每隔50ms發(fā)送一次事件流。

• 如果客戶端中止連接，我們使用 ob_flush() 和 flush() 來發(fā)送事件流。

• 我們使用 sleep() 發(fā)送下一個事件之前等待50ms。

• 我們使用 connection_aborted() 來中斷循環(huán)，如果客戶端中止了連接。

• 我們使用 Carbon\Carbon 類獲取當(dāng)前日期。

• 我們使用 App\Models\Trade 模型獲取最新交易。這僅用于演示，你可以使用任何你想要的模型。

• 將 Content-Type 標(biāo)頭設(shè)置為 text/event-stream 以告知瀏覽器響應(yīng)是事件流。

啟用輸出緩沖

為了使上述代碼正常工作，我們需要在你的 PHP.ini 文件中啟用輸出緩沖。 這是通過將以下行添加到 php.ini 文件中完成的：

output_buffering = On

進(jìn)行此更改后，可能需要重新加載 PHP-FPM 服務(wù)。 或者如果你使用的是 Apache，則可以重新啟動 Apache。

添加路由

當(dāng)請求 /stream 路由時，我們想調(diào)用 ``stream` 方法。

路由將被添加到routes/web.php 文件中，如下所示：

use App\Http\Controllers\StreamsController;Route::get('/stream', [StreamsController::class, 'stream']);

使用前端的事件流

你可以使用 Vue.js 之類的前端框架來處理事件流。 但是對于這個演示，我將使用純 Javascript。

添加到 blade 模板中的 JavaScript 片段如下所示：

const eventSource = new EventSource('/stream');eventSource.onmessage = function(event) {
    const data = JSON.parse(event.data);
    if (data.time) {
        document.getElementById('time').innerHTML = data.time;
    }
    const newElement = document.createElement("li");
    const eventList = document.getElementById("list");

    newElement.textContent = "message: " + event.data;
    eventList.appendChild(newElement);}

SSE vs WebSockets

事件流很棒且易于使用，但與 WebSockets 等其他流協(xié)議相比，它也有一些優(yōu)點和缺點。

例如，SSE 是單向的，這意味著一旦建立連接，服務(wù)器只會向客戶端發(fā)送數(shù)據(jù)，而客戶端不能將數(shù)據(jù)發(fā)送回服務(wù)器。

與長輪詢不同，使用 WebSockets，你只有一個與服務(wù)器的連接，類似于 SSE（服務(wù)器發(fā)送事件）。 連接是雙工的，這意味著你可以從服務(wù)器發(fā)送和接收數(shù)據(jù)。

關(guān)于“Laravel如何快速創(chuàng)建簡單事件流”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，小編每天都會為大家更新不同的知識點。

新聞標(biāo)題：Laravel如何快速創(chuàng)建簡單事件流
網(wǎng)站URL：http://www.chinadenli.net/article46/jdhjhg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供全網(wǎng)營銷推廣、網(wǎng)站策劃、關(guān)鍵詞優(yōu)化、Google、營銷型網(wǎng)站建設(shè)、網(wǎng)站改版

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)