【WebSocket】WebSocket经典实例

最新推荐文章于 2020-12-13 10:37:50 发布

杜鲁门

最新推荐文章于 2020-12-13 10:37:50 发布

阅读量6.2k

点赞数 1

分类专栏： WebSocket 文章标签： websocket 实例结构

本文链接：https://blog.csdn.net/bug_moving/article/details/52958169

版权

本文通过一个WebSocketTest2的实例展示了WebSocket的使用，包括jquery库的引用、后端Java处理和前端JSP页面。实现实现了多个客户端可以同时保持长连接，并能在后台看到连接数的增减情况。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

接着上一篇的环境，我们接下来弄了个WebSocketTest2

目录结构
这里写图片描述

jquery-1.12.3.js（贴心服务）

WebSocketTest2.java

package com.hust.websockettest;

import java.io.IOException;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.ConcurrentLinkedQueue;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint("/websocket2")
public class WebSocketTest2 {
   
    /**
     * 存储当前有效的session对象
     */
    private static Queue<Session> sessionSet = new ConcurrentLinkedQueue<Session>();

    @OnMessage
    public void onMessage(String message, Session currentSession) {
        System.out.println("Server say：Received: " + message);
        try {
            final Set<Session> sessions = currentSession.getOpenSessions();
            // 客户端互相发送消息
            for (Session session : sessions) {
                session.getBasicRemote().sendText(message);
            }
            /************ 启动定时公告 **************/
            //SystemTimer.getInstance();
            /**************************/
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @OnOpen
    public void onOpen(Session currentSession) {
        if (sessionSet.contains(currentSession) == false) {
            sessionSet.add(currentSession);
            System.out.println(

最低0.47元/天解锁文章