Ubuntu Java如何使用WebSocket

在Ubuntu上跑WebSocket，听起来挺硬核，但其实就几步代码的事儿。不管你是搭个实时聊天，还是推送数据，这套路都通用。接下来咱们把流程拆开聊，从环境准备到服务端、客户端，一条线走通。

1. 安装Ja va开发环境

先别急着写代码，你得确认系统里有没有Ja va。Ubuntu上装JDK挺简单，一行命令搞定：

sudo apt update
sudo apt install openjdk-11-jdk

别偷懒用JRE，JDK才有编译器，后面编译注解类全得靠它。装完可以跑 ja va -version 验证一下。

2. 添加WebSocket依赖

Ja va本身不内置WebSocket，得把API库引进来。官方标准叫JSR 356，推荐用 ja vax.websocket 包。如果你用Ma ven，在 pom.xml 里加上：

    ja vax.websocket
    ja vax.websocket-api
    1.1

Gradle的话，build.gradle 里写成：

implementation 'ja vax.websocket:ja vax.websocket-api:1.1'

注意这只是API，运行时还得有个具体实现，比如Tomcat或GlassFish自带的WebSocket容器。开发阶段只依赖API就够了，后续部署时容器会提供实现。

3. 创建WebSocket服务器端点

服务端核心就是写一个类，用 @ServerEndpoint 注解指明访问路径。比如我们定义一个 /websocket 端点：

import ja vax.websocket.*;
import ja vax.websocket.server.ServerEndpoint;

@ServerEndpoint("/websocket")
public class MyWebSocketServer {

    @OnOpen
    public void onOpen(Session session) {
        System.out.println("Connected ... " + session.getId());
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("Received ...." + message);
    }

    @OnClose
    public void onClose(Session session) {
        System.out.println("Session " + session.getId() + " has ended");
    }

    @OnError
    public void onError(Session session, Throwable throwable) {
        System.out.println("Error on session " + session.getId());
    }
}

四个注解分别对应连接打开、收到消息、连接关闭和异常。这里只是打印日志，实际项目中你可以在这里处理业务逻辑，比如转发消息给其他客户端。

4. 创建WebSocket客户端

客户端同样用注解，但路径得指向服务端的地址。注意客户端类前面是 @ClientEndpoint，然后通过 WebSocketContainer 发起连接：

import ja vax.websocket.*;
import ja va.net.URI;

@ClientEndpoint
public class MyWebSocketClient {

    public static void main(String[] args) {
        try {
            WebSocketContainer container = ContainerProvider.getWebSocketContainer();
            URI uri = new URI("ws://localhost:8080/websocket");
            container.connectToServer(MyWebSocketClient.class, uri);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    @OnOpen
    public void onOpen(Session session) {
        System.out.println("Connected to server");
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("Received message: " + message);
    }

    @OnClose
    public void onClose(Session session) {
        System.out.println("Session ended");
    }

    @OnError
    public void onError(Session session, Throwable throwable) {
        System.out.println("Error on session");
    }
}

客户端启动后，会主动连到 ws://localhost:8080/websocket。如果服务端没开，会抛异常；正常连上之后就能双向通信了。

5. 运行服务器和客户端

先把服务端类跑起来——它需要一个WebSocket容器环境，最简单的办法是用Tomcat或一个支持注解的Ja va EE服务器。如果你只想验证效果，也可以用 ja vax.websocket 自带的嵌入式容器（比如GlassFish的Grizzly）。启动服务端后，再运行客户端main方法，控制台就能看到连接建立和消息传递的日志。

当然，示例只是最基础的骨架。实际项目里你需要处理消息格式（比如JSON）、心跳检测、重连机制等。但掌握了这几个步骤，WebSocket在Ja va里的入口就算摸透了。