程序包 com.taosdata.jdbc.ws

类 WSClient

  • 所有已实现的接口:
    AutoCloseable, Runnable, org.java_websocket.WebSocket, org.java_websocket.WebSocketListener
    public class WSClient
extends org.java_websocket.client.WebSocketClient
implements AutoCloseable

    • 字段概要

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

        uri

    • 方法概要

      所有方法 实例方法 具体方法 
      修饰符和类型 方法 说明
      void close()  
      boolean isAuth()  
      void onClose​(int code, String reason, boolean remote)  
      void onError​(Exception e)  
      void onMessage​(String message)  
      void onMessage​(ByteBuffer bytes)  
      void onOpen​(org.java_websocket.handshake.ServerHandshake serverHandshake)  

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

        addHeader, clearHeaders, close, close, closeBlocking, closeConnection, connect, connectBlocking, connectBlocking, getAttachment, getConnection, getConnections, getDraft, getLocalSocketAddress, getLocalSocketAddress, getProtocol, getReadyState, getRemoteSocketAddress, getRemoteSocketAddress, getResourceDescriptor, getSocket, getSSLSession, getURI, hasBufferedData, hasSSLSupport, isClosed, isClosing, isFlushAndClose, isOpen, onCloseInitiated, onClosing, 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

    • 构造器详细资料

      • WSClient

        public WSClient​(URI serverUri,
                String user,
                String password,
                String database,
                InFlightRequest inFlightRequest,
                Map<String,​String> httpHeaders,
                CountDownLatch latch,
                int maxRequest)
        create websocket connection client
        参数:
        serverUri - connection url
        user - database user
        password - database password
        database - connection database

    • 方法详细资料

      • isAuth

        public boolean isAuth()

      • onOpen

        public void onOpen​(org.java_websocket.handshake.ServerHandshake serverHandshake)
        指定者:
        onOpen 在类中 org.java_websocket.client.WebSocketClient

      • onMessage

        public void onMessage​(String message)
        指定者:
        onMessage 在类中 org.java_websocket.client.WebSocketClient

      • onMessage

        public void onMessage​(ByteBuffer bytes)
        覆盖:
        onMessage 在类中 org.java_websocket.client.WebSocketClient

      • onClose

        public void onClose​(int code,
                    String reason,
                    boolean remote)
        指定者:
        onClose 在类中 org.java_websocket.client.WebSocketClient

      • onError

        public void onError​(Exception e)
        指定者:
        onError 在类中 org.java_websocket.client.WebSocketClient

      • close

        public void close()
        指定者:
        close 在接口中 AutoCloseable
        指定者:
        close 在接口中 org.java_websocket.WebSocket
        覆盖:
        close 在类中 org.java_websocket.client.WebSocketClient