org.zodiac.server.proxy.http.websocket.client

类 AbstractWebSocketClient

java.lang.Object

org.zodiac.server.proxy.http.websocket.client.AbstractWebSocketClient

所有已实现的接口:

WebSocketClient, WebSocketClientListener

直接已知子类:

WebSocketNettyClient

public abstract class AbstractWebSocketClient
extends Object
implements WebSocketClient, WebSocketClientListener

字段概要

字段

限定符和类型	字段和说明
protected io.netty.channel.ChannelHandlerContext	ctx
protected io.netty.channel.EventLoopGroup	eventLoopGroup
private AtomicInteger	idleConnectTimeout
protected org.slf4j.Logger	log
protected String	uri

构造器概要

构造器

构造器和说明
AbstractWebSocketClient(String uri, io.netty.channel.EventLoopGroup eventLoopGroup, io.netty.channel.ChannelHandlerContext ctx) Constructs a WebSocketClient instance and sets it to the connect to the specified URI.

方法概要

限定符和类型	方法和说明
int	addAndGetIdleConnectTimeout(int idleConnectTimeout) Adds Idle Connect Timeout and get it.
void	onMessage(io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame frame)
void	onMessage(io.netty.handler.codec.http.websocketx.TextWebSocketFrame frame)
void	onPing(io.netty.handler.codec.http.websocketx.PingWebSocketFrame frame)
void	onPong(io.netty.handler.codec.http.websocketx.PongWebSocketFrame frame)
void	resetIdleConnectTimeout() Resets idle connect timeout.
void	send(io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame frame) Send Binary data (plain bytes) to the other end.
void	send(io.netty.handler.codec.http.websocketx.TextWebSocketFrame frame) Sends text to the connected websocket server.
void	sendPing(io.netty.handler.codec.http.websocketx.PingWebSocketFrame frame) Send a ping to the other end.
void	sendPong(io.netty.handler.codec.http.websocketx.PongWebSocketFrame frame) Send a ping to the other end.

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

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

从接口继承的方法 org.zodiac.server.proxy.http.websocket.client.WebSocketClient

close, connect, getState

从接口继承的方法 org.zodiac.server.proxy.http.websocket.client.WebSocketClientListener

onClose

字段详细资料

log

protected final org.slf4j.Logger log

uri

protected String uri

ctx

protected io.netty.channel.ChannelHandlerContext ctx

eventLoopGroup

protected io.netty.channel.EventLoopGroup eventLoopGroup

idleConnectTimeout

private volatile AtomicInteger idleConnectTimeout

构造器详细资料

AbstractWebSocketClient

public AbstractWebSocketClient(String uri,
                               io.netty.channel.EventLoopGroup eventLoopGroup,
                               io.netty.channel.ChannelHandlerContext ctx)
                        throws URISyntaxException

Constructs a WebSocketClient instance and sets it to the connect to the specified URI. The channel does not attampt to connect automatically. The connection will be established once you call connect.

参数:

uri - the server URI to connect to

eventLoopGroup - eventLoopGroup

ctx - handler context

抛出:

URISyntaxException - URISyntaxException

方法详细资料

addAndGetIdleConnectTimeout

public int addAndGetIdleConnectTimeout(int idleConnectTimeout)

从接口复制的说明: WebSocketClient

Adds Idle Connect Timeout and get it.

指定者:

addAndGetIdleConnectTimeout 在接口中 WebSocketClient

参数:

idleConnectTimeout - idle connect timeout

返回:

timeout

resetIdleConnectTimeout

public void resetIdleConnectTimeout()

从接口复制的说明: WebSocketClient

Resets idle connect timeout.

指定者:

resetIdleConnectTimeout 在接口中 WebSocketClient

sendPing

public void sendPing(io.netty.handler.codec.http.websocketx.PingWebSocketFrame frame)

从接口复制的说明: WebSocketClient

Send a ping to the other end.

指定者:

sendPing 在接口中 WebSocketClient

参数:

frame - PingWebSocketFrame

sendPong

public void sendPong(io.netty.handler.codec.http.websocketx.PongWebSocketFrame frame)

从接口复制的说明: WebSocketClient

Send a ping to the other end.

指定者:

sendPong 在接口中 WebSocketClient

参数:

frame - PingWebSocketFrame

send

public void send(io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame frame)

从接口复制的说明: WebSocketClient

Send Binary data (plain bytes) to the other end.

指定者:

send 在接口中 WebSocketClient

参数:

frame - PingWebSocketFrame

send

public void send(io.netty.handler.codec.http.websocketx.TextWebSocketFrame frame)

从接口复制的说明: WebSocketClient

Sends text to the connected websocket server.

指定者:

send 在接口中 WebSocketClient

参数:

frame - TextWebSocketFrame text The string which will be transmitted.

onPing

public void onPing(io.netty.handler.codec.http.websocketx.PingWebSocketFrame frame)

指定者:

onPing 在接口中 WebSocketClientListener

onPong

public void onPong(io.netty.handler.codec.http.websocketx.PongWebSocketFrame frame)

指定者:

onPong 在接口中 WebSocketClientListener

onMessage

public void onMessage(io.netty.handler.codec.http.websocketx.TextWebSocketFrame frame)

指定者:

onMessage 在接口中 WebSocketClientListener

onMessage

public void onMessage(io.netty.handler.codec.http.websocketx.BinaryWebSocketFrame frame)

指定者:

onMessage 在接口中 WebSocketClientListener