溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
springboot服務端怎么推送SSE，針對這個問題，這篇文章詳細介紹了相對應的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。
package com.demo.action;
import com.demo.serviceI.DemoService;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.jackson.JsonObjectDeserializer;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;
@RestController
public class DemoAction {
@Autowired
private DemoService demoService;
/**
* 健康檢查json串模擬
* @return
*/
@RequestMapping(value = "health.json")
public String healt(){
return "{\"status\":\"UP\",\"diskSpace\":{\"status\":\"UP\",\"total\":249769230336,\"free\":71914618880,\"threshold\":10485760},\"db\":{\"status\":\"UP\",\"database\":\"MySQL\",\"hello\":1}}";
}
/**
* 條件注解使用
* @return
*/
@RequestMapping(value = "user/info")
public String info(){
return demoService.info();
}
/**
* 異步調用方法
*/
@RequestMapping(value = "print")
public void print(){
for (int i = 0; i < 100; i++) {
demoService.print(i);
}
}
/**
* 服務端推送技術
*/
@RequestMapping(value = "serverPush",produces = {MediaType.TEXT_EVENT_STREAM_VALUE})
public String serverPush(){
Map<String,String> demo = new HashMap<>(1);
demo.put("name","張三"+new Random().nextInt());
ObjectMapper objectMapper = new ObjectMapper();
String s = "data:";
try {
s += objectMapper.writeValueAsString(demo)+"\n\n";
System.out.println(s);
} catch (JsonProcessingException e) {
e.printStackTrace();
}
return s;
}
}頁面代碼
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Title</title>
<script type="application/javascript">
if (!!window.EventSource) {
var event = new EventSource("/serverPush");
event.addEventListener('message', function(t) {
var data = t.data;
document.write(data+"<br/>")
});
event.addEventListener("open",function (t) {
console.log("開啟");
},false);
event.addEventListener("error",function (t) {
if (t.readyState == EventSource.CLOSED) {
console.log("關閉");
}
},false);
}else{
console.error("瀏覽器不支持");
}
</script>
</head>
<body>
</body>
</html>注意使用過程中容易遇到的問題：
1.由于返回類型使用了text/event-stream，所以在服務端響應數據必須使用String或其他文本類型
2. 在返回數據時，必須用data:和\n\n分別開頭和結尾；如：String.format("data:%s\n\n",data)，這里將我坑慘，網上和書上資料只是給了個例子沒有具體說明，找了半天沒找到原因和前端鏈接成功就是觸發不了message事件
關于springboot服務端怎么推送SSE問題的解答就分享到這里了，希望以上內容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關注億速云行業資訊頻道了解更多相關知識。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
