类class io.agentscope.core.model.transport.websocket 2.x

JdkWebSocketTransport

public class JdkWebSocketTransport implements WebSocketTransport

源码Source io/agentscope/core/model/transport/websocket/JdkWebSocketTransport.java:73–277

Jdk WebSocket 传输层，与模型服务通信并返回生成或向量化结果。位于 io.agentscope.core.model.transport.websocket 包，实现 WebSocketTransport。核心成员包括 create、connect、shutdown。

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));
`

方法摘要Method Summary

方法Method	说明Description
`public static` `JdkWebSocketTransport create()` static	创建客户端使用默认配置。 Create a client with default configuration.
`public static` `JdkWebSocketTransport create(HttpClient httpClient)` static	创建客户端使用自定义 HttpClient。 Create a client with custom HttpClient.
`public static` `JdkWebSocketTransport create(WebSocketTransportConfig config)` static	创建客户端使用自定义配置。 Create a client with custom configuration.
`public T Mono<WebSocketConnection<T>> connect(WebSocketRequest request, Class<T> messageType)`	建立连接并完成初始化。 Performs the connect operation.
`public void shutdown()`	关闭资源并释放连接。 Releases resources and connections.

方法详情Method Detail

create

public static JdkWebSocketTransport create()

static

创建客户端使用默认配置。

Create a client with default configuration.

返回Returns JdkWebSocketTransport

返回JdkWebSocketTransport。JdkWebSocketTransport instance

源码Source io/agentscope/core/model/transport/websocket/JdkWebSocketTransport.java:88–91

create

public static JdkWebSocketTransport create(HttpClient httpClient)

static

创建客户端使用自定义 HttpClient。

Create a client with custom HttpClient.

参数Parameters

名称Name	类型Type	说明Description
`httpClient`	HttpClient	HTTP 客户端（类型 `HttpClient`）。Custom HttpClient instance

返回Returns JdkWebSocketTransport

返回JdkWebSocketTransport。JdkWebSocketTransport instance

源码Source io/agentscope/core/model/transport/websocket/JdkWebSocketTransport.java:99–101

create

public static JdkWebSocketTransport create(WebSocketTransportConfig config)

static

创建客户端使用自定义配置。

Create a client with custom configuration.

参数Parameters

名称Name	类型Type	说明Description
`config`	WebSocketTransportConfig	WebSocket 客户端配置。the WebSocket client configuration

返回Returns JdkWebSocketTransport

返回JdkWebSocketTransport。JdkWebSocketTransport instance

源码Source io/agentscope/core/model/transport/websocket/JdkWebSocketTransport.java:111–113

connect

public T Mono<WebSocketConnection<T>> connect(WebSocketRequest request, Class<T> messageType)

建立连接并完成初始化。

Performs the connect operation.

参数Parameters

名称Name	类型Type	说明Description
`request`	WebSocketRequest	请求（类型 `WebSocketRequest`）。The request.
`messageType`	Class<T>	消息类型（类型 `Class`）。The message type.

返回Returns Mono<WebSocketConnection<T>>

返回Mono>。Returns mono.

源码Source io/agentscope/core/model/transport/websocket/JdkWebSocketTransport.java:195–240

shutdown

public void shutdown()

关闭资源并释放连接。

Releases resources and connections.

源码Source io/agentscope/core/model/transport/websocket/JdkWebSocketTransport.java:242–247