如何在java主方法中使用WebSocket框架

在Java主方法中使用WebSocket框架，首先需要选择一个WebSocket库

1. 添加依赖

以Maven为例，将以下依赖添加到pom.xml文件中：

<dependencies>
    <dependency>
        <groupId>org.java-websocket</groupId>
        <artifactId>Java-WebSocket</artifactId>
        <version>1.5.3</version>
    </dependency>
</dependencies>

2. 创建WebSocket服务器

创建一个名为MyWebSocketServer的类，继承org.java_websocket.server.WebSocketServer。重写onOpen、onClose和onMessage方法以处理连接打开、关闭和接收消息的事件。

import org.java_websocket.handshake.ClientHandshake;
import org.java_websocket.server.WebSocketServer;
import org.java_websocket.WebSocket;

import java.net.InetSocketAddress;

public class MyWebSocketServer extends WebSocketServer {

    public MyWebSocketServer(InetSocketAddress address) {
        super(address);
    }

    @Override
    public void onOpen(WebSocket conn, ClientHandshake handshake) {
        System.out.println("New connection from " + conn.getRemoteSocketAddress().getAddress().getHostAddress());
    }

    @Override
    public void onClose(WebSocket conn, int code, String reason, boolean remote) {
        System.out.println("Connection closed by " + (remote ? "remote peer" : "us") + " Code: " + code + " Reason: " + reason);
    }

    @Override
    public void onMessage(WebSocket conn, String message) {
        System.out.println("Received message from " + conn.getRemoteSocketAddress().getAddress().getHostAddress() + ": " + message);
        // Echo the message back to the client
        conn.send("You said: " + message);
    }

    @Override
    public void onError(WebSocket conn, Exception ex) {
        ex.printStackTrace();
    }

    @Override
    public void onStart() {
        System.out.println("Server started successfully");
    }

    public static void main(String[] args) {
        // Replace with your desired port
        int port = 8887;
        MyWebSocketServer server = new MyWebSocketServer(new InetSocketAddress(port));
        server.run();
    }
}

3. 运行WebSocket服务器

在main方法中，创建一个MyWebSocketServer实例并指定监听的端口号。然后调用run方法启动服务器。

public static void main(String[] args) {
    int port = 8887;
    MyWebSocketServer server = new MyWebSocketServer(new InetSocketAddress(port));
    server.run();
}

现在，当客户端连接到WebSocket服务器时，服务器将接收到消息并将其原样发送回客户端。你可以根据需要修改onMessage方法以执行其他操作。