org.apache.shenyu.plugin.sync.data.websocket.client

类 ShenyuWebsocketClient

java.lang.Object

org.java_websocket.WebSocketAdapter

org.java_websocket.AbstractWebSocket

org.java_websocket.client.WebSocketClient

org.apache.shenyu.plugin.sync.data.websocket.client.ShenyuWebsocketClient

所有已实现的接口:

java.lang.Runnable, org.java_websocket.WebSocket, org.java_websocket.WebSocketListener

public final class ShenyuWebsocketClient
extends org.java_websocket.client.WebSocketClient

The type shenyu websocket client.

字段概要

从类继承的字段 org.java_websocket.client.WebSocketClient

uri

构造器概要

构造器

构造器和说明
ShenyuWebsocketClient(java.net.URI serverUri, java.util.Map<java.lang.String,java.lang.String> headers, org.apache.shenyu.sync.data.api.PluginDataSubscriber pluginDataSubscriber, java.util.List<org.apache.shenyu.sync.data.api.MetaDataSubscriber> metaDataSubscribers, java.util.List<org.apache.shenyu.sync.data.api.AuthDataSubscriber> authDataSubscribers, java.util.List<org.apache.shenyu.sync.data.api.ProxySelectorDataSubscriber> proxySelectorDataSubscribers, java.util.List<org.apache.shenyu.sync.data.api.DiscoveryUpstreamDataSubscriber> discoveryUpstreamDataSubscribers) Instantiates a new shenyu websocket client.
ShenyuWebsocketClient(java.net.URI serverUri, org.apache.shenyu.sync.data.api.PluginDataSubscriber pluginDataSubscriber, java.util.List<org.apache.shenyu.sync.data.api.MetaDataSubscriber> metaDataSubscribers, java.util.List<org.apache.shenyu.sync.data.api.AuthDataSubscriber> authDataSubscribers, java.util.List<org.apache.shenyu.sync.data.api.ProxySelectorDataSubscriber> proxySelectorDataSubscribers, java.util.List<org.apache.shenyu.sync.data.api.DiscoveryUpstreamDataSubscriber> discoveryUpstreamDataSubscribers) Instantiates a new shenyu websocket client.

方法概要

限定符和类型	方法和说明
void	close()
boolean	connectBlocking()
void	nowClose() Now close.
void	onClose(int i, java.lang.String s, boolean b)
void	onError(java.lang.Exception e)
void	onMessage(java.lang.String result)
void	onOpen(org.java_websocket.handshake.ServerHandshake serverHandshake)

从类继承的方法 org.java_websocket.client.WebSocketClient

addHeader, clearHeaders, close, close, closeBlocking, closeConnection, connect, connectBlocking, getAttachment, getConnection, getConnections, getDraft, getLocalSocketAddress, getLocalSocketAddress, getReadyState, getRemoteSocketAddress, getRemoteSocketAddress, getResourceDescriptor, getSocket, getSSLSession, getURI, hasBufferedData, hasSSLSupport, isClosed, isClosing, isFlushAndClose, isOpen, onCloseInitiated, onClosing, onMessage, onSetSSLParameters, onWebsocketClose, onWebsocketCloseInitiated, onWebsocketClosing, onWebsocketError, onWebsocketMessage, onWebsocketMessage, onWebsocketOpen, onWriteDemand, reconnect, reconnectBlocking, removeHeader, run, send, send, send, sendFragmentedFrame, sendFrame, sendFrame, sendPing, setAttachment, setDnsResolver, setProxy, setSocket, setSocketFactory

从类继承的方法 org.java_websocket.AbstractWebSocket

getConnectionLostTimeout, isReuseAddr, isTcpNoDelay, setConnectionLostTimeout, setReuseAddr, setTcpNoDelay, startConnectionLostTimer, stopConnectionLostTimer

从类继承的方法 org.java_websocket.WebSocketAdapter

onPreparePing, onWebsocketHandshakeReceivedAsClient, onWebsocketHandshakeReceivedAsServer, onWebsocketHandshakeSentAsClient, onWebsocketPing, onWebsocketPong

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

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

构造器详细资料

ShenyuWebsocketClient

public ShenyuWebsocketClient(java.net.URI serverUri,
                             org.apache.shenyu.sync.data.api.PluginDataSubscriber pluginDataSubscriber,
                             java.util.List<org.apache.shenyu.sync.data.api.MetaDataSubscriber> metaDataSubscribers,
                             java.util.List<org.apache.shenyu.sync.data.api.AuthDataSubscriber> authDataSubscribers,
                             java.util.List<org.apache.shenyu.sync.data.api.ProxySelectorDataSubscriber> proxySelectorDataSubscribers,
                             java.util.List<org.apache.shenyu.sync.data.api.DiscoveryUpstreamDataSubscriber> discoveryUpstreamDataSubscribers)

Instantiates a new shenyu websocket client.

参数:

serverUri - the server uri

pluginDataSubscriber - the plugin data subscriber

metaDataSubscribers - the meta data subscribers

authDataSubscribers - the auth data subscribers

proxySelectorDataSubscribers - proxySelectorDataSubscribers,

discoveryUpstreamDataSubscribers - discoveryUpstreamDataSubscribers,

ShenyuWebsocketClient

public ShenyuWebsocketClient(java.net.URI serverUri,
                             java.util.Map<java.lang.String,java.lang.String> headers,
                             org.apache.shenyu.sync.data.api.PluginDataSubscriber pluginDataSubscriber,
                             java.util.List<org.apache.shenyu.sync.data.api.MetaDataSubscriber> metaDataSubscribers,
                             java.util.List<org.apache.shenyu.sync.data.api.AuthDataSubscriber> authDataSubscribers,
                             java.util.List<org.apache.shenyu.sync.data.api.ProxySelectorDataSubscriber> proxySelectorDataSubscribers,
                             java.util.List<org.apache.shenyu.sync.data.api.DiscoveryUpstreamDataSubscriber> discoveryUpstreamDataSubscribers)

Instantiates a new shenyu websocket client.

参数:

serverUri - the server uri

headers - the headers

pluginDataSubscriber - the plugin data subscriber

metaDataSubscribers - the meta data subscribers

authDataSubscribers - the auth data subscribers

proxySelectorDataSubscribers - proxySelectorDataSubscribers,

discoveryUpstreamDataSubscribers - discoveryUpstreamDataSubscribers,

方法详细资料

connectBlocking

public boolean connectBlocking()

覆盖:

connectBlocking 在类中 org.java_websocket.client.WebSocketClient

onOpen

public void onOpen(org.java_websocket.handshake.ServerHandshake serverHandshake)

指定者:

onOpen 在类中 org.java_websocket.client.WebSocketClient

onMessage

public void onMessage(java.lang.String result)

指定者:

onMessage 在类中 org.java_websocket.client.WebSocketClient

onClose

public void onClose(int i,
                    java.lang.String s,
                    boolean b)

指定者:

onClose 在类中 org.java_websocket.client.WebSocketClient

onError

public void onError(java.lang.Exception e)

指定者:

onError 在类中 org.java_websocket.client.WebSocketClient

close

public void close()

指定者:

close 在接口中 org.java_websocket.WebSocket

覆盖:

close 在类中 org.java_websocket.client.WebSocketClient

nowClose

public void nowClose()

Now close. now close. will cancel the task execution.