程序包 com.agentsflex.core.model.client.impl

类 WebSocketClient

java.lang.Object

okhttp3.WebSocketListener

com.agentsflex.core.model.client.impl.WebSocketClient

所有已实现的接口:

StreamClient

public class WebSocketClient
extends okhttp3.WebSocketListener
implements StreamClient

字段概要

字段

修饰符和类型	字段	说明
private ChatConfig	config
private boolean	isStop
private StreamClientListener	listener
private static final org.slf4j.Logger	log
private okhttp3.OkHttpClient	okHttpClient
private String	payload
private okhttp3.WebSocket	webSocket

构造器概要

构造器

构造器	说明
WebSocketClient()
WebSocketClient(okhttp3.OkHttpClient okHttpClient)

方法概要

修饰符和类型	方法	说明
private void	closeWebSocketAndNotify()	安全关闭 WebSocket 并通知监听器（确保只执行一次）
okhttp3.OkHttpClient	getOkHttpClient()
void	onClosed(okhttp3.WebSocket webSocket, int code, String reason)
void	onClosing(okhttp3.WebSocket webSocket, int code, String reason)
void	onFailure(okhttp3.WebSocket webSocket, Throwable t, okhttp3.Response response)
void	onMessage(okhttp3.WebSocket webSocket, String text)
void	onMessage(okhttp3.WebSocket webSocket, okio.ByteString bytes)
void	onOpen(okhttp3.WebSocket webSocket, okhttp3.Response response)
void	setOkHttpClient(okhttp3.OkHttpClient okHttpClient)
void	start(String url, Map<String,String> headers, String payload, StreamClientListener listener, ChatConfig config)
void	stop()

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

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

字段详细资料

log

private static final org.slf4j.Logger log

okHttpClient

private okhttp3.OkHttpClient okHttpClient

webSocket

private okhttp3.WebSocket webSocket

listener

private StreamClientListener listener

config

private ChatConfig config

isStop

private boolean isStop

payload

private String payload

构造器详细资料

WebSocketClient

public WebSocketClient()

WebSocketClient

public WebSocketClient(okhttp3.OkHttpClient okHttpClient)

方法详细资料

getOkHttpClient

public okhttp3.OkHttpClient getOkHttpClient()

setOkHttpClient

public void setOkHttpClient(okhttp3.OkHttpClient okHttpClient)

start

public void start(String url,
 Map<String,String> headers,
 String payload,
 StreamClientListener listener,
 ChatConfig config)

指定者:

start 在接口中 StreamClient

stop

public void stop()

指定者:

stop 在接口中 StreamClient

onOpen

public void onOpen(okhttp3.WebSocket webSocket,
 okhttp3.Response response)

覆盖:

onOpen 在类中 okhttp3.WebSocketListener

onMessage

public void onMessage(okhttp3.WebSocket webSocket,
 String text)

覆盖:

onMessage 在类中 okhttp3.WebSocketListener

onMessage

public void onMessage(okhttp3.WebSocket webSocket,
 okio.ByteString bytes)

覆盖:

onMessage 在类中 okhttp3.WebSocketListener

onClosing

public void onClosing(okhttp3.WebSocket webSocket,
 int code,
 String reason)

覆盖:

onClosing 在类中 okhttp3.WebSocketListener

onFailure

public void onFailure(okhttp3.WebSocket webSocket,
 Throwable t,
 okhttp3.Response response)

覆盖:

onFailure 在类中 okhttp3.WebSocketListener

onClosed

public void onClosed(@NotNull
 okhttp3.WebSocket webSocket,
 int code,
 @NotNull
 String reason)

覆盖:

onClosed 在类中 okhttp3.WebSocketListener

closeWebSocketAndNotify

private void closeWebSocketAndNotify()

安全关闭 WebSocket 并通知监听器（确保只执行一次）