如何在java主方法中使用WebSocket

在Java主方法中使用WebSocket，您需要遵循以下步骤：

1. 添加依赖项 首先，您需要在项目中添加WebSocket库的依赖项。如果您使用的是Maven，可以在pom.xml文件中添加以下依赖项：

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

如果您使用的是Gradle，可以在build.gradle文件中添加以下依赖项：

implementation 'org.java-websocket:Java-WebSocket:1.5.3'

2. 创建WebSocket服务器 接下来，您需要创建一个WebSocket服务器类。以下是一个简单的示例：

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;
import java.net.URISyntaxException;

public class MyWebSocketServer extends WebSocketClient {

    public MyWebSocketServer(URI serverUri) {
        super(serverUri);
    }

    @Override
    public void onOpen(ServerHandshake handshakedata) {
        System.out.println("Connected to server");
    }

    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }

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

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

    public static void main(String[] args) {
        try {
            MyWebSocketServer server = new MyWebSocketServer(new URI("ws://localhost:8080"));
            server.connect();
        } catch (URISyntaxException e) {
            e.printStackTrace();
        }
    }
}

在这个示例中，我们创建了一个名为MyWebSocketServer的类，它继承了WebSocketClient。我们重写了onOpen、onMessage、onClose和onError方法，以便在连接打开、接收到消息、连接关闭和发生错误时执行相应的操作。

在main方法中，我们创建了一个MyWebSocketServer实例，并尝试连接到WebSocket服务器。

3. 运行WebSocket服务器 现在，您可以运行WebSocket服务器。如果一切正常，您应该看到控制台输出“Connected to server”。

4. 创建WebSocket客户端 要创建一个WebSocket客户端，您可以使用相同的库。以下是一个简单的示例：

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;

import java.net.URI;
import java.net.URISyntaxException;

public class MyWebSocketClient extends WebSocketClient {

    public MyWebSocketClient(URI serverUri) {
        super(serverUri);
    }

    @Override
    public void onOpen(ServerHandshake handshakedata) {
        System.out.println("Connected to server");
        send("Hello, server!");
    }

    @Override
    public void onMessage(String message) {
        System.out.println("Received message: " + message);
    }

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

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

    public static void main(String[] args) {
        try {
            MyWebSocketClient client = new MyWebSocketClient(new URI("ws://localhost:8080"));
            client.connect();
        } catch (URISyntaxException e) {
            e.printStackTrace();
        }
    }
}

在这个示例中，我们创建了一个名为MyWebSocketClient的类，它继承了WebSocketClient。我们重写了onOpen、onMessage、onClose和onError方法，以便在连接打开、接收到消息、连接关闭和发生错误时执行相应的操作。

在main方法中，我们创建了一个MyWebSocketClient实例，并尝试连接到WebSocket服务器。当连接打开时，我们会发送一条消息给服务器。

5. 运行WebSocket客户端 现在，您可以运行WebSocket客户端。如果一切正常，您应该看到控制台输出“Connected to server”和“Received message: Hello, server!”。

这就是在Java主方法中使用WebSocket的基本方法。请注意，这只是一个简单的示例，实际应用可能需要更多的错误处理和功能。