迹忆客 专注技术分享

本文介绍如何使用 Java 创建 WebSocket 客户端。

Java 中的 WebSocket 客户端

WebSocket 可用于在客户端和服务器之间创建通信通道。 WebSocket 协议与用于 Web 通信的 HTTP 兼容。

WebSocket协议相对于HTTP有两点改进：一是开销比HTTP低，二是双向Web通信。

客户端和服务器端是WebSocket通信的一部分，客户端用于发送和接收数据，服务器端用于通信。

让我们尝试使用 WebSocket 创建一个客户端：

• 首先，我们的类需要注释为 ClientEndpoint。
• 然后，我们需要创建一个 ClientManager 并要求它连接到带注释的端点，即我们的客户端。 URI 将指定服务器。
• 当连接建立时，逻辑将与服务器类似。
• 当方法打开、收到消息或连接关闭方法时，将自动调用 onOpen()、onMessage() 或 onClose()。

以下是客户端使用上述几点的示例：

package jiyik;

import java.io.*;
import java.net.URI;
import javax.websocket.*;

@ClientEndpoint
public class Client_Endpoint {

    @OnOpen
    public void onOpen(Session Client_Session) {
        System.out.println ("--- Connection Successful " + Client_Session.getId());
        try {
            Client_Session.getBasicRemote().sendText("Start");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @OnMessage
    public String onMessage(String Client_Message, Session Client_Session) {
        BufferedReader Buffered_Reader = new BufferedReader(new InputStreamReader(System.in));
        try {
            System.out.println ("--- Message Received " + Client_Message);
            String User_Input = Buffered_Reader.readLine();
            return User_Input;
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    @OnClose
    public void onClose(Session Client_Session, CloseReason Close_Reason) {
        System.out.println("--- Session ID: " + Client_Session.getId());
        System.out.println("--- Closing Reason: " + Close_Reason);
    }

    public static void main(String[] args) {
        ClientManager Client_Manager = ClientManager.createClient();
        try {
            URI uri = new URI("ws://localhost:8080");
            Client_Manager.connectToServer(MyClientEndpoint.class, uri);
            while(true) {}
        } catch (DeploymentException | URISyntaxException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

该代码实现了基于聊天的系统的客户端。 当连接打开时，客户端将使用 Client_Session.getBasicRemote().sendText() 向服务器发送一条消息。

服务器将收到消息并使用相同的字符串进行应答。 这将使 onMessage() 方法在客户端中运行。

onMessage() 方法将从系统中的用户输入中读取消息。