في كثير من الأحيان نرى فريقًا من (من خلال Socket.io أو Pusher) عندما يحتاجون ببساطة إلى تحديث UI مع تغييرات المستوى على الجانب المورد. في حين أن WebSockets قوية ، فهي غالبا ما يقتل. هذا هو البروتوكول الذي يجب عليك القيام به. WebSockets Server-Sent Events (SSE) يعمل SSE على HTTP / 1.1 المعتاد أو HTTP / 2 المعتاد.ليس من الضروري إدخال اليدين المعقدة، ويعمل مع آليات الاعتماد المعتادة، ويشمل الدعم الأصلية في كل متصفح حديث عبر الموقع. . EventSource API في هذه الدليل ، سنقوم بتنفيذ SSE في Symfony 7.4 باستخدام طريقتين: 
 
 
 الطريقة الأصلية: باستخدام StreamedResponse (أفضل في فهم بروتوكول ومهمات بسيطة منخفضة المنافسة). نهج الإنتاج: باستخدام بروتوكول Mercure (النموذج المتوسطي غير المحدد لـ Symfony). الطريقة الأصلية (StreamedResponse) الـ Symphony يتيح لك وتخزين البيانات إلى العملاء بشكل متزايد.هذه هي تطبيق "الصناعي" من معيار SSE. StreamedResponse keep an HTTP connection open إنشاء جهاز التحكم الجديد. سوف نستخدم إنتاج أو حزمة لتشبه البيانات المتحركة. 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 هي قوية. <!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>
 نظام التشغيل (Critical Configuration) هذا هو المكان الذي يخسر معظم المطورين.الخدمات الويب (nginx ، إلخ) يحب إرسال المفاتيح لتعزيز التكسير.للعاب SSE ، يقتل المفاتيح الدورة (العميل لا يحصل على أي شيء حتى يتم ملء المفاتيح). يجب أن تكون قادرة على أو استخدام لقد أضفت في التحكم. 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: يمنع التخزين في الرماد. النتائج المتوقعة: يجب أن ترى أي موضوع JSON يظهر كل 2 ثانية. التحقق من الواقع "المتقدم" (لماذا المولود هو خطير) While the code above works, I rarely recommend it for high-traffic production apps. عندما يتصل المستخدم إلى /api/stream/stock/AAPL ، يتم إدخال هذا العمل PHP-FPM . . . PHP is synchronous while(true) loop It is locked إذا كان لديك 50 عاملين في PHP-FPM و 50 مستخدمين يفتحون هذه الصفحة ، فإن موقعك كله يقطع. كما أنه يحافظ على اتصال قاعدة بيانات مفتوحة إذا كنت لا تراقب. يجب عليك إرسال إدارة الاتصال المفتوح إلى خدمة مخصصة مصممة خصيصا لها. . Mercure نهج الإنتاج (Mercury) Mercure هو بروتوكول مفتوح لتحديثات في الوقت الحقيقي. 
 
 
 
 
 يتم الاتصال بالعميل إلى مركز (إلا تطبيق PHP الخاص بك) للاستماع إلى الأحداث. يتم إرسال Symfony طلب POST واحد إلى مركز البيانات عند تغيير البيانات. يطلق هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف هاتف النتيجة: الحد الأدنى من الحظر على عمليات PHP. في بيئة الإنتاج، لا يمكنك أن تترك إشاراتك العامة. تحتاج إلى التحكم في من يستطيع سماع ما. مريم تستخدم لهذا الأمر. JSON Web Tokens (JWT) 
 
 
 Publisher JWT: يتيح التطبيق Symfony الخاص بك لإرسال البيانات (التي يتم التعامل بها تلقائيا من قبل الحزمة من خلال MERCURE_JWT_SECRET). JWT المشترك: يسمح للمستخدم بتسمية التحديثات الخاصة. هنا هو كيفية تنفيذ تحميل برنامج Symfony 7.4 Subscriber JWT تثبيت كتابة JWT نحن بحاجة إلى مكتبة لإنتاج الوريدات من قبل مستخدمينا. هذه هي المعايير في بيئة PHP. lcobucci/jwt composer require lcobucci/jwt
 خدمة Generator Token إنشاء خدمة تؤدي إلى إنتاج JWT المقبول للمستخدم المحدد. تحديد الموضوعات التي يسمح للمستخدم بالوصول إليها. 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();
    }
}
 إدخال تقييم (طريقة الكوكيز) متصفح Native لا يدعم إرسال عناوين HTTP (مثل ) EventSource API Authorization: Bearer لتحديد هذا دون إضافة العديد من الملفات الكبيرة في جاكرتا، نستخدم يبحث Mercure Hub تلقائياً عن ملف ما يسمى . 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;
    }
}
 تحديث المصدر الآن، قم بتحديث خدمة المستعرض الخاص بك لتحديد التحديث كمتصفح. // ...
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);
}
 صفحة المستخدم (لا حاجة إلى التغيير) لأننا استخدمنا يظل JavaScript متواضعًا تمامًا، ويترسل المستعرض تلقائيًا الكوكيز عندما يتم الاتصال بالبيت. Cookie mercureAuthorization // The browser sends the cookie automatically!
const eventSource = new EventSource(hubUrl);
 التحقق 
 
 
 
 
 إزالة ملفات الكوكيز: إزالة ملفات الكوكيز الخاصة بك من localhost. تحميل لوحة المراقبة: زيارة / لوحة المراقبة. تحقق في صفحة الشبكة. يجب أن ترى عنوان Set-Cookie مع mercureAuthorization. تحقق من الاتصال: يجب أن يكون طلب EventSource إلى مركز الآن خضراء (200 OK). اختبار الخصوصية: حاول إزالة الوسط مباشرة دون الكوكيز، وسوف تحصل على 401 غير موثوق بها للمناقشات الخاصة. النتيجة كما اكتشفنا، فإن تطبيق البيانات في الوقت الحقيقي في Symfony 7.4 ليس فقط عن فتح اتصال، بل عن اختيار الأكاديمية التي تتوافق مع نمط حركة المرور الخاص بك. في حين أن يوفر مسارًا سريعًا ومتوازنًا للأنشطة الإدارية (مثل صفحات التقدم التصديرية) أو أدوات داخلية منخفضة الدخل، ويحمل المخاطر الكبيرة فيما يتعلق بتوتر الموظفين في PHP. Native StreamedResponse بالنسبة إلى أي ميزة موجهة للمستخدم - سواء كانت لوحة التحكم المباشرة أو مركز الإشعارات أو أداة التعاون - وهذه هي بالنسبة لـ إنه يخترق تماما منطق التطبيق من إدارة الاتصال، مما يسمح لك Symfony backend بالبقاء غير مستقر والقدرة على التكيف مع Caddy تتعامل مع زيادة كبيرة من الحفاظ على الآلاف من الاتصالات المفقودة. Mercure non-negotiable standard modern Symfony ecosystem تتيح لك إدارة هذه الأنماط للتركيز على دورة حياة "الطلب-الرد" البسيطة وتصنيع التطبيقات التي تشعر بالعيش والردع. دعونا نترك في الاتصال في كثير من الأحيان ، يقدم الأكاديمية في الوقت الحقيقي تعقيداً مخفياً حول توازن الأعباء ، والتصميم المستمر (Nginx / HAProxy) ، والحدود الأمنية. دعونا نتحدث عن كيف يمكننا إعداد التطبيق في الوقت الحقيقي.

Read My Stories

تم إنتاج هذا الصوت باللغة الأصلية للقصة!

كل ما تحتاج إلى معرفته لتعلم الأحداث التي يتم إرسالها من قبل المورد (SSE) في Symfony 7.4

About Author

تعليقات

شنق العلامات

تم تقديم هذه المقالة في

Related Stories

I2ShowSpeed With My HackerNoon Articles on Bitcoin

30 Top Blockchain Development Companies in 2019

Credentials Don't Make Alpha Engineers, Products Do

TechWomen is Back Online!

I2ShowSpeed With My HackerNoon Articles on Bitcoin

30 Top Blockchain Development Companies in 2019

Credentials Don't Make Alpha Engineers, Products Do

TechWomen is Back Online!

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps