test SseEmitter

Author: netbuffer

README.md

@@ -1,23 +1,28 @@
 # spring-boot-demo
+
 ![](https://img.shields.io/static/v1?label=java&message=1.8&color=blue)
 ![](https://img.shields.io/static/v1?label=spring-boot&message=2.4.5.RELEASE&color=blue)
 ![](https://img.shields.io/static/v1?label=spring-restdocs&message=2.0.4.RELEASE&color=blue)
 ![](https://img.shields.io/static/v1?label=junit&message=4.13.2&color=black)
 ![](https://img.shields.io/static/v1?label=hibernate-validator&message=6.1.7.Final&color=blue)
+
 * use spring-boot 2.x
 * https://shields.io/
 * [github source](https://github.com/netbuffer/spring-boot-demo)
 * [gitee source](https://gitee.com/netbuffer/spring-boot-demo)
 * /actuator/health
+* [spring-boot-2.4.5-reference](https://docs.spring.io/spring-boot/docs/2.4.5/reference/htmlsingle/)
 * [@ControllerAdvice](https://docs.spring.io/spring-framework/docs/5.3.6/reference/html/web.html#mvc-ann-controller-advice)
 * [Exceptions Process](https://docs.spring.io/spring-framework/docs/5.3.6/reference/html/web.html#mvc-ann-exceptionhandler)
 * [ResponseEntityExceptionHandler](https://docs.spring.io/spring-framework/docs/5.3.6/javadoc-api/org/springframework/web/servlet/mvc/method/annotation/ResponseEntityExceptionHandler.html)
 * [requestmapping](https://docs.spring.io/spring-framework/docs/5.3.6/reference/html/web.html#mvc-ann-requestmapping-registration)
+* [mvc-sse](https://docs.spring.io/spring-framework/docs/5.3.6/reference/html/web.html#mvc-ann-async-sse)
 * [hibernate_validator_reference](https://docs.jboss.org/hibernate/validator/6.2/reference/en-US/pdf/hibernate_validator_reference.pdf#validator-gettingstarted)
 * https://docs.docker.com/compose/compose-file/compose-file-v3/#build
 * https://hub.docker.com/_/openjdk
 
 ### server.servlet.session.timeout
+
 ```html
 ns for nanoseconds
 us for microseconds
@@ -29,14 +34,17 @@ d for days
 ```
 
 ### mvn build test
-> `mvn -Dmvn-arg=your param -DskipTests clean package -P test`  
--Dparam,-Pyour profile
+
+> `mvn -Dmvn-arg=your param -DskipTests clean package -P test`
+> -Dparam,-Pyour profile
 
 ### maven-help-plugin use
+
 * `mvn help:system` Displays a list of the platform details like system properties and environment variables
 * `mvn help:help` Display help information on maven-help-plugin.Call mvn help:help -Ddetail=true -Dgoal=<goal-name> to display parameter details
 
 ### branch
+
 * javamelody
 * spring-restdocs
 * templating-maven-plugin
@@ -46,27 +54,33 @@ d for days
 ### docker镜像制作
 
 #### 构建
+
 1. 先通过maven打包到target目录下
-2. 执行构建指令：`cd target;docker build -f ../Dockerfile -t netbuffer/spring-boot-demo:1.0 ../` (`docker build -t netbuffer/spring-boot-demo:1.0 .`) 
+2. 执行构建指令：`cd target;docker build -f ../Dockerfile -t netbuffer/spring-boot-demo:1.0 ../` (`docker build -t netbuffer/spring-boot-demo:1.0 .`)
 
 #### 运行
+
 * docker run --rm -it -p 9100:9100 netbuffer/spring-boot-demo:1.0
 * docker-compose up (使用docker-compose启动服务)
 
 #### 发布到DockerHub
+
 > 需要注册DockerHub身份，再docker login登录对应的Registry
+
 1. docker images 找到镜像ID
 2. docker tag 镜像ID 你的DockerHub账户名/spring-boot-demo:1.0 打tag
 3. docker push 你的DockerHub账户名/spring-boot-demo:1.0 推送到远程
 
 #### 远程镜像
-> 已发布到DockerHub，可以直接运行以下指令测试  
-https://hub.docker.com/r/javawiki/spring-boot-demo  
+
+> 已发布到DockerHub，可以直接运行以下指令测试
+> https://hub.docker.com/r/javawiki/spring-boot-demo
 
 * docker pull javawiki/spring-boot-demo:1.0          拉取远程镜像
 * docker run -it --rm javawiki/spring-boot-demo:1.0  运行远程镜像
 
 ### articles
+
 * [spring-boot中统一修改http响应体内容的方法](https://www.toutiao.com/i7014375995448820231)
 * [spring-boot中异常的处理](https://www.toutiao.com/i7014369292791579148)
 * [关于spring-boot中logback日志配置引用spring环境变量的使用方式](https://www.toutiao.com/i7014368145578230304)
@@ -76,4 +90,4 @@ https://hub.docker.com/r/javawiki/spring-boot-demo
 * [获取SpringBoot工程运行时的操作系统进程ID方法](https://www.toutiao.com/i7015456367477522977)
 * [SpringBoot使用基于json格式的配置方法](https://www.toutiao.com/i7016209186543469069)
 * [怎么查看SpringBoot工程中每个过滤器的执行顺序](https://www.toutiao.com/i7016666337527382532)
-* [Spring中出现NoUniqueBeanDefinitionException的解决方法](https://www.toutiao.com/i7018897444583113247)
+* [Spring中出现NoUniqueBeanDefinitionException的解决方法](https://www.toutiao.com/i7018897444583113247)

help/http-requests.http

@@ -17,4 +17,7 @@ GET http://localhost:9100/async/dotask?sleep=3
 GET http://localhost:9100/retry/test
 
 ### /param/defaultValue
-GET http://localhost:9100/param/defaultValue
+GET http://localhost:9100/param/defaultValue
+
+### /sse/sendById
+GET http://localhost:9100/sse/sendById?id=uitest&message=hello

src/main/java/cn/netbuffer/springboot/demo/controller/SSEController.java

@@ -0,0 +1,37 @@
+package cn.netbuffer.springboot.demo.controller;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
+@Slf4j
+@RestController
+@RequestMapping("/sse")
+public class SSEController {
+
+    private Map<String, SseEmitter> sseEmitterMap = new HashMap<>();
+
+    //https://www.w3.org/TR/eventsource/
+    @GetMapping(path = "/events", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    @CrossOrigin
+    public SseEmitter handle(String id) {
+        log.debug("new SseEmitter for id={}", id);
+        SseEmitter sseEmitter = new SseEmitter(30 * 1000L);
+        sseEmitterMap.put(id, sseEmitter);
+        return sseEmitter;
+    }
+
+    @GetMapping("sendById")
+    public void sendById(String id, String message) throws IOException {
+        log.debug("send message with SseEmitter id={}", id);
+        sseEmitterMap.get(id).send(message);
+    }
+
+}