java 中的 websocket 客户端-ag捕鱼王app官网

本文介绍如何使用 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() 方法将从系统中的用户输入中读取消息。