Saya sering melihat pasukan untuk mencapai (melalui Socket.io atau Pusher) apabila mereka hanya perlu mengemas kini UI dengan perubahan keadaan di sisi pelayan. manakala WebSockets berkuasa, mereka sering overkill. ialah protokol yang anda perlu menguasai. WebSockets Server-Sent Events (SSE) SSE berjalan di atas standard HTTP/1.1 atau HTTP/2. Ia tidak memerlukan tangan yang rumit, berfungsi dengan mekanisme pengesahan standard, dan sokongan asli dibina dalam setiap pelayar moden melalui . EventSource API Dalam panduan ini, kami akan melaksanakan SSE dalam Symfony 7.4 menggunakan dua pendekatan: 
 
 
 Pendekatan asli: Menggunakan StreamedResponse (Sangat baik untuk memahami protokol dan tugas-tugas yang mudah dan rendah persaingan). Pendekatan Pengeluaran: Menggunakan protokol Mercure (standar yang boleh diperluas dan tidak menghalang untuk Symfony). Pendekatan asli (StreamedResponse) Simfoni yang membolehkan anda untuk dan membasuh data kepada klien secara beransur-ansur.Ini adalah pelaksanaan "beras" standard SSE. StreamedResponse keep an HTTP connection open Kami akan menggunakan generator atau loop untuk mensimulasikan data streaming. namespace App\Controller;

use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\StreamedResponse;
use Symfony\Component\Routing\Attribute\Route;

#[Route('/api/stream', name: 'api_stream_stock')]
class StockStreamController extends AbstractController
{
    #[Route('/stock/{symbol}', name: 'stock_ticker', methods: ['GET'])]
    public function stream(string $symbol): StreamedResponse
    {
        // 1. Create the StreamedResponse
        $response = new StreamedResponse(function () use ($symbol) {
            // 2. Prevent PHP time limits for long-running processes
            set_time_limit(0); 
            
            // 3. Simple loop to simulate data stream
            // In a real app, you might check Redis or a Database here
            $i = 0;
            while (true) {
                // Connection check: Stop if client disconnected
                if (connection_aborted()) {
                    break;
                }

                $data = [
                    'symbol' => strtoupper($symbol),
                    'price' => rand(100, 200),
                    'timestamp' => date('c'),
                    'sequence' => $i++
                ];

                // 4. Format according to SSE Spec
                // Format: "data: {payload}\n\n"
                echo "event: stock_update\n"; // Optional event name
                echo 'data: ' . json_encode($data) . "\n\n";

                // 5. Critical: Flush the buffer to send data immediately
                ob_flush();
                flush();

                // simulate delay
                sleep(2);
            }
        });

        // 6. Set Headers specifically for SSE
        $response->headers->set('Content-Type', 'text/event-stream');
        $response->headers->set('Cache-Control', 'no-cache');
        $response->headers->set('X-Accel-Buffering', 'no'); // Crucial for Nginx

        return $response;
    }
}
 Anda tidak memerlukan perpustakaan untuk ini. EventSource asli pelayar adalah kukuh. <!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Symfony SSE Stream</title>
</head>
<body>
    <h1>Live Ticker: <span id="symbol">LOADING...</span></h1>
    <div id="price" style="font-size: 2rem;">--</div>
    <ul id="log"></ul>

    <script>
        const symbol = 'AAPL';
        // Connect to the Symfony endpoint
        const eventSource = new EventSource(`/api/stream/stock/${symbol}`);

        // Listen for the specific 'stock_update' event name defined in PHP
        eventSource.addEventListener('stock_update', (e) => {
            const data = JSON.parse(e.data);
            
            document.getElementById('symbol').innerText = data.symbol;
            document.getElementById('price').innerText = '$' + data.price;
            
            // Log for visibility
            const li = document.createElement('li');
            li.innerText = `${data.timestamp}: $${data.price}`;
            document.getElementById('log').prepend(li);
        });

        eventSource.onerror = (err) => {
            console.error("EventSource failed:", err);
            // EventSource auto-reconnects by default, but you can handle closure here
        };
    </script>
</body>
</html>
 Konfigurasi Server (Kritik) Ini adalah di mana kebanyakan pengembang gagal. pelayan web (nginx, dan lain-lain) suka output buffer untuk mengoptimumkan kompresi. Untuk SSE, buffering membunuh aliran (pelanggan tidak menerima apa-apa sehingga buffer mengisi). Anda mesti tidak mampu atau menggunakan Kami telah menambah kepada pengawal. fastcgi_buffering X-Accel-Buffering: no header # inside your location ~ \.php$ block
fastcgi_split_path_info ^(.+\.php)(/.+)$;
# ... standard config ...
# Ensure buffering is off for SSE if headers fail
fastcgi_buffering off;
 Periksa anda memastikan telah ditetapkan kepada atau nilai yang rendah. php.ini output_buffering Off Pengesahan : 
 
 
 
 
 
 Start your local server:  symfony server:start 
 
 Open your terminal. 
 
 Use   to verify the stream without a browser: curl curl -N -v http://127.0.0.1:8000/api/stream/stock/AAPL
 
 
 
 -N: Menghalang buffering dalam curl. Hasil yang dijangka: Anda perlu melihat satu objek JSON muncul setiap 2 saat. The “Senior” Reality Check (Mengapa Orang Asli Berbahaya) Walaupun kod di atas berfungsi, saya jarang mengesyorkan untuk aplikasi pengeluaran yang tinggi trafik. Apabila klien menyambung ke /api/stream/stock/AAPL, proses kerja PHP-FPM itu memasuki daripada . PHP is synchronous while(true) loop It is locked Jika anda mempunyai 50 pekerja PHP-FPM dan 50 pengguna membuka halaman ini, seluruh laman anda jatuh. Ia juga menyimpan sambungan pangkalan data terbuka jika anda tidak berhati-hati. Anda perlu memindahkan pengurusan sambungan terbuka kepada perkhidmatan khusus yang direka khas untuknya. . Mercure Pendekatan Pengeluaran ( Mercury ) Mercure ialah protokol terbuka untuk kemas kini masa nyata. ia bertindak sebagai hub. 
 
 
 
 
 Klien menyambung ke Hub (bukan aplikasi PHP anda) untuk mendengarkan acara. Symfony menghantar permintaan POST tunggal kepada Hub apabila data berubah. Hub menghantar data kepada beribu-ribu pendengar. Hasilnya: Zero memblokir proses PHP. Dalam persekitaran pengeluaran, anda tidak boleh meninggalkan aliran anda awam. anda perlu mengawal siapa yang boleh mendengar apa. Mercury digunakan untuk ini. JSON Web Tokens (JWT) 
 
 
 Publisher JWT: Membolehkan aplikasi Symfony anda untuk memindahkan data (diproses secara automatik oleh bundle melalui MERCURE_JWT_SECRET). Abon JWT: Membolehkan pelayar pengguna untuk mendengar kemas kini peribadi. Berikut ialah cara untuk melaksanakan Pengenalan kepada Symfony 7.4. Subscriber JWT Memasang Perpustakaan JWT Kami memerlukan perpustakaan untuk menghasilkan token secara manual untuk pengguna kami. merupakan standard dalam ekosistem PHP. lcobucci/jwt composer require lcobucci/jwt
 Perkhidmatan Token Generator Mencipta perkhidmatan yang menghasilkan JWT yang ditandatangani untuk pengguna tertentu. token ini akan mengandungi mengklaim senarai topik yang pengguna dibenarkan untuk mengakses. mercure //src/Service/MercureTokenGenerator.php

namespace App\Service;

use Lcobucci\JWT\Configuration;
use Lcobucci\JWT\Signer\Hmac\Sha256;
use Lcobucci\JWT\Signer\Key\InMemory;
use Symfony\Component\DependencyInjection\Attribute\Autowire;

class MercureTokenGenerator
{
    private Configuration $config;

    public function __construct(
        // Inject the same secret used in your .env for the Mercure Hub
        #[Autowire('%env(MERCURE_JWT_SECRET)%')]
        private string $secret
    ) {
        $this->config = Configuration::forSymmetricSigner(
            new Sha256(),
            InMemory::plainText($this->secret)
        );
    }

    public function generate(string $userTopic): string
    {
        return $this->config->builder()
            ->withClaim('mercure', [
                'subscribe' => [
                    $userTopic, // Allow access to this specific topic
                    // 'https://mysite.com/books/{id}' // You can add patterns here
                ]
            ])
            ->getToken($this->config->signer(), $this->config->signingKey())
            ->toString();
    }
}
 Menyuntikkan Token (Metode Kuki) Pengguna Native Browser tidak menyokong menghantar tajuk HTTP (seperti ) daripada EventSource API Authorization: Bearer Untuk menyelesaikan ini tanpa menambah polyfills JavaScript yang berat, kami menggunakan Mercure Hub secara automatik mencari kuki yang dinamakan . Cookie mercureAuthorization //src/Controller/StockPageController.php

namespace App\Controller;

use App\Service\MercureTokenGenerator;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\Cookie;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\Attribute\Route;

class StockPageController extends AbstractController
{
    #[Route('/dashboard', name: 'app_dashboard')]
    public function index(MercureTokenGenerator $tokenGenerator): Response
    {
        // 1. Define the private topic this user is allowed to see
        $userTopic = 'https://mysite.com/user/123/alerts';

        // 2. Generate the JWT
        $token = $tokenGenerator->generate($userTopic);

        // 3. Create the response (render your Twig template)
        $response = $this->render('dashboard/index.html.twig', [
            'userTopic' => $userTopic
        ]);

        // 4. Attach the JWT as a Cookie
        // The Hub must be on the same domain (or subdomain) for this to work
        $response->headers->setCookie(Cookie::create(
            'mercureAuthorization',
            $token,
            0,              // Session cookie
            '/.well-known/mercure', // Path (critical: restricts cookie to Hub)
            null,           // Domain (null = current domain)
            false,          // Secure (true if HTTPS)
            true,           // HttpOnly
            false,          // Raw
            'strict'        // SameSite
        ));

        return $response;
    }
}
 Mengemas kini penerbit Sekarang, kemas kini perkhidmatan penerbit anda untuk menandakan kemas kini sebagai Peribadi. // ...
public function publishPrivateAlert(string $userId, string $message): void
{
    $topic = "https://mysite.com/user/{$userId}/alerts";
    
    $update = new Update(
        $topic,
        json_encode(['alert' => $message]),
        true // <--- TRUE marks this as Private
    );

    $this->hub->publish($update);
}
 Halaman pelanggan (Tiada perubahan diperlukan) Oleh kerana kami telah menggunakan a , JavaScript kekal persis sama. pelayar akan menghantar automatik kuki apabila ia menyambung ke hub. Cookie mercureAuthorization // The browser sends the cookie automatically!
const eventSource = new EventSource(hubUrl);
 Pengesahan 
 
 
 
 
 Bersihkan kuki: Bersihkan kuki pelayar anda untuk localhost. Load Dashboard: Visit /dashboard. Semak tab Rangkaian. Anda harus melihat tajuk Set-Cookie dengan mercureAuthorization. Semak sambungan: Permintaan EventSource kepada Hub kini mesti hijau (200 OK). Ujian Privasi: Cuba menggelengkan Hub secara langsung tanpa kuki; anda akan menerima 401 Tidak dibenarkan untuk topik peribadi. Kesimpulan Seperti yang telah kami jelajahi, menerapkan data masa nyata dalam Symfony 7.4 bukan sahaja tentang membuka sambungan; ia adalah tentang memilih seni bina yang sesuai dengan corak trafik anda. Semasa yang menawarkan laluan yang cepat dan bebas ketergantungan untuk tugas pentadbiran (seperti bar kemajuan eksport) atau alat dalaman yang rendah trafik, ia membawa risiko yang signifikan mengenai kelelahan pekerja PHP. Native StreamedResponse Untuk mana-mana ciri yang berhadapan dengan pengguna — sama ada ia adalah papan panduan langsung, pusat notis, atau alat kerjasama — Adalah yang Untuk The Ia sepenuhnya memisahkan logik aplikasi anda daripada pengurusan sambungan, membolehkan backend Symfony anda untuk kekal tanpa status dan prestasi manakala Caddy menangani beban berat mengekalkan beribu-ribu sambungan kosong. Mercure non-negotiable standard modern Symfony ecosystem Menguasai corak-corak ini membolehkan anda melampaui kitaran hayat "permintaan dan tindak balas" yang mudah dan membina aplikasi yang berasa hidup dan responsif. Mari kita kekal dalam sentuhan Arsitektur masa nyata sering membawa kerumitan tersembunyi mengenai keseimbangan beban, konfigurasi proxy terbalik (Nginx/HAProxy), dan had keselamatan. Mari kita membincangkan bagaimana kita boleh membuat aplikasi anda bersedia dalam masa nyata.

Read My Stories

Audio ini dihasilkan dalam bahasa asal cerita!

Semua yang anda perlu tahu untuk menguasai peristiwa yang dihantar oleh pelayan (SSE) dalam Symfony 7.4

About Author

KOMEN

GANTUNG TANDA

ARTIKEL INI DIBENTANGKAN DALAM

Related Stories

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps