io.jpom.socket.client

Class NodeClient

java.lang.Object

org.java_websocket.WebSocketAdapter

org.java_websocket.AbstractWebSocket

org.java_websocket.client.WebSocketClient

io.jpom.socket.client.NodeClient

All Implemented Interfaces:

Runnable, org.java_websocket.WebSocket, org.java_websocket.WebSocketListener

public class NodeClient
extends org.java_websocket.client.WebSocketClient

节点Client

Author:

lf

Field Summary

Fields inherited from class org.java_websocket.client.WebSocketClient

uri

Constructor Summary

Constructors

Constructor and Description
NodeClient(String uri, NodeModel nodeModel, org.springframework.web.socket.WebSocketSession session)

Method Summary

Modifier and Type	Method and Description
void	close()
void	getVersion()
void	onClose(int code, String reason, boolean remote)
void	onError(Exception e)
void	onMessage(String message)
void	onOpen(org.java_websocket.handshake.ServerHandshake serverHandshake)
void	send(ByteBuffer bytes)
void	send(String text)

Methods inherited from class 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, onMessage, onSetSSLParameters, onWebsocketClose, onWebsocketCloseInitiated, onWebsocketClosing, onWebsocketError, onWebsocketMessage, onWebsocketMessage, onWebsocketOpen, onWriteDemand, reconnect, reconnectBlocking, removeHeader, run, send, sendFragmentedFrame, sendFrame, sendFrame, sendPing, setAttachment, setDnsResolver, setProxy, setSocket, setSocketFactory

Methods inherited from class org.java_websocket.AbstractWebSocket

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

Methods inherited from class org.java_websocket.WebSocketAdapter

onPreparePing, onWebsocketHandshakeReceivedAsClient, onWebsocketHandshakeReceivedAsServer, onWebsocketHandshakeSentAsClient, onWebsocketPing, onWebsocketPong

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeClient

public NodeClient(String uri,
                  NodeModel nodeModel,
                  org.springframework.web.socket.WebSocketSession session)
           throws URISyntaxException,
                  InterruptedException

Throws:

URISyntaxException

InterruptedException

Method Detail

onOpen

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

Specified by:

onOpen in class org.java_websocket.client.WebSocketClient

getVersion

public void getVersion()

onMessage

public void onMessage(String message)

Specified by:

onMessage in class org.java_websocket.client.WebSocketClient

onClose

public void onClose(int code,
                    String reason,
                    boolean remote)

Specified by:

onClose in class org.java_websocket.client.WebSocketClient

send

public void send(String text)

Specified by:

send in interface org.java_websocket.WebSocket

Overrides:

send in class org.java_websocket.client.WebSocketClient

close

public void close()

Specified by:

close in interface org.java_websocket.WebSocket

Overrides:

close in class org.java_websocket.client.WebSocketClient

send

public void send(ByteBuffer bytes)

Specified by:

send in interface org.java_websocket.WebSocket

Overrides:

send in class org.java_websocket.client.WebSocketClient

onError

public void onError(Exception e)

Specified by:

onError in class org.java_websocket.client.WebSocketClient