Symfony 7.4 හි Server-Sent Events (SSE) ක්රියාත්මක කිරීම සඳහා ඔබ දැනගත යුතු සියල්ල

මම නිතරම දකිනවා කණ්ඩායම් පිවිසීමට (Socket.io හෝ Pusher හරහා) ඔවුන් සෘජුවම සේවාදායක තත්වය වෙනස් කිරීම සමඟ UI යාවත්කාලීන කිරීමට අවශ්ය විට. WebSockets බලවත් වන අතර, ඔවුන් බොහෝ විට overkill.If your requirement is unidirectional (Server → Client) — such as stock tickers, progress bars, or notification feeds — ඔබ පාඩම් කළ යුතු ප්රොටෝලට්. WebSockets Server-Sent Events (SSE) SSE සම්මත HTTP / 1.1 හෝ HTTP / 2 හරහා ක්රියා කරයි.එය සංකීර්ණ අතපසු අවශ්ය නොවේ, එය සම්මත ඔප්පු යන්ත්රයන් සමඟ ක්රියා කරයි, සහ සම්මත සහාය සෑම නවීන බ්රවුසරයටම ඇතුළත් වේ. . EventSource API මෙම මාර්ගෝපදේශයේ දී, අපි Symfony 7.4 හි SSE ක්රියාත්මක කරමු: The Native Approach: Using StreamedResponse (පොටෝලට් සහ සරල, අඩු තරඟකාරී කාර්යයන් තේරුම් ගැනීම සඳහා විශිෂ්ට). නිෂ්පාදන ප්රවේශය: Mercure ප්රොටෝලට් භාවිතා කිරීම (Symfony සඳහා ප්රමාණවත්, නොබැඳෙන සම්මතය). The Native Approach (StreamedResponse) ප් රදර්ශනය සින්ෆෝනියාව ඔබට ඉඩ දෙන්නේ ඒ අනුව, මෙම පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් රමවේදයේ පර්යේෂණ ක් 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 ශක්තිමත් වේ. Symfony SSE Stream Live Ticker: LOADING... -- 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 }; සේවාදායක සංකල්පය (Critical) බොහෝ පරිගණකයින් අසාර්ථක වන්නේ මෙහිදීයි. වෙබ් සේවාදායකයින් (nginx, ආදිය.) සංකීර්ණ කිරීම සඳහා බැෆර් ප්රතිඵල ලබා ගැනීමට කැමතියි.SSE සඳහා, බැෆර් පද්ධතිය මරා දමන්නේය (බෆර් සම්පූර්ණ වන තුරු පාරිභෝගිකයා කිසිවක් නොලැබේ). ඔබ අහිතකර විය යුතුය හෝ භාවිතා කරන්න අපි Controller එක ඇතුලත් කළා. 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: Curl හි buffering අවලංගු කරයි. බලාපොරොත්තු වූ ප් රතිඵලයක්: සෑම තත්පර දෙකකට වරක් එක් JSON ඔත්තු දැක්විය යුතුය. The “Senior” Reality Check (Why Native is Dangerous) (ඇයි නවීන ජාතිකයා භයානකද) ඉහත කේතය ක්රියාත්මක වන අතර, මම බොහෝ විට අධිවේගී නිෂ්පාදන යෙදුම් සඳහා එය නිර්දේශ කරමි. Client එක /api/stream/stock/AAPL එකට සම්බන්ධ වන විට, ඒ PHP-FPM worker process එක ඇතුළත් වේ. . PHP is synchronous while(true) loop It is locked ඔබ PHP-FPM සේවකයින් 50 ක් සහ 50 ක් මෙම පිටුව විවෘත කරන්නේ නම්, ඔබේ මුළු වෙබ් අඩවිය බිඳ වැටෙනු ඇත. ඔබ පරිස්සම් නොවී නම් එය දත්ත සබැඳි විවෘත කරයි. ඔබ විවෘත සම්බන්ධතා කළමනාකරණය ඒ සඳහා විශේෂයෙන් නිර්මාණය කරන ලද විශේෂ සේවයට බාගත කළ යුතුය. . Mercure නිෂ්පාදන ක් රමය (Mercury) Mercure යනු සැබෑ කාලීන යාවත්කාලීන කිරීම සඳහා විවෘත ප්රොටොක්ටොක් ය.එය Hub ලෙස ක්රියා කරයි. ගනුදෙනුකරුවන් සිදුවීම් සඳහා ඇසීමට Hub (ඔබගේ PHP යෙදුම නොවේ) වෙත සම්බන්ධ වේ. Symfony දත්ත වෙනස් කරන විට එක් එක් POST ඉල්ලීමක් හුවමාරු කරයි. Hub දහස් ගණනක් සවන් දෙන අයට දත්ත ප්රවාහනය කරයි. ප්රතිඵල: PHP ක්රියාවලිය බිඳ දැමීම. නිෂ්පාදන පරිසරය තුළ, ඔබ ඔබේ ප්රවාහය ප්රකාශයට පත් කළ නොහැක.ඔබ පාලනය කළ යුතුය කවුද කුමක් ඇහුම්කන් කළ හැකි. Mercury භාවිතය මේ සඳහා JSON Web Tokens (JWT) Publisher JWT: ඔබගේ Symfony යෙදුම මගින් දත්ත ( MERCURE_JWT_SECRET හරහා bundle විසින් ස්වයංක්රීයව කළමනාකරණය කරනු ලැබේ). Subscriber JWT: පරිශීලකයාගේ බ්රවුසරයට පෞද්ගලික යාවත්කාලීන කිරීම් ඇසීමට ඉඩ සලසයි. මෙන්න කොහොමද implement කරන්නෙ සින්ෆෝනියාව 7.4 Subscriber JWT JWT Library ස්ථාපනය කිරීම අපගේ පරිශීලකයින් සඳහා මෑතව ටෝකන් නිර්මාණය කිරීමට පුස්තකාලයක් අවශ්ය වේ. එය PHP පරිගණකයේ ස්ථාවරයකි. lcobucci/jwt composer require lcobucci/jwt Token Generator සේවා විශේෂිත පරිශීලකයක් සඳහා අත්සන් කරන 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(); } } කුකී ක් රමය (The Cookie Method) Native බ්රවුසරය HTTP Headers යැවීමට ප් රයෝජනවත් නොවේ (උදා: ) EventSource API Authorization: Bearer මෙම ගැටලුව විසඳීමට අපහසු JavaScript polyfills එකතු කිරීමකින් තොරව, අපි 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; } } විවෘත කිරීම Publisher දැන් ඔබගේ Publisher සේවාව යාවත්කාලීන කරන්න, මෙම යාවත්කාලීන කිරීම පෞද්ගලික ලෙස සකස් කරන්න. // ... public function publishPrivateAlert(string $userId, string $message): void { $topic = "https://mysite.com/user/{$userId}/alerts"; $update = new Update( $topic, json_encode(['alert' => $message]), true // hub->publish($update); } පාරිභෝගික පිටුව (අවශ්ය කිසිදු වෙනසක්) මොකද අපි පාවිච්චි කලේ A , JavaScript නිවැරදිව සමාන වන අතර, බ්රවුසරය ස්වයංක්රීයව එය Hub එකට සම්බන්ධ වන විට කුකී. Cookie mercureAuthorization // The browser sends the cookie automatically! const eventSource = new EventSource(hubUrl); පරීක්ෂා කිරීම Clear Cookies: localhost සඳහා ඔබගේ බ්රවුසරය කුකීස් පිරිසිදු කරන්න. Load Dashboard: Visit /dashboard. Network tab පරීක්ෂා කරන්න. you should see a Set-Cookie header with mercureAuthorization. සම්බන්ධතාවය පරීක්ෂා කිරීම: දැන් Hub වෙත EventSource ඉල්ලීම Green (200 OK) විය යුතුය. පෞද්ගලිකත්වය පරීක්ෂා කිරීම: කුකීස් නොමැතිව සෘජුවම හුවමාරු කිරීමට උත්සාහ කරන්න; ඔබ පුද්ගලික මාතෘකා සඳහා 401 අවසර නොලැබේ. ප් රතිඵල අපි පරීක්ෂා කර ඇති පරිදි, සැබෑ කාලීන දත්ත සකස් කිරීම Symfony 7.4 හි සම්බන්ධතාවය විවෘත කිරීම ගැන පමණක් නොවේ; එය ඔබේ ප් රවාහන ආකෘතියට ගැලපෙන ආකෘතිය තෝරා ගැනීමයි. ඒ අතරින් The කළමනාකරණ කාර්යයන් සඳහා වේගවත්, ස්වාධීන මාර්ගය ලබා දීම (උදාහරණයක් වශයෙන්, ප්රවාහන ක්රියාත්මක කිරීම්) හෝ අඩු ප්රවේශය සහිත අභ්යන්තර මෙවලම්, එය PHP කාර්ය මණ්ඩලයේ පිරිසිදු වීම සම්බන්ධයෙන් විශාල අවදානමක් සපයයි. Native StreamedResponse ඕනෑම පරිශීලක ප්රවේශයක් සඳහා - එය සජීවී ආකෘති පුවරුවක්, තැපැල් මධ්යස්ථානය හෝ සන්නිවේදන මෙවලමක් - එය The සඳහා The එය සම්පූර්ණයෙන්ම සම්බන්ධතාවය කළමනාකරණයෙන් ඔබේ යෙදුම් ලෝහය වෙන් කරයි, ඔබේ Symfony backend ස්ථාවර හා ක්රියාකාරීව ඉතිරි කිරීමට ඉඩ සලසයි අතර, Caddy දහස් ගණනක් හිස් සම්බන්ධතා සකස් කිරීම සඳහා බරපතල ප්රමාණය පාලනය කරයි. Mercure non-negotiable standard modern Symfony ecosystem මෙම ආකෘති පාලනය කිරීමෙන් ඔබට සරල "අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අවශ්ය-අ අපි Touch එකට ඉන්නම් සැබෑ කාලීන ආකෘතිය බොහෝ විට load balancing, reverse proxy configuration (Nginx/HAProxy) සහ security boundaries ගැන සැඟවුණු සංකීර්ණතා ගෙන එයි. අපි ඔබේ යෙදුම සැබෑ කාලය තුළ සූදානම් කර ගත හැකි ආකාරය ගැන සාකච්ඡා කරමු.