百度360必应搜狗淘宝本站头条
python判断字典是否为空crontab每周一执行aes和des区别安装指定版本npmadb pull
当前位置：网站首页 > IT知识 > 正文

Java WebSocket 示例（java nio websocket）

liuian 2025-07-17 20:39 3 浏览

一、环境准备

1. 依赖配置（Maven）

在 pom.xml 中添加 WebSocket 依赖： xml


<!-- Spring Boot WebSocket -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<!-- 原生 WebSocket API（备用） -->
<dependency>
    <groupId>javax.websocket</groupId>
    <artifactId>javax.websocket-api</artifactId>
    <version>1.1</version>
</dependency>



二、服务端实现（Spring Boot）

1. WebSocket 配置类


import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;

@Configuration
public class WebSocketConfig {
    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter(); // 自动注册 @ServerEndpoint
    }
}


2. WebSocket 服务端类


import org.springframework.stereotype.Component;
import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;

@Component
@ServerEndpoint("/chat/{username}")
public class ChatWebSocketServer {
    // 存储所有会话
    private static final ConcurrentHashMap<String, Session> sessions = new ConcurrentHashMap<>();
    private static final AtomicInteger onlineCount = new AtomicInteger(0);

    @OnOpen
    public void onOpen(Session session, @PathParam("username") String username) {
        sessions.put(username, session);
        onlineCount.incrementAndGet();
        System.out.println("用户 " + username + " 上线，当前在线人数：" + onlineCount);
    }

    @OnMessage
    public void onMessage(String message, Session session, @PathParam("username") String username) {
        System.out.println("收到消息：" + message);
        // 广播消息给所有用户
        broadcast(username + ": " + message);
    }

    @OnClose
    public void onClose(Session session, @PathParam("username") String username) {
        sessions.remove(username);
        onlineCount.decrementAndGet();
        System.out.println("用户 " + username + " 下线，当前在线人数：" + onlineCount);
    }

    @OnError
    public void onError(Session session, Throwable error) {
        error.printStackTrace();
    }

    // 广播消息
    private void broadcast(String message) {
        sessions.values().forEach(session -> {
            try {
                session.getAsyncRemote().sendText(message);
            } catch (IOException e) {
                e.printStackTrace();
            }
        });
    }
}



三、客户端实现

1. 浏览器端（HTML + JavaScript）


<!DOCTYPE html>
<html>
<head>
    <title>WebSocket 测试客户端</title>
</head>
<body>
    <input type="text" id="username" placeholder="用户名">
    <input type="text" id="message" placeholder="消息内容">
    <button onclick="sendMessage()">发送</button>
    <div id="output"></div>

    <script>
        const ws = new WebSocket("ws://localhost:8080/chat/用户昵称");
        ws.onmessage = function(event) {
            document.getElementById("output").innerHTML += event.data + "<br>";
        };

        function sendMessage() {
            const msg = document.getElementById("message").value;
            ws.send(msg);
        }
    </script>
</body>
</html>


2. Java 客户端（控制台交互）


import javax.websocket.*;
import java.net.URI;
import java.util.Scanner;

@ClientEndpoint
public class WebSocketClient {
    private Session session;

    public WebSocketClient(URI uri) {
        try {
            WebSocketContainer container = ContainerProvider.getWebSocketContainer();
            container.connectToServer(this, uri);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        System.out.println("已连接到服务器");
    }

    @OnMessage
    public void onMessage(String message) {
        System.out.println("收到消息：" + message);
    }

    public void sendMessage(String message) {
        try {
            session.getBasicRemote().sendText(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        WebSocketClient client = new WebSocketClient(URI.create("ws://localhost:8080/chat/TestUser"));
        Scanner scanner = new Scanner(System.in);
        while (true) {
            String msg = scanner.nextLine();
            client.sendMessage(msg);
        }
    }
}



四、运行与测试

1. 启动服务端

运行 Spring Boot 应用，访问 http://localhost:8080。

2. 浏览器客户端

3. 在浏览器中打开 HTML 文件，输入用户名和消息即可发送。 Java 控制台客户端

运行 WebSocketClient 类，输入消息发送到服务端。


五、关键功能说明

1. 路径参数传递

通过 @PathParam("username") 获取 URL 中的参数（如用户昵称）

2. 消息广播

使用 ConcurrentHashMap 存储所有会话，遍历发送消息

3. 异步发送

session.getAsyncRemote().sendText() 避免阻塞主线程


六、注意事项

1. 依赖冲突

确保 javax.websocket-api 与 Spring Boot 版本兼容。

2. 线程安全

使用 ConcurrentHashMap 保证多线程环境下会话操作的原子性

3. 异常处理

在 @OnError 中捕获连接异常，避免服务端崩溃

4. 路径配置

若需携带参数（如认证 Token），需在服务端解析 session.getRequestParameterMap()

相关推荐

Springboot 整合 Websocket 轻松实现IM及时通讯

一、方案实践集成分为三步：添加依赖、增加配置类和消息核心类、前端集成。1.1、添加依赖<dependency><groupId>org.springframework...

SpringBoot扩展——应用Web Socket!

应用WebSocket目前，网络上的即时通信App有很多，如QQ、微信和飞书等，按照以往的技术来说，即时功能通常会采用服务器轮询和Comet技术来解决。HTTP是非持久化、单向的网络协议，在建立连接...

【Spring Boot】WebSocket 的 6 种集成方式

介绍由于前段时间我实现了一个库【SpringCloud】一个配置注解实现WebSocket集群方案以至于我对WebSocket的各种集成方式做了一些研究目前我所了解到的就是下面这些了（就一个破w...

SpringBoot生产级WebSocket集群实践，支持10万连接!

1、问题背景智慧门诊系统旨在从一定程度上解决患者面临的三长一短（挂号、看病、取药时间长，医生问诊时间短）的问题。实现“诊前、诊中、诊后”实时智能一体化，整合完善医院工作流程。围绕门诊看病的各个环节，让...

Spring Boot3 中 WebSocket 实现数据实时通信全解析

各位互联网大厂的开发同仁们，在如今的互联网应用开发中，实时通信功能越来越重要。比如在线聊天、数据推送、实时通知等场景，都离不开高效的实时通信技术。而WebSocket作为一种高效的双向通信协议，在...

Java WebSocket 示例（java nio websocket）

一、环境准备1.依赖配置（Maven）在pom.xml中添加WebSocket依赖：xml<!--SpringBootWebSocket--><dependen...

Spring Boot整合WebSocket:开启实时通信之旅

SpringBoot整合WebSocket：开启实时通信之旅今天咱们来聊聊SpringBoot整合WebSocket这件大事儿。说到实时通信，你是不是第一时间想到QQ、微信这些聊天工具？没错，We...

Spring Boot3 竟能如此轻松整合 WebSocket 技术，你还不知道?

在当今互联网大厂的软件开发领域，实时通信的需求愈发迫切。无论是在线聊天应用、实时数据更新，还是协同办公系统，都离不开高效的实时通信技术支持。而WebSocket作为一种能够实现浏览器与服务器之间持...

Spring Boot集成WebSocket（springboot集成websocket）

一、基础配置依赖引入<dependency><groupId>org.springframework.boot</groupId><artifactId>...

Springboot下的WebSocket开发（springboot websocket server）

今天遇到一个需求，需要对接第三方扫码跳转。一种方案是前端页面轮询后端服务，但是这种空轮询会虚耗资源，实时性比较差而且也不优雅。所以决定使用另一种方案，websocket。以前就知道websocket，...

springboot websocket开发（java spring boot websocket）

maven依赖SpringBoot2.0对WebSocket的支持简直太棒了，直接就有包可以引入<dependency><groupId>org....

Python界面(GUI)编程PyQt5窗体小部件

一、简介在Qt（和大多数用户界面）中，“小部件”是用户可以与之交互的UI组件的名称。用户界面由布置在窗口内的多个小部件组成。Qt带有大量可用的小部件，也允许您创建自己的自定义和自定义小部件。二、小部件...

实战PyQt5: 014-下拉列表框控件QComboBox

QComboBox简介QComboBox下拉列表框，是一个集按钮和下拉列表选项于一体的部件。QComboBox提供了一种向用户呈现选项列表的方式，其占用最小量的屏幕空间。QComboBox中的常用方法...

Python小白逆袭!7天吃透PyQt6，独立开发超酷桌面应用

PythonGUI编程：PyQt6从入门到实战的全面指南在Python的庞大生态系统中，PyQt6作为一款强大的GUI（GraphicalUserInterface，图形用户界面）编程框架，为开...

如何用 PyQt6 打造一个功能完善的 SQLite 数据库管理工具

如何使用PyQt6和qt_material库，打造一个功能完善的SQLite数据库管理工具，轻松管理和查询SQLite数据库。一、目标数据库连接与表管理：支持连接SQLite数据库...

一周热门
最近发表
标签列表