setInterval(() => {
  // 方法請求
  messageCount().then((res) => {
      if (res.code === 200) {
          this.messageCount = res.data
      }
  })
}, 1000);

@Controller
@RequestMapping("/polling")
public class PollingController {
    // 存放監(jiān)聽某個Id的長輪詢集合
    // 線程同步結構
    public static Multimap<String, DeferredResult<String>> watchRequests = Multimaps.synchronizedMultimap(HashMultimap.create());
    /**
     * 公眾號：程序員小富
     * 設置監(jiān)聽
     */
    @GetMapping(path = "watch/{id}")
    @ResponseBody
    public DeferredResult<String> watch(@PathVariable String id) {
        // 延遲對象設置超時時間
        DeferredResult<String> deferredResult = new DeferredResult<>(TIME_OUT);
        // 異步請求完成時移除 key，防止內存溢出
        deferredResult.onCompletion(() -> {
            watchRequests.remove(id, deferredResult);
        });
        // 注冊長輪詢請求
        watchRequests.put(id, deferredResult);
        return deferredResult;
    }
    /**
     * 公眾號：程序員小富
     * 變更數(shù)據(jù)
     */
    @GetMapping(path = "publish/{id}")
    @ResponseBody
    public String publish(@PathVariable String id) {
        // 數(shù)據(jù)變更 取出監(jiān)聽ID的所有長輪詢請求，并一一響應處理
        if (watchRequests.containsKey(id)) {
            Collection<DeferredResult<String>> deferredResults = watchRequests.get(id);
            for (DeferredResult<String> deferredResult : deferredResults) {
                deferredResult.setResult("我更新了" + new Date());
            }
        }
        return "success";
    }

@ControllerAdvice
public class AsyncRequestTimeoutHandler {
    @ResponseStatus(HttpStatus.NOT_MODIFIED)
    @ResponseBody
    @ExceptionHandler(AsyncRequestTimeoutException.class)
    public String asyncRequestTimeoutHandler(AsyncRequestTimeoutException e) {
        System.out.println("異步請求超時");
        return "304";
    }
}

<iframe src="/iframe/message" style="display:none"></iframe>

@Controller
@RequestMapping("/iframe")
public class IframeController {
    @GetMapping(path = "message")
    public void message(HttpServletResponse response) throws IOException, InterruptedException {
        while (true) {
            response.setHeader("Pragma", "no-cache");
            response.setDateHeader("Expires", 0);
            response.setHeader("Cache-Control", "no-cache,no-store");
            response.setStatus(HttpServletResponse.SC_OK);
            response.getWriter().print(" <script type=\"text/javascript\">\n" +
                    "parent.document.getElementById('clock').innerHTML = \"" + count.get() + "\";" +
                    "parent.document.getElementById('count').innerHTML = \"" + count.get() + "\";" +
                    "</script>");
        }
    }
}

<script>
    let source = null;
    let userId = 7777
    if (window.EventSource) {
        // 建立連接
        source = new EventSource('http://localhost:7777/sse/sub/'+userId);
        setMessageInnerHTML("連接用戶=" + userId);
        /**
         * 連接一旦建立，就會觸發(fā)open事件
         * 另一種寫法：source.onopen = function (event) {}
         */
        source.addEventListener('open', function (e) {
            setMessageInnerHTML("建立連接。。。");
        }, false);
        /**
         * 客戶端收到服務器發(fā)來的數(shù)據(jù)
         * 另一種寫法：source.onmessage = function (event) {}
         */
        source.addEventListener('message', function (e) {
            setMessageInnerHTML(e.data);
        });
    } else {
        setMessageInnerHTML("你的瀏覽器不支持SSE");
    }
</script>

private static Map<String, SseEmitter> sseEmitterMap = new ConcurrentHashMap<>();
/**
 * 創(chuàng)建連接
 *
 * @date: 2022/7/12 14:51
 * @auther: 公眾號：程序員小富
 */
public static SseEmitter connect(String userId) {
    try {
        // 設置超時時間，0表示不過期。默認30秒
        SseEmitter sseEmitter = new SseEmitter(0L);
        // 注冊回調
        sseEmitter.onCompletion(completionCallBack(userId));
        sseEmitter.onError(errorCallBack(userId));
        sseEmitter.onTimeout(timeoutCallBack(userId));
        sseEmitterMap.put(userId, sseEmitter);
        count.getAndIncrement();
        return sseEmitter;
    } catch (Exception e) {
        log.info("創(chuàng)建新的sse連接異常，當前用戶：{}", userId);
    }
    return null;
}
/**
 * 給指定用戶發(fā)送消息
 *
 * @date: 2022/7/12 14:51
 * @auther: 公眾號：程序員小富
 */
public static void sendMessage(String userId, String message) {
    if (sseEmitterMap.containsKey(userId)) {
        try {
            sseEmitterMap.get(userId).send(message);
        } catch (IOException e) {
            log.error("用戶[{}]推送異常:{}", userId, e.getMessage());
            removeUser(userId);
        }
    }
}

<!-- 引入websocket -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

@Component
@Slf4j
@ServerEndpoint("/websocket/{userId}")
public class WebSocketServer {
    //與某個客戶端的連接會話，需要通過它來給客戶端發(fā)送數(shù)據(jù)
    private Session session;
    private static final CopyOnWriteArraySet<WebSocketServer> webSockets = new CopyOnWriteArraySet<>();
    // 用來存在線連接數(shù)
    private static final Map<String, Session> sessionPool = new HashMap<String, Session>();
    /**
     * 公眾號：程序員小富
     * 鏈接成功調用的方法
     */
    @OnOpen
    public void onOpen(Session session, @PathParam(value = "userId") String userId) {
        try {
            this.session = session;
            webSockets.add(this);
            sessionPool.put(userId, session);
            log.info("websocket消息: 有新的連接，總數(shù)為:" + webSockets.size());
        } catch (Exception e) {
        }
    }
    /**
     * 公眾號：程序員小富
     * 收到客戶端消息后調用的方法
     */
    @OnMessage
    public void onMessage(String message) {
        log.info("websocket消息: 收到客戶端消息:" + message);
    }
    /**
     * 公眾號：程序員小富
     * 此為單點消息
     */
    public void sendOneMessage(String userId, String message) {
        Session session = sessionPool.get(userId);
        if (session != null && session.isOpen()) {
            try {
                log.info("websocket消: 單點消息:" + message);
                session.getAsyncRemote().sendText(message);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

<script>
    var ws = new WebSocket('ws://localhost:7777/webSocket/10086');
    // 獲取連接狀態(tài)
    console.log('ws連接狀態(tài)：' + ws.readyState);
    //監(jiān)聽是否連接成功
    ws.onopen = function () {
        console.log('ws連接狀態(tài)：' + ws.readyState);
        //連接成功則發(fā)送一個數(shù)據(jù)
        ws.send('test1');
    }
    // 接聽服務器發(fā)回的信息并處理展示
    ws.onmessage = function (data) {
        console.log('接收到來自服務器的消息：');
        console.log(data);
        //完成通信后關閉WebSocket連接
        ws.close();
    }
    // 監(jiān)聽連接關閉事件
    ws.onclose = function () {
        // 監(jiān)聽整個過程中websocket的狀態(tài)
        console.log('ws連接狀態(tài)：' + ws.readyState);
    }
    // 監(jiān)聽并處理error事件
    ws.onerror = function (error) {
        console.log(error);
    }
    function sendMessage() {
        var content = $("#message").val();
        $.ajax({
            url: '/socket/publish?userId=10086&message=' + content,
            type: 'GET',
            data: { "id": "7777", "content": content },
            success: function (data) {
                console.log(data)
            }
        })
    }
</script>