Test EventSource

ithewei · ithewei · commit f51b4718501a · 2021-12-31T12:01:28.000+08:00
diff --git a/examples/httpd/handler.cpp b/examples/httpd/handler.cpp
@@ -287,13 +287,17 @@ int Handler::upload(const HttpContextPtr& ctx) {
 
 int Handler::sse(const HttpContextPtr& ctx) {
     ctx->writer->EndHeaders("Content-Type", "text/event-stream");
-    // send(time) every 1s
+    // send(message) every 1s
     hv::setInterval(1000, [ctx](hv::TimerID timerID) {
         char szTime[DATETIME_FMT_BUFLEN] = {0};
         datetime_t now = datetime_now();
         datetime_fmt(&now, szTime);
-        ctx->writer->write("event: timeout\n");
-        ctx->writer->write(hv::asprintf("data: %s\n\n", szTime));
+        // @test html/EventSource.html EventSource.onmessage
+        std::string msg("event: message\n");
+        msg += "data: ";
+        msg += szTime;
+        msg += "\n\n";
+        ctx->writer->write(msg);
     });
     return HTTP_STATUS_UNFINISHED;
 }
diff --git a/examples/httpd/router.cpp b/examples/httpd/router.cpp
@@ -135,5 +135,5 @@ void Router::Register(hv::HttpService& router) {
     router.POST("/upload", Handler::upload);
 
     // SSE: Server Send Events
-    router.GET("/SSE", Handler::sse);
+    router.GET("/sse", Handler::sse);
 }
diff --git a/html/EventSource.html b/html/EventSource.html
@@ -0,0 +1,50 @@
+<!DOCTYPE HTML>
+<html>
+
+<head>
+<meta charset="utf-8">
+<title>EventSource客户端</title>
+
+<script type="text/javascript">
+function EventSourceTest(url)
+{
+  if (typeof(EventSource) !== "undefined")
+  {
+    var es = new EventSource(url);
+
+    es.onopen = function()
+    {
+      alert("连接已建立");
+    };
+
+    es.onmessage = function(ev)
+    {
+      console.log("received event: " + ev.data);
+      var li=document.createElement("li");
+      li.innerHTML=ev.data;
+      document.getElementById("msg_list").appendChild(li);
+    };
+
+    es.onerror = function(e)
+    {
+      alert("连接断开");
+    };
+  }
+  else
+  {
+    alert("您的浏览器不支持 EventSource!");
+  }
+}
+</script>
+</head>
+
+<body>
+  URL: <input type="text" id="url" value="http://127.0.0.1:8080/sse" style="width:300px;">
+  <button onclick="EventSourceTest(document.getElementById('url').value)">运行 EventSource</button>
+  <div>
+    <ul id="msg_list" style="height:500px;overflow-y:scroll;">
+    </ul>
+  <div>
+</body>
+
+</html>
diff --git a/html/WebSocket.html b/html/WebSocket.html

Original file line number	Diff line number	Diff line change
`@@ -135,5 +135,5 @@ void Router::Register(hv::HttpService& router) {`
`135`	`135`	`router.POST("/upload", Handler::upload);`
`136`	`136`
`137`	`137`	`// SSE: Server Send Events`
`138`		`- router.GET("/SSE", Handler::sse);`
	`138`	`+ router.GET("/sse", Handler::sse);`
`139`	`139`	`}`