C# Dotnet SSE Server выполняет ответ, но браузер не отображает сообщения. Почему? ⇐ Javascript

[Anonymous]

I have an SSE Server that has the following settings/requirements:

• C# dotnet 8
• Non Blocking Communication
• No ASP
• No Extention
• Allow CORS

On the Другая сторона (клиент) У меня есть браузер с javascript < /p>
Проблема: < /p>

Я вижу связь с клиента на сервер.
Сервер принимает запрос и отправляет пакеты обратно клиенту. Пакеты. Затем через короткий промежуток времени кэшированные пакеты (много пакетов). Но я думаю, что кэш заполнен, и я вижу кэш.using System;
using System.Collections.Generic;
using System.Net;
using System.Text;
using System.Threading.Tasks;
using System.Timers;

class Program
{
private static readonly List clients = new List();
private static readonly object lockObject = new object();
private static System.Timers.Timer? messageTimer;

static async Task Main(string[] args)
{
string url = "http://+:5000/";
HttpListener listener = new HttpListener();
listener.Prefixes.Add(url);
listener.Start();
Console.WriteLine($"Server runs on {url}");

// Timer
messageTimer = new System.Timers.Timer(1000);
messageTimer.Elapsed += SendPeriodicMessages;
messageTimer.AutoReset = true;
messageTimer.Enabled = true;

while (true)
{
HttpListenerContext context = await listener.GetContextAsync();
HandleClient(context);
}
}

private static void HandleClient(HttpListenerContext context)
{
HttpListenerRequest request = context.Request;
HttpListenerResponse response = context.Response;

response.Headers.Add("Access-Control-Allow-Origin", "*");
response.Headers.Add("Access-Control-Allow-Methods", "GET, OPTIONS");
response.Headers.Add("Access-Control-Allow-Headers", "Content-Type");

if (request.HttpMethod == "OPTIONS")
{
response.Headers.Add("Access-Control-Allow-Origin", "*");
response.Headers.Add("Access-Control-Allow-Methods", "GET, OPTIONS");
response.Headers.Add("Access-Control-Allow-Headers", "Content-Type");
response.StatusCode = (int)HttpStatusCode.OK;
response.OutputStream.Close();
return;
}

response.Headers.Add("Content-Type", "text/event-stream");
response.Headers.Add("Cache-Control", "no-cache");
response.Headers.Add("Connection", "keep-alive");

AddClient(context);
}

private static void AddClient(HttpListenerContext context)
{
lock (lockObject)
{
clients.Add(context);

var clientIp = context.Request.RemoteEndPoint.Address.ToString();
var clientPort = context.Request.RemoteEndPoint.Port;
Console.WriteLine($"Client connected: IP = {clientIp}, Port = {clientPort}");
}
}

static int TimerCounter = 0;
private static void SendPeriodicMessages(object? sender, ElapsedEventArgs e)
{
Console.WriteLine("TimerTick " + TimerCounter);
SendMessagesToClients("data: " + TimerCounter++ + "\\n\\n");
}

private static void SendMessagesToClients(string message)
{
Task.Run(async () =>
{
byte[] buffer = Encoding.UTF8.GetBytes(message);

List sendTasks = new List();
List removeList = new ();

lock (lockObject)
{
Console.WriteLine("Number of Clients: " + clients.Count);
foreach (var client in clients)
{
sendTasks.Add(Task.Run(() =>
{
try
{
HttpListenerRequest request = client.Request;
HttpListenerResponse response = client.Response;

var clientIp = client.Request.RemoteEndPoint.Address.ToString();
var clientPort = client.Request.RemoteEndPoint.Port;
Console.WriteLine($"Sending Data ({buffer.Length}) to {clientIp}:{clientPort}");

response.OutputStream.Write(buffer, 0, buffer.Length);
response.OutputStream.Flush();
}
catch (Exception ex)
{
Console.WriteLine($"Error - Cant send data to Client: {ex.Message}");
removeList.Add(client);
}
}));
}
}

await Task.WhenAll(sendTasks);

lock (lockObject)
{
while (removeList.Count > 0)
{
clients.Remove(removeList.First());
removeList.RemoveAt(0);
}
}
});
}
}
< /code>
и javacode: < /p>






TEST



Server Send Event



const eventSource = new EventSource('http://192.168.56.245:5000/');

eventSource.onmessage = function(event) {
const messagesDiv = document.getElementById('messages');
messagesDiv.innerHTML += `
${event.data}
`;
console.log(event.data);
};

eventSource.onerror = function(event) {
console.error("Error receiving messages from SSE:", event);
eventSource.close();
};





Подробнее здесь: https://stackoverflow.com/questions/796 ... e-messages