ຂ້າພະເຈົ້າສືບຕໍ່ໄດ້ຮັບການປະທັບໃຈຂອງພວກເຮົາ (via Socket.io ຫຼື Pusher) ໃນເວລາທີ່ພວກເຮົາມີຄວາມຕ້ອງການທີ່ຈະປັບປຸງ UI ກັບການປ່ຽນແປງຂອງສະພາບແວດລ້ອມ server-side. While WebSockets are powerful, they are often overkill. If your requirement is unidirectional (Server → Client) — like stock tickers, progress bars, or notification feeds — ນີ້ແມ່ນ protocole ທ່ານຈະ master. WebSockets Server-Sent Events (SSE) SSE ດໍາເນີນການໂດຍຜ່ານ HTTP / 1.1 ຫຼື HTTP / 2 ຄຸນນະສົມບູນ. ມັນບໍ່ຈໍາເປັນຕ້ອງມີ handshakes ອັດຕະໂນມັດ, ມັນເຮັດວຽກກັບ mekanisms ອັດຕະໂນມັດ, ແລະການສະຫນັບສະຫນູນທີ່ແທ້ຈິງແມ່ນໄດ້ສ້າງຕັ້ງຂຶ້ນໃນທຸກ browser ທີ່ທັນສະໄຫມໂດຍຜ່ານ . EventSource API ໃນອຸປະກອນນີ້, ພວກເຮົາຈະນໍາໃຊ້ SSE ໃນ Symfony 7.4 ໂດຍໃຊ້ສອງວິທີ: 
 
 
 The Native Approach: ການນໍາໃຊ້ StreamedResponse (ດີສໍາລັບການຮູ້ສຶກ protocol ແລະການເຮັດວຽກຢ່າງງ່າຍດາຍ, ປະສິດທິພາບຕ່ໍາ). ການປິ່ນປົວການຜະລິດ: ການນໍາໃຊ້ protocol Mercure (ມາດຕະຖານການຂະຫຍາຍຕົວ, ບໍ່ blocking ສໍາລັບ Symfony). The Native Approach (StreamedResponse) ລະຫັດ QR ເຮັດໃຫ້ທ່ານ ແລະ flush data ກັບລູກຄ້າຢ່າງກວ້າງຂວາງ. ນີ້ແມ່ນການນໍາໃຊ້ " Raw" ຂອງມາດຕະຖານ SSE. StreamedResponse keep an HTTP connection open Create a new controller. We will use a generator or a loop to simulate streaming data. 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;
    }
}
 ທ່ານບໍ່ຈໍາເປັນຕ້ອງມີໂທລະສັບມືຖືສໍາລັບການນີ້. ໂທລະສັບມືຖື EventSource ຂອງ browser ແມ່ນເຂັ້ມແຂງ. <!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>
 ການຕິດຕັ້ງ Server (Critical) ນີ້ແມ່ນສະຖານທີ່ທີ່ຜູ້ພັດທະນາຫຼາຍທີ່ສຸດບໍ່ໄດ້ເຮັດວຽກ. server Web (nginx, ແລະອື່ນໆ) loves to buffer output to optimize compression. For SSE, buffering kills the stream (client receives nothing until the buffer fills). ທ່ານຈໍາເປັນຕ້ອງ disable ຫຼືການນໍາໃຊ້ ພວກເຮົາໄດ້ເພີ່ມການຄວບຄຸມ. 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;
 ການທົບທວນຄືນ ການຮັບປະກັນ ການຕັ້ງຄ່າ ຫຼືຄຸນນະພາບຕ່ໍາ. php.ini output_buffering Off ການທົບທວນຄືນ 
 
 
 
 
 
 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: Disables buffering ໃນ curl. ການຜະລິດທີ່ຄາດຄະເນດິນ: ທ່ານຄວນຈະຊອກຫາ JSON One Object ໃນ 2 ວິນາທີ. The “Senior” Reality Check (Why Native Is Dangerous) ໃນຂະນະທີ່ລະຫັດທີ່ຜ່ານມາເຮັດວຽກ, ຂໍຂອບໃຈວ່າຂ້າພະເຈົ້າ rarely ນໍາໃຊ້ມັນສໍາລັບການອຸປະກອນການຜະລິດທີ່ມີຄວາມໄວສູງ. ໃນເວລາທີ່ຄອມພິວເຕີເຊື່ອມຕໍ່ກັບ /api/stream/stock/AAPL, ການເຮັດວຽກຂອງ PHP-FPM ຈະເຂົ້າໄປໃນປັດຈຸບັນ ປະເພດ . PHP is synchronous while(true) loop It is locked ຖ້າຫາກວ່າທ່ານມີ 50 ພະນັກງານ PHP-FPM ແລະ 50 ຜູ້ໃຊ້ເປີດເວັບໄຊທ໌ນີ້, ເວັບໄຊທ໌ທັງຫມົດຂອງທ່ານຈະດໍາເນີນການ. ບໍ່ສາມາດປິ່ນປົວຄວາມຕ້ອງການອື່ນໆ. ມັນຍັງເຮັດໃຫ້ການເຊື່ອມຕໍ່ຂໍ້ມູນອີເມວທີ່ເປີດ, ຖ້າຫາກວ່າທ່ານບໍ່ໄດ້ຮັບຄວາມປອດໄພ. ທ່ານຕ້ອງດາວໂຫລດການຄຸ້ມຄອງການເຊື່ອມຕໍ່ Open ກັບບໍລິການ dedicated ທີ່ຖືກອອກແບບໂດຍສະເພາະສໍາລັບມັນ. ໃນ ecosystem Symfony, ການແກ້ໄຂນີ້ແມ່ນ . Mercure ວິທີການຜະລິດ (Mercury) Mercure ແມ່ນ protocole open for real-time updates. ມັນເປັນ Hub. 
 
 
 
 
 Client ການເຊື່ອມຕໍ່ກັບ Hub (ບໍ່ແມ່ນ app PHP ຂອງທ່ານ) ເພື່ອຊອກຫາສໍາລັບເຫດຜົນ. Symfony ສະ ຫນັບ ສະ ຫນັບ ສະ ຫນັບ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ ສະ ຫນູນ Hub ສະຫນັບສະຫນູນຂໍ້ມູນຂອງພວກເຮົາມີຫຼາຍກ່ວາ 1000 ຜູ້ຊອກຫາ. ຄວາມຄິດເຫັນທີ່ Zero Blocking PHP Processes ໃນສະພາບແວດລ້ອມການຜະລິດ, ທ່ານບໍ່ສາມາດສະຫນັບສະຫນູນສະພາບແວດລ້ອມຂອງທ່ານໂດຍທົ່ວໄປ. ທ່ານຈໍາເປັນຕ້ອງຄວບຄຸມຜູ້ທີ່ສາມາດຊອກຫາສິ່ງ. ການນໍາໃຊ້ Mercury ສໍາລັບການນີ້ JSON Web Tokens (JWT) 
 
 
 Publisher JWT: ອະນຸຍາດໃຫ້ app Symfony ຂອງທ່ານເພື່ອທົດລອງຂໍ້ມູນ (ການປິ່ນປົວໂດຍອັດຕະໂນມັດໂດຍ bundle via MERCURE_JWT_SECRET). ຊື່ຫຍໍ້ຂອງ : Subscriber JWT: ອະນຸຍາດໃຫ້ browser ຂອງຜູ້ໃຊ້ເພື່ອຊອກຫາການປັບປຸງສ່ວນບຸກຄົນ. ນີ້ແມ່ນວິທີການນໍາໃຊ້ ດາວໂຫລດ Symfony 7.4 Subscriber JWT ການຕິດຕັ້ງ JWT Library ພວກເຮົາມີຄວາມຕ້ອງການຂອງຄອມພິວເຕີເພື່ອສ້າງ tokens manually ສໍາລັບຜູ້ໃຊ້ຂອງພວກເຮົາ. ເປັນມາດຕະຖານໃນ ecosystem PHP. lcobucci/jwt composer require lcobucci/jwt
 ການບໍລິການ Token Generator Create a service that generates a signed JWT for a specific user. This token will contain a ຊື່ຫຍໍ້ຂອງ : Topics that the user is allowed to access 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();
    }
}
 Injecting the Token (ວິທີການ cookie) ຊື່ຫຍໍ້ຂອງ : Native Browser ດາວນ໌ໂຫລດ HTTP Headers ລະຫັດ QR EventSource API Authorization: Bearer ສໍາລັບການປິ່ນປົວນີ້ໂດຍບໍ່ມີການເພີ່ມ polyfills JavaScript ຂະຫນາດໃຫຍ່, ພວກເຮົາໃຊ້ Mercure Hub ອັດຕະໂນມັດຊອກຫາ cookies ທີ່ມີຊື່ . 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;
    }
}
 ດາວນ໌ໂຫລດ Publisher ໃນປັດຈຸບັນ, ການປັບປຸງບໍລິການ Publisher ຂອງທ່ານເພື່ອຮັບປະກັນການປັບປຸງເປັນ Private. // ...
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);
}
 ຊື່ຫຍໍ້ຂອງ : Client Side (No Changes Needed) ເປັນຫຍັງພວກເຮົາໄດ້ນໍາໃຊ້ a ການຕິດຕໍ່ JavaScript ໄດ້ຖືກນໍາໃຊ້ຢ່າງເຕັມທີ່. ການຕິດຕໍ່ JavaScript ໄດ້ຖືກນໍາໃຊ້ຢ່າງວ່ອງໄວ. cookies ໃນເວລາທີ່ມັນເຊື່ອມຕໍ່ກັບ Hub. Cookie mercureAuthorization // The browser sends the cookie automatically!
const eventSource = new EventSource(hubUrl);
 ການຄວບຄຸມ 
 
 
 
 
 ຄຸນນະສົມບັດຂອງ cookies: ຄຸນສົມບັດຂອງ cookies ສໍາລັບ localhost ດາວໂຫລດ Dashboard: Visit /dashboard. Inspect the Network tab. You should see a Set-Cookie header with mercureAuthorization. ການເຊື່ອມຕໍ່ການຄວບຄຸມ: ຄໍາຮ້ອງສະຫມັກ EventSource ກັບ Hub ຈະເປັນ Green (200 OK). ການທົດສອບຄວາມປອດໄພຂອງພວກເຮົາ: ກະລຸນາທົດສອບຄວາມປອດໄພຂອງພວກເຮົາໂດຍບໍ່ມີການເຂົ້າລະຫັດ cookie; ທ່ານຈະໄດ້ຮັບ 401 Unauthorized ສໍາລັບຫົວຂໍ້ສ່ວນບຸກຄົນ. ພາສາລາວ ໃນຂະນະທີ່ພວກເຮົາໄດ້ທົດລອງ, ການນໍາໃຊ້ຂໍ້ມູນໃນເວລາທີ່ແທ້ຈິງໃນ Symfony 7.4 ແມ່ນບໍ່ພຽງແຕ່ກ່ຽວກັບການເປີດການເຊື່ອມຕໍ່; ມັນແມ່ນກ່ຽວກັບການເລືອກຂອງອຸປະກອນທີ່ເຫມາະສົມກັບຮູບແບບການຂົນສົ່ງຂອງທ່ານ. ໃນເວລາທີ່ The ສະຫນັບສະຫນູນການຝຶກອົບຮົມທີ່ດີທີ່ສຸດສໍາລັບການຝຶກອົບຮົມການຝຶກອົບຮົມແລະການຝຶກອົບຮົມ Native StreamedResponse ສໍາລັບຄຸນນະສົມບັດທີ່ຖືກນໍາໃຊ້ໂດຍຜູ້ໃຊ້ໃດໆ - ບໍ່ວ່າຈະເປັນ Dashboard Live, Notification Center, ຫຼືເຄື່ອງມືການຮ່ວມມື - ມັນແມ່ນ The ສໍາລັບ The ມັນເປັນການຕັດສິນໃຈທີ່ດີທີ່ສຸດ ສໍາ ລັບການປິ່ນປົວຄວາມປອດໄພແລະການປິ່ນປົວຄວາມປອດໄພ. ມັນເປັນການຕັດສິນໃຈທີ່ດີທີ່ສຸດ ສໍາ ລັບການປິ່ນປົວຄວາມປອດໄພ. Mercure non-negotiable standard modern Symfony ecosystem ການຄຸ້ມຄອງຮູບແບບເຫຼົ່ານີ້ສາມາດຊ່ວຍໃຫ້ທ່ານໄປກ່ວາລະດັບປະເພດຂອງ "ການຢັ້ງຢືນ - ການຕອບສະຫນອງ" ທີ່ງ່າຍດາຍແລະສ້າງອຸປະກອນທີ່ສວຍງາມແລະຕອບສະຫນອງ. ຫນ້າທໍາອິດ / Let's Stay In Touch ການອຸປະກອນສະພາບອາກາດໃນເວລາທີ່ແທ້ຈິງໄດ້ຖືກນໍາໃຊ້ຢ່າງກວ້າງຂວາງໃນໄລຍະການປັບປຸງຄວາມກວ້າງຂວາງກ່ຽວກັບການ balancing load, ການຄຸ້ມຄອງ proxy reverse (Nginx / HAProxy) ແລະຄວາມກວ້າງຂວາງຂອງຄວາມປອດໄພ. ພວກເຮົາຈະທົດສອບວິທີທີ່ພວກເຮົາມີຄວາມສາມາດໃນການເຮັດວຽກຂອງທ່ານໃນເວລາທີ່ແທ້ຈິງ.

Read My Stories

ສຽງນີ້ຖືກຜະລິດເປັນພາສາຕົ້ນສະບັບຂອງເລື່ອງ!

ທັງຫມົດທີ່ທ່ານຈໍາເປັນຕ້ອງຮູ້ເພື່ອ Master Server-Sent Events (SSE) ໃນ Symfony 7.4

About Author

ຄຳເຫັນ

ວາງປ້າຍ

ບົດຄວາມນີ້ໄດ້ຖືກນໍາສະເຫນີໃນ

Related Stories

Meet Surfshark: HackerNoon Company of the Week

New Year, New Exciting Features: Mint Your Name, Watch Web 2.5 and Meet The Top Startups of The Year

10 Lessons I Learned as a First-time Tech Product Founder

Unraveling Web and API Security by Vulnerabilities Examples

Meet Surfshark: HackerNoon Company of the Week

New Year, New Exciting Features: Mint Your Name, Watch Web 2.5 and Meet The Top Startups of The Year

10 Lessons I Learned as a First-time Tech Product Founder

Unraveling Web and API Security by Vulnerabilities Examples

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps

ທັງຫມົດທີ່ທ່ານຈໍາເປັນຕ້ອງຮູ້ເພື່ອ Master Server-Sent Events (SSE) ໃນ Symfony 7.4

About Author

ຄຳເຫັນ

ວາງປ້າຍ

ບົດ​ຄວາມ​ນີ້​ໄດ້​ຖືກ​ນໍາ​ສະ​ເຫນີ​ໃນ

Related Stories

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps

ບົດຄວາມນີ້ໄດ້ຖືກນໍາສະເຫນີໃນ