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

类 WebSocketNettyClient

java.lang.Object

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

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

所有已实现的接口:

WebSocketClient, WebSocketClientListener

public class WebSocketNettyClient
extends AbstractWebSocketClient

字段概要

字段

限定符和类型	字段和说明
private Channel	channel
private HttpProtocolWebSocketOption	httpProtocolWebSocketOption
private AtomicBoolean	initialized
private WebSocketStatus	status

从类继承的字段 org.zodiac.server.proxy.http.websocket.client.AbstractWebSocketClient

ctx, eventLoopGroup, log, uri

构造器概要

构造器

构造器和说明
WebSocketNettyClient(String uri, EventLoopGroup eventLoopGroup, ChannelHandlerContext ctx, HttpProtocolWebSocketOption httpProtocolWebSocketOption)

方法概要

限定符和类型	方法和说明
void	close()
void	connect()
WebSocketStatus	getState() This represents the state of the connection.
void	onClose(io.netty.handler.codec.http.websocketx.CloseWebSocketFrame frame)
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	onResponse(io.netty.handler.codec.http.websocketx.WebSocketFrame frame)
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.

从类继承的方法 org.zodiac.server.proxy.http.websocket.client.AbstractWebSocketClient

addAndGetIdleConnectTimeout, resetIdleConnectTimeout

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

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

字段详细资料

status

private WebSocketStatus status

channel

private Channel channel

initialized

private volatile AtomicBoolean initialized

httpProtocolWebSocketOption

private final HttpProtocolWebSocketOption httpProtocolWebSocketOption

构造器详细资料

WebSocketNettyClient

public WebSocketNettyClient(String uri,
                            EventLoopGroup eventLoopGroup,
                            ChannelHandlerContext ctx,
                            HttpProtocolWebSocketOption httpProtocolWebSocketOption)
                     throws URISyntaxException

抛出:

URISyntaxException

方法详细资料

connect

public void connect()

close

public void close()

sendPing

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

从接口复制的说明: WebSocketClient

Send a ping to the other end.

指定者:

sendPing 在接口中 WebSocketClient

覆盖:

sendPing 在类中 AbstractWebSocketClient

参数:

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

覆盖:

send 在类中 AbstractWebSocketClient

参数:

frame - PingWebSocketFrame

send

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

从接口复制的说明: WebSocketClient

Sends text to the connected websocket server.

指定者:

send 在接口中 WebSocketClient

覆盖:

send 在类中 AbstractWebSocketClient

参数:

frame - TextWebSocketFrame text The string which will be transmitted.

getState

public WebSocketStatus getState()

从接口复制的说明: WebSocketClient

This represents the state of the connection.

返回:

WebSocketStatus

sendPong

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

从接口复制的说明: WebSocketClient

Send a ping to the other end.

指定者:

sendPong 在接口中 WebSocketClient

覆盖:

sendPong 在类中 AbstractWebSocketClient

参数:

frame - PingWebSocketFrame

onPing

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

指定者:

onPing 在接口中 WebSocketClientListener

覆盖:

onPing 在类中 AbstractWebSocketClient

onPong

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

指定者:

onPong 在接口中 WebSocketClientListener

覆盖:

onPong 在类中 AbstractWebSocketClient

onMessage

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

指定者:

onMessage 在接口中 WebSocketClientListener

覆盖:

onMessage 在类中 AbstractWebSocketClient

onMessage

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

指定者:

onMessage 在接口中 WebSocketClientListener

覆盖:

onMessage 在类中 AbstractWebSocketClient

onClose

public void onClose(io.netty.handler.codec.http.websocketx.CloseWebSocketFrame frame)

onResponse

public void onResponse(io.netty.handler.codec.http.websocketx.WebSocketFrame frame)