4

我正在尝试处理服务器发送的事件，但我无法让它在 MVC 项目（不是 WebAPI）中工作。我在网上没有找到任何好的样品。

这是我尝试过的服务器端代码（包括来自不同帖子的几次失败尝试）：

Function GetRows() as ActionResult
    Dim ret = New HttpResponseMessage
    ' ret.Content.w
    ' Return ret

    Response.ContentType = "text/event-stream"
    Response.Write("data: " & "aaaa")
    Dim flag = False
    If flag Then
        For i = 0 To 100
            Response.Write("data: " & i)
        Next
    End If
    Response.Flush()
    'Return Content("Abv")
    'Return Content(("data: {0}\n\n" & DateTime.Now.ToString(), "text/event-stream")
End Function

这是Javascript

var source = new EventSource("/Tool/GetRows");
source.onmessage = function (event) {
    document.getElementById("messages").innerHTML += event.data + "<br>";
};
source.onerror = function (e) {
    console.log(e);
};

由于某种原因，它总是进入onerror，并且没有任何信息表明它可能是什么类型的错误。

我究竟做错了什么？

顺便说一句，我认为这个动作不应该真正返回任何东西，因为我的理解是它应该只逐个字符串写入流字符串。

4

1 回答 1

15

EventSource需要一个特定的 formatonerror ，如果流与该格式不匹配，则会引发- 一组由 a 分隔的字段/值对:行，每行以换行符结尾：

field: value
field: value

field可以是data, event, id,retry中的一个或空的评论（将被 EventSource 忽略）。

data可以跨越多行，但每行必须以data:

每个事件触发器必须以双换行符结尾

data: 1
data: second line of message

data: 2
data: second line of second message

注意：如果你是用 VB.NET 编写的，你不能使用\n转义序列来编写换行符；你必须使用vbLfor Chr(10)。

顺便说一句，EventSource 应该保持与服务器的开放连接。来自MDN（重点是我的）：

EventSource接口用于接收服务器发送的事件。它通过 HTTP 连接到服务器并以文本/事件流格式接收事件，而无需关闭连接。

一旦控制从 MVC 控制器方法中退出，结果将被打包并发送到客户端，并关闭连接。EventSource 的一部分是客户端将尝试重新打开连接，该连接将再次被服务器立即关闭；由此产生的close -> reopen循环也可以在这里看到。

该方法不应退出该方法，而应具有某种循环，该循环将连续写入Response流。

VB.NET 中的示例

Imports System.Threading
Public Class HomeController
    Inherits Controller

    Sub Message()
        Response.ContentType= "text/event-stream"
        Dim i As Integer
        Do
            i += 1
            Response.Write("data: DateTime = " & Now & vbLf)
            Response.Write("data: Iteration = " & i & vbLf)
            Response.Write(vbLf)
            Response.Flush

            'The timing of data sent to the client is determined by the Sleep interval (and latency)
            Thread.Sleep(1000) 
        Loop
    End Sub
End Class

C# 中的示例

客户端：

<input type="text" id="userid" placeholder="UserID" /><br />
<input type="button" id="ping" value="Ping" />

<script>
    var es = new EventSource('/home/message');
    es.onmessage = function (e) {
        console.log(e.data);
    };
    es.onerror = function () {
        console.log(arguments);
    };

    $(function () {
        $('#ping').on('click', function () {
            $.post('/home/ping', {
                UserID: $('#userid').val() || 0
            });
        });
    });
</script>

服务器端：

using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Web.Mvc;
using Newtonsoft.Json;

namespace EventSourceTest2.Controllers {
    public class PingData {
        public int UserID { get; set; }
        public DateTime Date { get; set; } = DateTime.Now;
    }

    public class HomeController : Controller {
        public ActionResult Index() {
            return View();
        }

        static ConcurrentQueue<PingData> pings = new ConcurrentQueue<PingData>();

        public void Ping(int userID) {
            pings.Enqueue(new PingData { UserID = userID });
        }

        public void Message() {
            Response.ContentType = "text/event-stream";
            do {
                PingData nextPing;
                if (pings.TryDequeue(out nextPing)) {
                    Response.Write("data:" + JsonConvert.SerializeObject(nextPing, Formatting.None) + "\n\n");
                }
                Response.Flush();
                Thread.Sleep(1000);
            } while (true);
        }
    }
}
于 2016-02-28T03:01:04.197 回答