Laravel 및 Vue.js의 SSE(서버 전송 이벤트)를 통한 실시간 알림

서버 전송 이벤트(SSE)는 애플리케이션에서 실시간 알림이나 업데이트를 활성화하는 데 유용한 솔루션입니다. WebSocket과 달리 SSE는 서버에서 클라이언트로의 단방향 통신을 허용하므로 가볍고 구현하기 쉽습니다. 이 튜토리얼에서는 Laravel 백엔드에서 SSE를 설정하고 Vue.js 프런트엔드에서 이벤트를 사용하는 방법을 살펴보겠습니다.

개요

SSE를 사용하여 간단한 실시간 알림 시스템을 만들어 보겠습니다. 서버(Laravel)는 인증된 사용자에 대한 새로운 알림이 있을 때마다 클라이언트(Vue.js)에 알림을 푸시합니다. 우리가 다룰 내용은 다음과 같습니다.

1. 백엔드(Laravel): 알림을 스트리밍하도록 SSE 엔드포인트를 설정합니다.
2. 프런트엔드(Vue.js): 들어오는 알림을 수신하도록 EventSource를 설정합니다.

1단계: 백엔드(Laravel)

1.1 Laravel에서 SSE 경로 생성

routes/api.php에서 SSE 스트림에 대한 엔드포인트를 생성합니다. 이렇게 하면 Vue.js 프런트엔드가 SSE 연결을 설정하고 알림을 수신할 수 있습니다.
AppHttpControllersNotificationController를 사용하세요.

Route::get('/notifications', [NotificationController::class, 'get']);

1.2 스트리밍 알림을 위한 컨트롤러 방법

다음으로, NotificationController에서 데이터베이스에서 읽지 않은 알림을 가져오고 SSE를 통해 클라이언트로 스트리밍하는 논리를 구현합니다.

namespace App\Http\Controllers;

use App\Models\Notification;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;

class NotificationController extends Controller
{
    public function get(Request $request)
    {
        $headers = [
            "Content-Type" => "text/event-stream",
            "Cache-Control" => "no-cache",
            "Connection" => "keep-alive",
            "X-Accel-Buffering" => "no",
        ];

        return response()->stream(function () {
            while (true) {
                // Fetch the unread notifications for the authenticated user
                $notifications = Notification::where('clicked', 0)
                                             ->where('user_id', 2)  // For now, hardcoding the user ID, you can replace it with Auth::id() for dynamic user handling
                                             ->get();

                // If there are notifications, send them to the frontend
                if ($notifications->isNotEmpty()) {
                    // Format notifications as JSON and send them via SSE
                    echo "data: " . json_encode($notifications) . "\n\n";
                }

                // Flush the output buffer
                ob_flush();
                flush();

                // Sleep for a few seconds before checking again
                sleep(5);
            }
        }, 200, $headers);
    }
}

설명:

스트리밍 응답: response()->stream() 메서드는 무한한 이벤트 스트림을 보내는 데 사용됩니다.
알림: 특정 사용자에 대해 읽지 않은 알림(클릭 = 0)에 대한 알림 모델을 쿼리하고 있습니다. 알림은 JSON으로 인코딩되어 클라이언트로 전송됩니다.
헤더: 헤더는 SSE(Content-Type: text/event-stream)에 대해 설정됩니다.
무한 루프: while(true) 루프는 연결을 열린 상태로 유지하고 5초마다 새로운 알림을 계속 보냅니다(sleep(5)을 수정하여 조정 가능).

2단계: 프런트엔드(Vue.js)

이제 EventSource API를 사용하여 이러한 알림을 수신하도록 Vue.js 프런트엔드를 설정해 보겠습니다.

2.1. SSE 이벤트를 수신하도록 Vue 구성 요소 설정

SSE 스트림에서 들어오는 이벤트를 수신하는 Vue 구성 요소를 만듭니다.

<template>
  <div>
    <h3 id="Unread-Notifications">Unread Notifications</h3>
    <ul v-if="notifications.length">
      <li v-for="notification in notifications" :key="notification.id">
        {{ notification.message }}
      </li>
    </ul>
    <p v-else>No new notifications</p>
  </div>
</template>

<script>
export default {
  data() {
    return {
      notifications: [], // Store notifications
    };
  },
  mounted() {
    // Initialize EventSource to listen to the /api/notifications endpoint
    const eventSource = new EventSource('/api/notifications');

    // Handle incoming events from SSE
    eventSource.onmessage = (event) => {
      const data = JSON.parse(event.data); // Parse JSON data from the server
      this.notifications = data;  // Update notifications list
    };

    // Handle errors
    eventSource.onerror = (error) => {
      console.error("EventSource failed:", error);
      eventSource.close(); // Close the connection if there's an error
    };
  },
  beforeDestroy() {
    // Close the SSE connection when the component is destroyed
    if (this.eventSource) {
      this.eventSource.close();
    }
  }
};
</script>

설명:

1. EventSource: /api/notifications 엔드포인트를 수신하는 EventSource 인스턴스를 생성합니다. 그러면 서버에 대한 지속적인 연결이 설정됩니다. onmessage: 이 이벤트 리스너는 수신 메시지를 처리합니다. 데이터는 JSON에서 구문 분석되어 알림 배열에 추가됩니다. onerror: 오류가 발생하면(예: SSE 연결이 끊어진 경우) 오류를 기록하고 연결을 닫습니다.
2. beforeDestroy: 메모리 누수를 방지하기 위해 구성 요소가 삭제되면 SSE 연결이 닫힙니다.

결론

이 튜토리얼에서는 Laravel 백엔드와 Vue.js 프런트엔드에서 SSE(서버 전송 이벤트)를 사용하여 실시간 알림을 설정했습니다. SSE는 실시간 업데이트를 클라이언트에 푸시하는 간단하고 효율적인 방법을 제공하므로 알림과 같은 기능에 탁월한 선택입니다. 최소한의 설정만으로 실시간 실시간 기능으로 애플리케이션을 향상시킬 수 있습니다.

위 내용은 Laravel 및 Vue.js의 SSE(서버 전송 이벤트)를 통한 실시간 알림의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!