JdkWebSocketConnection
public class JdkWebSocketConnection<T> implements WebSocketConnection<T>源码Source
io/agentscope/core/model/transport/websocket/JdkWebSocketConnection.java:38–280Jdk WebSocket 连接，与模型服务通信并返回生成或向量化结果。位于 io.agentscope.core.model.transport.websocket 包，实现 WebSocketConnection<T>。核心成员包括 send、receive、close、isOpen、getCloseInfo。
WebSocket connection implementation based on JDK WebSocket.
Supports both text (String) and binary (byte[]) message types through generic type parameter.
方法摘要Method Summary
| 方法Method | 说明Description |
|---|---|
public Mono<Void> send(T data) | 设置发送。 Performs the send operation. |
public Flux<T> receive() | 返回接收。 Returns the receive. |
public Mono<Void> close() | 关闭连接并释放相关资源。 Releases resources and connections. |
public boolean isOpen() | 判断是否打开。 Returns whether the open. |
public CloseInfo getCloseInfo() | 获取关闭信息。 Returns the close info. |
方法详情Method Detail
send
public Mono<Void> send(T data)设置发送。
Performs the send operation.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
data | T | 数据（类型 `T`）。The data. |
Mono<Void>返回Mono。Returns mono.
源码Source
io/agentscope/core/model/transport/websocket/JdkWebSocketConnection.java:176–229receive
public Flux<T> receive()返回接收。
Returns the receive.
Flux<T>返回Flux。Returns flux.
源码Source
io/agentscope/core/model/transport/websocket/JdkWebSocketConnection.java:231–241close
public Mono<Void> close()关闭连接并释放相关资源。
Releases resources and connections.
Mono<Void>返回Mono。Returns mono.
源码Source
io/agentscope/core/model/transport/websocket/JdkWebSocketConnection.java:243–269isOpen
public boolean isOpen()判断是否打开。
Returns whether the open.
boolean返回布尔值，表示判断结果。Returns a boolean result.
源码Source
io/agentscope/core/model/transport/websocket/JdkWebSocketConnection.java:271–274getCloseInfo
public CloseInfo getCloseInfo()获取关闭信息。
Returns the close info.
CloseInfo返回CloseInfo。Returns close info.
源码Source
io/agentscope/core/model/transport/websocket/JdkWebSocketConnection.java:276–279