EventSource; отправленные сервером события - PullRequest
Новая
       52

EventSource; отправленные сервером события

0 голосов
/ 07 марта 2020

Я пытаюсь обработать EvenSource, отправленный из браузера на мой C# WebServer.

Когда я получаю HTTP-запрос (Get / event / api / endpoint) .. Я отвечаю: - 200 OK и with - Content-Type: text / event-stream - body: data: null

Консоль успешно записывает информацию. На сервере я держу соединение открытым и поток ответов также открытым. Кажется, что мой сервер не отправляет последующие события через уже открытый TCP Response.Outputstream.

Проблема в том, что браузер (Chrome) отправляет новое событие, как если бы соединение было закрыто, но это не так.

Код клиента: 

<html lang="en">
<head>
    <meta charset="utf-8">
    <meta http-equiv="X-UA-Compatible" content="IE=Edge,chrome=1">
    <title>SSE Test</title>
</head>
<body style="background: #fff;">
    <div id="infoPane">
    </div>
</body>
    <script>
    (function() {
        var infoPane = document.getElementById('infoPane');
        var report = function(msg) {
            var info = document.createElement('p'); 
            info.textContent = msg;
            infoPane.appendChild(info);
        };

        var source = 'http://localhost:8011/SSE/now';
        var loader = new EventSource(source);
        loader.onmessage = function (event) {
            report(event.data);
        };
    }());
    </script>
</html>

Код сервера: 

var listener = new HttpListener();
listener.Prefixes.Add("http://+:8011/SSE/");
listener.Start();
Task.Run(() =>
{
    while (true)
    {
        var ctx = listener.GetContext();
        Task.Run(() =>
        {
            var response = ctx.Response;
            response.StatusCode = (int)HttpStatusCode.OK;
            response.ContentType = "text/event-stream";
            response.ContentEncoding = Encoding.UTF8;
            try
            {
                while (true)
                {
                    var msg = string.Format("data: it is now {0} Zulu\n\n", DateTime.UtcNow);
                    var bytes = Encoding.UTF8.GetBytes(msg);
                    response.OutputStream.Write(bytes, 0, bytes.Length);
                    response.OutputStream.Flush();
                    System.Threading.Thread.Sleep(1000);
                }
            }
            catch (HttpListenerException)
            {
            }
        });
    }
});

1 Ответ

0 голосов
/ 09 марта 2020

Это также исправлено.

Это ограничение от MSFT HttpListener .. Мне пришлось создать свой собственный C# HTTP и HTTPS веб-сервер с нуля поверх TCPClient ... это наверняка лучше, чем реализация MSFT сто раз!

...