ASPNET-Core-Server Gesendeten Ereignisse / Antwort flush

Zwar gibt es keine offizielle Dokumentation, weiss jemand wie SSE implementiert werden kann, mit ASP.NET Core?

Ich vermute, dass eine Umsetzung möglicherweise verwenden Sie benutzerdefinierte middleware, vielleicht ist es aber möglich, dass in der controller-action?

  • Sprechen Sie von SignalR?
  • Nein, es gibt keine SignalR für Core noch.
  • Als eine Angelegenheit von der Tat, SignalR 3 steht in der rc1-Finale auf der sowohl die offiziellen nuget feed sowie auf die myget Stall myget.org/gallery/aspnetmaster und nightlies. Das ist, warum ich fragte. Jedoch, es wird nicht bereit sein, für die Freigabe, wenn ASP.NET Core 1.0 veröffentlicht wie bereits erwähnt auf der roadmap github.com/aspnet/Home/wiki/Roadmap
  • Danke, mir war nicht bewusst, dass. Ich werde einen Blick auf die Quelle, vielleicht finde ich etwas nützliches. In dieser situation, kompletter Rahmen ist ein wenig übertrieben. Ich habe eine single-uni-direktional-Kanal, implementiert unter Verwendung von websockets und ich bin auf der Suche nach Möglichkeiten, wie Sie machen es noch einfacher.
  • pre-Core: github.com/erizet/ServerSentEvent4Net
InformationsquelleAutor Zygimantas | 2016-03-25
  1. 40

    wwwroot/index.html

    Laden der Seite, erstellen Sie eine EventSource für die http://www.somehost.ca/sse url. Schreiben Sie dann Ihre Veranstaltungen auf der Konsole. 

    <body>
    <script type="text/javascript">

        var source = new EventSource('sse');

        source.onmessage = function (event) {
            console.log('onmessage: ' + event.data);
        };

        source.onopen = function(event) {
            console.log('onopen');
        };

        source.onerror = function(event) {
            console.log('onerror');
        }

    </script>
</body>

    Middleware

    Die middleware verarbeitet die sse Weg. Es legt die Content-Type header text/event-stream, die den server-socket-Ereignis benötigt. Dann schreibt es in den Antwort-stream, ohne schließen der Verbindung. Es ahmt die Arbeit, durch die Verzögerung für fünf Sekunden zwischen den schreibt. 

    app.Use(async (context, next) =>
{
    if (context.Request.Path.ToString().Equals("/sse"))
    {
        var response = context.Response;
        response.Headers.Add("Content-Type", "text/event-stream");

        for(var i = 0; true; ++i)
        {
            //WriteAsync requires `using Microsoft.AspNetCore.Http`
            await response
                .WriteAsync($"data: Middleware {i} at {DateTime.Now}\r\r");

            await response.Body.FlushAsync();
            await Task.Delay(5 * 1000);
        }
    }

    await next.Invoke();
});

    Controller

    Der controller tut genau das gleiche wie die middleware übernimmt.

    [Route("/api/sse")]
public class ServerSentEventController : Controller
{
    [HttpGet]
    public async Task Get()
    {
        var response = Response;
        response.Headers.Add("Content-Type", "text/event-stream");

        for(var i = 0; true; ++i)
        {
            await response
                .WriteAsync($"data: Controller {i} at {DateTime.Now}\r\r");

            response.Body.Flush();
            await Task.Delay(5 * 1000);
        }
    }
}

    Die Ausgabe der Konsole in Firefox

    Dies ist das Ergebnis in der Firefox-Konsole-Fenster. Alle fünf Sekunden neue Nachrichten ankommt. 

    onopen
onmessage: Message 0 at 4/15/2016 3:39:04 PM
onmessage: Message 1 at 4/15/2016 3:39:09 PM
onmessage: Message 2 at 4/15/2016 3:39:14 PM
onmessage: Message 3 at 4/15/2016 3:39:19 PM
onmessage: Message 4 at 4/15/2016 3:39:24 PM

    Referenzen:

    • Danke Shaun, deine Antwort sieht sehr umfassend. Ich überweise Rufpunkte bald, ich habe noch immer Probleme bei der Wiedergabe dieser auf RC1 auf der lokalen Maschine und Azure. Es sieht aus wie die Reaktion ist nicht geleert, die bei jeder iteration. Vielleicht ist es eine gute Zeit zu gehen, um pre-RC2.
    • Es ist definitiv eine gute Zeit zu gehen, um pre-RC2. Ich habe nicht versucht, die oben auf der RC1. Während der Arbeit mit pre-RC2 kann schmerzhaft sein, werden Sie lernen, eine riesige Menge, wie Sie arbeiten durch den Schmerz.
    • danke für das drücken, um die bleeding edge 🙂 Jetzt kann ich bestätigen, das funktioniert auf pre-RC2 als erwartet, aber nicht auf der RC1.
    • Gutes Zeug. Die RC1 Zeug ist gut und ist ein "go-live" - Produkt. Die RC2 ist aber die Zukunft, so ist es eine gute Idee, beginnen Sie zu lernen. Ich bin froh zu hören, dass dieses für Sie arbeitet. 🙂
    • Ich habe auch bemerkt, dass du mit IHttpContextAccessor anstelle des Erben ControllerBase und diese aufrufen.HttpContext. Ich habe nicht gesehen, bevor auf RC1. Gibt es irgendwelche Vorteile das zu tun?
    • Ich bin mir nicht sicher über die Vorteile des einen über den anderen. Ich weiß, dass das neue MVC unterstützt plain-old-crl-Objekt (POCO) - Controller. In anderen Worten, dies sind die Controller, die Erben nicht von der Controller Klasse. Ich tendiere Weg von der Vererbung für einfache Projekte, den overhead zu vermeiden. Es gibt Vorteile für die Erben der Controller Klasse. Es kommt mit einer Menge von hilfsprozeduren, so zu sprechen. Hier ist die Klasse. Kasse seiner öffentlichen/Schutz der Mitglieder, um zu sehen, was es gibt Sie: github.com/aspnet/Mvc/blob/dev/src/...
    • Um zu sehen, die WriteAsyn() auf die Antwort, die Sie brauchen, um mit Microsoft.AspNetCore.Http;
    • Gibt es eine Möglichkeit, um eine Nachricht zu senden, die nur für bestimmte Benutzer? Können wir utilize_httpContextAccessor.HttpContext.Benutzer für diese?
    • Ich fürchte, ich weiß nicht, wie zu tun, dass aus der Spitze von meinem Kopf.
    • Wie Sie wissen, wenn zum schließen der Verbindung? Wenn ich den browser aktualisieren es einen zweiten Antrag, der fordert, den controller wieder verlassen 2 Schleifen laufen.
    • Sie können schließen Sie die Verbindung von der client-Seite durch den Aufruf die Ereignisquelle.schließen().
    • Weiß jemand, warum die Antwort auf diese Anfrage ist immer text/html und nicht text/event-stream??? Ich ständig erhalten "EventSource' s Antwort hat einen MIME-type ("text/html"), die nicht "text/event-stream". Die Verbindung abgebrochen wird.", in Chrom, obwohl es scheint nicht abzubrechen oder wieder an alle. Seltsam.
    • Nevermind, ich fand das ist ein Artefakt der HotModuleReplacement der webpack-middleware Zeug.
    • hast du diese arbeiten auf Azure? Es funktioniert auf meinem Rechner, aber auf Azure die Antwort nie abgeschlossen.
    • aber später habe ich verschoben, um websockets da die Wartezeit senden von Daten an den server über separate rest-api zu groß war.
    • Obigen code verwirrt durch nicht eindeutig hervorgeht, dass Beispiel .Net-code wird entweder von Middleware oder controller. Beide sind nicht notwendig, da die Middleware Vorrang.

    InformationsquelleAutor Shaun Luttin
  2. 1

    Server gesendeten Ereignisse können vollständig implementiert werden in einer controller-action.

    Grundlage dafür ist die Antwort von Shaun Luttin, aber es ist eher ein real-world Beispiel, dass es halten wird, öffnen Sie die Verbindung auf unbestimmte Zeit, und es sendet Nachrichten an die EventSource in Reaktion auf Nachrichten, die erstellt wird.

    using Example.Models;
using Example.Repositories;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using Newtonsoft.Json.Serialization;
using System;
using System.Threading;
using System.Threading.Tasks;

namespace Example.Controllers
{
    [Route("api/[controller]")]
    [ApiController]
    public class SseMessagesController : ControllerBase
    {
        private readonly IMessageRepository messageRepository;
        private readonly JsonSerializerSettings jsonSettings;

        public SseMessagesController(IMessageRepository messageRepository)
        {
            this.messageRepository = messageRepository;
            this.jsonSettings = new JsonSerializerSettings();
            jsonSettings.ContractResolver = new CamelCasePropertyNamesContractResolver();
        }

        [HttpGet]
        public async Task GetMessages(CancellationToken cancellationToken)
        {
            Response.StatusCode = 200;
            Response.Headers.Add("Content-Type", "text/event-stream");

            EventHandler<MessageCreatedArgs> onMessageCreated = async (sender, eventArgs) =>
            {
                try
                {
                    var message = eventArgs.Message;
                    var messageJson = JsonConvert.SerializeObject(message, jsonSettings);
                    await Response.WriteAsync($"data:{messageJson}\n\n");
                    await Response.Body.FlushAsync();
                }
                catch (Exception)
                {
                    //TODO: log error
                }
            };
            messageRepository.MessageCreated += onMessageCreated;

            while (!cancellationToken.IsCancellationRequested) {
                await Task.Delay(1000);
            }

            messageRepository.MessageCreated -= onMessageCreated;
        }
    }
}

    Wenn die EventSource verbindet /api/ssemessages wir ein Ereignis hinzufügen Delegierter des MessageCreated Fall auf den message-repository. Dann schauen wir alle 1 Sekunde um zu sehen, ob die EventSource wurde geschlossen, die bewirken, dass der Antrag storniert werden. Wenn der request abgebrochen wird, entfernen wir die Veranstaltung zu delegieren.

    Den Fall delegieren, bekommt die Message - Objekt aus den ereignisargumenten, serialisiert es zu JSON (mit camel-case zu sein, im Einklang mit ASP.NET Core default-Verhalten, wenn Sie ein Objekt zurückgeben Ergebnis), schreibt die JSON an den Körper und spült den Körper stream, schieben die Daten um die EventSource.

    Weitere bei der Erstellung des event-delegate, siehe dieser Artikel und dieses update für .NET Core.

    Auch, wenn Sie host das hinter Nginx, werden Sie wollen, Lesen Sie diese SO beantworten und diese ServerFault Antwort.

    • Hey delial, vielen Dank für die Antwort! Nicht sicher, ob Sie wussten, aber diese Frage ist mehr als 3 Jahre alt - wenn Sie möchten, um Ihre Bemühungen konzentrieren sich auf neue Fragen, können Sie das "Neueste" - Reiter zu erreichen. Zum Beispiel, dieser ist der link zu der neuesten C# Fragen.
    • Hast du einen GitHub-repo oder gist mit einem kompletten Beispiel einer IMessageRepository Umsetzung?
    InformationsquelleAutor delial
Schreibe einen Kommentar