程序包 io.agentscope.core.model.transport.websocket

类 JdkWebSocketTransport

java.lang.Object

io.agentscope.core.model.transport.websocket.JdkWebSocketTransport

所有已实现的接口:

WebSocketTransport

public class JdkWebSocketTransport
extends Object
implements WebSocketTransport

WebSocket client implementation based on JDK 11+ HttpClient.

Features:

• No additional dependencies, uses JDK built-in API
• Client instance is reusable
• Thread-safe

Usage example:

 WebSocketTransport client = JdkWebSocketTransport.create();

 WebSocketRequest request = WebSocketRequest.builder("wss://api.example.com/ws")
     .header("Authorization", "Bearer token")
     .build();

 client.connect(request, String.class)
     .flatMapMany(conn -> {
         conn.send("{\"type\":\"config\"}").subscribe();
         return conn.receive();
     })
     .subscribe(data -> handle(data));
 

方法概要

修饰符和类型	方法	说明
<T> reactor.core.publisher.Mono<WebSocketConnection<T>>	connect(WebSocketRequest request, Class<T> messageType)	Establish a WebSocket connection.
static JdkWebSocketTransport	create()	Create a client with default configuration.
static JdkWebSocketTransport	create(WebSocketTransportConfig config)	Create a client with custom configuration.
static JdkWebSocketTransport	create(HttpClient httpClient)	Create a client with custom HttpClient.
void	shutdown()	Shutdown the client and release resources.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

create

public static JdkWebSocketTransport create()

Create a client with default configuration.

返回:

JdkWebSocketTransport instance

create

public static JdkWebSocketTransport create(HttpClient httpClient)

Create a client with custom HttpClient.

参数:

httpClient - Custom HttpClient instance

返回:

JdkWebSocketTransport instance

create

public static JdkWebSocketTransport create(WebSocketTransportConfig config)

Create a client with custom configuration.

This method supports proxy configuration and other advanced settings.

参数:

config - the WebSocket client configuration

返回:

JdkWebSocketTransport instance

connect

public <T>
reactor.core.publisher.Mono<WebSocketConnection<T>> connect(WebSocketRequest request,
 Class<T> messageType)

从接口复制的说明: WebSocketTransport

Establish a WebSocket connection.

指定者:

connect 在接口中 WebSocketTransport

类型参数:

T - Message type: String for text protocol, byte[] for binary protocol

参数:

request - Connection request configuration

messageType - Class object for message type (String.class or byte[].class)

返回:

Mono that emits WebSocketConnection on successful connection

shutdown

public void shutdown()

从接口复制的说明: WebSocketTransport

Shutdown the client and release resources.

After shutdown, this client should not be used anymore.

指定者:

shutdown 在接口中 WebSocketTransport