‫رویکردی نوین به ارتباطات بی‌درنگ: رویدادهای ارسالی سرور (Server-Sent Events) در NET 10.

• آغاز اتصال توسط کلاینت: کلاینت (معمولاً یک مرورگر یا برنامه فرانت‌اند) با استفاده از EventSource API یک درخواست HTTP به سرور آغاز می‌کند. این API به طور خاص برای مدیریت اتصالات SSE طراحی شده است.
• باز نگه داشتن اتصال توسط سرور: سرور اتصال را باز نگه می‌دارد و به طور مداوم پیام‌ها را در قالب text/event-stream به کلاینت ارسال می‌کند. این فرمت استاندارد برای رویدادهای ارسالی سرور است که تضمین می‌کند کلاینت می‌تواند پیام‌ها را به درستی تفسیر کند.
• دریافت و پردازش پیام توسط کلاینت: کلاینت پیام‌ها را به صورت بی‌درنگ دریافت می‌کند و با استفاده از شنونده‌های رویداد (JavaScript event listeners) آن‌ها را پردازش می‌کند. این شنونده‌ها می‌توانند به رویدادهای خاصی گوش دهند و با دریافت داده‌های جدید، رابط کاربری را به‌روزرسانی کنند یا اقدامات دیگری را انجام دهند.

• اعلان‌های زنده (Live Notifications): مانند اعلان‌های شبکه‌های اجتماعی یا سیستم‌های پیام‌رسان.
• نشان‌دهنده‌های سهام (Stock Tickers): برای نمایش تغییرات قیمت سهام به صورت لحظه‌ای.
• گزارش‌های بی‌درنگ (Realtime Logs): نمایش لاگ‌های سیستم به محض تولید.
• به‌روزرسانی‌های آب و هوای بی‌درنگ (Realtime Weather Updates): ارائه اطلاعات آب و هوا به صورت لحظه‌ای.

• ارتباطات دوطرفه (Bi-directional communications): در سناریوهایی مانند برنامه‌های چت که کلاینت نیز نیاز به ارسال داده به سرور دارد، SSE راه حل مناسبی نیست. در این موارد، فناوری‌هایی مانند WebSockets گزینه بهتری هستند.
• فرکانس بالای به‌روزرسانی‌های دوطرفه: در کاربردهایی که حجم بالایی از تبادل داده دوطرفه وجود دارد، WebSockets کارایی بیشتری خواهند داشت.

public class RideStatusService: INotifyPropertyChanged
{
    public RideStatusService()
    {
        NextDirection = "Starting the trip";
    }

    private static List<string> _directions = ["left", "right", "straight"];
    private static List<string> _distances = ["50", "60", "70", "80", "90", "100"];
    public event PropertyChangedEventHandler? PropertyChanged;
    
    private string _nextDirection;
    
    private string NextDirection
    {
        get => _nextDirection;
        set
        {
            _nextDirection = value;
            OnPropertyChanged();
        }
    }

    protected virtual void OnPropertyChanged([CallerMemberName] string? propertyName = null)
    {
        PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(propertyName));
    }

    public void SetDirection()
    {
        NextDirection = $"Going {_directions[Random.Shared.Next(_directions.Count)]} for {_distances[Random.Shared.Next(_distances.Count)]} meters";
    }
    
    public async IAsyncEnumerable<string> GetNextDirection([EnumeratorCancellation] CancellationToken ct)
    {
        while (ct is not { IsCancellationRequested: true })
        {
            yield return NextDirection;
            var tcs = new TaskCompletionSource();
            PropertyChangedEventHandler handler = (_, _) => tcs.SetResult();
            PropertyChanged += handler;
            try
            {
                await tcs.Task.WaitAsync(ct);
            }
            finally
            {
                PropertyChanged -= handler;
            }
        }
    }
}

public class RideShareBackgroundWorker(RideStatusService rideStatusService): BackgroundService
{
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            rideStatusService.SetDirection();
            await Task.Delay(1000, stoppingToken);
        }
    }
}

app.MapGet("/ride-status", (RideStatusService rideStatusService, CancellationToken cancellationToken) => 
    TypedResults.ServerSentEvents(rideStatusService.GetNextDirection(cancellationToken), eventType: "ride-status")
);

builder.Services.AddSingleton<RideStatusService>();
builder.Services.AddHostedService<RideShareBackgroundWorker>();

<div class="text-center">
    <h1 class="display-4">Welcome to My Ride Share</h1>
    <h4>You current ride's routing status is:</h4>
    
    <ul id="status"></ul>
</div>

<script>
    const eventSource = new EventSource('http://localhost:5252/ride-status');
    const statusList = document.getElementById('status');

    eventSource.addEventListener('ride-status', event => {
        const li = document.createElement('li');
        li.textContent = event.data;
        statusList.appendChild(li);
    });

    eventSource.onerror = error => {
        console.error('EventSource failed for ride status:', error);
        eventSource.close();
    };
</script>