com.alipay.mychain.sdk.network

类 NetworkConnection

java.lang.Object

com.alipay.mychain.sdk.network.NetworkConnection

所有已实现的接口:

IConnection, Closeable, AutoCloseable

public class NetworkConnection
extends Object
implements IConnection

版本:

$Id: NetworkConnection, v0.1 2019年05月03日 上午11:09 xiuyi.lp Exp $

作者:

xiuyi.lp

构造器概要

构造器

构造器和说明
NetworkConnection(NetworkOption networkOption, ICodec codec, MessageProcessor processor, ILogger logger, ClientEnv clientEnv)
NetworkConnection(NetworkOption networkOption, ISslOption sslOption, ICodec codec, MessageProcessor processor, ILogger logger)

方法概要

限定符和类型	方法和说明
void	checkAndSetStatus(ChannelStatus status) only heartbeat thread use
void	close()
boolean	connect(Long connectionEndTime) channel connect
boolean	connectWithBtn(Long connectionEndTime)
boolean	disConnect() channel disconnect
void	disConnectForce() disconnect, MessageProcessor threadPool will invoke
BaseChannel	getChannel()
Long	getLastActiveTime()
ChannelStatus	getStatus()
Long	getSystemTimestamp()
String	getToEndpoint()
void	notifyEvent()
void	notifyEventInNewThread()
boolean	registerEventHandler(IConnectionCallback callback) register event handler
boolean	sendRequest(Request request, Long connectionEndTime)
boolean	sendRequest(Request request, Long connectionEndTime, String toEndpoint)
void	setConnectIndex(int connectIndex)
void	setStatus(ChannelStatus channelStatus)
void	setSystemTimestamp(Long ts)
void	setToEndpoint(String toEndpoint)
void	start()
void	startWithBtn()
void	stop()
void	stopWithBtn()
void	updateLastActiveTime() update last active time

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

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

构造器详细资料

NetworkConnection

public NetworkConnection(NetworkOption networkOption,
                         ISslOption sslOption,
                         ICodec codec,
                         MessageProcessor processor,
                         ILogger logger)

NetworkConnection

public NetworkConnection(NetworkOption networkOption,
                         ICodec codec,
                         MessageProcessor processor,
                         ILogger logger,
                         ClientEnv clientEnv)

方法详细资料

start

public void start()

startWithBtn

public void startWithBtn()

stop

public void stop()

stopWithBtn

public void stopWithBtn()

connect

public boolean connect(Long connectionEndTime)

从接口复制的说明: IConnection

channel connect

指定者:

connect 在接口中 IConnection

返回:

boolean

connectWithBtn

public boolean connectWithBtn(Long connectionEndTime)

指定者:

connectWithBtn 在接口中 IConnection

disConnect

public boolean disConnect()

从接口复制的说明: IConnection

channel disconnect

指定者:

disConnect 在接口中 IConnection

返回:

boolean

registerEventHandler

public boolean registerEventHandler(IConnectionCallback callback)

从接口复制的说明: IConnection

register event handler

指定者:

registerEventHandler 在接口中 IConnection

参数:

callback - cb

返回:

boolean

getLastActiveTime

public Long getLastActiveTime()

updateLastActiveTime

public void updateLastActiveTime()

从接口复制的说明: IConnection

update last active time

指定者:

updateLastActiveTime 在接口中 IConnection

checkAndSetStatus

public void checkAndSetStatus(ChannelStatus status)

only heartbeat thread use

参数:

status - status

disConnectForce

public void disConnectForce()

disconnect, MessageProcessor threadPool will invoke

指定者:

disConnectForce 在接口中 IConnection

getSystemTimestamp

public Long getSystemTimestamp()

setSystemTimestamp

public void setSystemTimestamp(Long ts)

setConnectIndex

public void setConnectIndex(int connectIndex)

sendRequest

public boolean sendRequest(Request request,
                           Long connectionEndTime)

sendRequest

public boolean sendRequest(Request request,
                           Long connectionEndTime,
                           String toEndpoint)

notifyEventInNewThread

public void notifyEventInNewThread()

notifyEvent

public void notifyEvent()

close

public void close()

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

getChannel

public BaseChannel getChannel()

getStatus

public ChannelStatus getStatus()

setStatus

public void setStatus(ChannelStatus channelStatus)

getToEndpoint

public String getToEndpoint()

setToEndpoint

public void setToEndpoint(String toEndpoint)