Class ClientUserChannel

java.lang.Object

com.iohao.net.extension.client.user.ClientUserChannel

public class ClientUserChannel
extends Object

Client communication channel facade for sending requests and receiving server responses.

    Sends requests and receives server responses.

Author:

渔民小镇

date:

2023-07-13

Field Summary

Fields

Modifier and Type	Field	Description
Runnable	closeChannel
InetSocketAddress	inetSocketAddress	Target server address.

Constructor Summary

Constructors

Constructor	Description
ClientUserChannel(DefaultClientUser clientUser)

Method Summary

Modifier and Type	Method	Description
void	addListen(ListenCommand listenCommand)
void	closeChannel()
void	execute(RequestCommand requestCommand)
Map<Integer, RequestCommand>	getCallbackMap()	请求回调
ChannelAccept	getChannelAccept()
ClientChannelRead	getChannelRead()
DefaultClientUser	getClientUser()
Runnable	getCloseChannel()
InetSocketAddress	getInetSocketAddress()	Target server address.
Map<Integer, ListenCommand>	getListenMap()	广播监听
AtomicInteger	getMsgIdSeq()
AtomicBoolean	getStarting()
void	readMessage(ExternalMessage message)
void	request(InputCommand inputCommand)
void	setChannelAccept(ChannelAccept channelAccept)
void	setChannelRead(ClientChannelRead channelRead)
void	setCloseChannel(Runnable closeChannel)
void	setInetSocketAddress(InetSocketAddress inetSocketAddress)	Target server address.
void	writeAndFlush(ExternalMessage message)

Methods inherited from class Object

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

Field Details

closeChannel

public Runnable closeChannel

inetSocketAddress

public InetSocketAddress inetSocketAddress

Target server address.

Constructor Details

ClientUserChannel

public ClientUserChannel(DefaultClientUser clientUser)

Method Details

request

public void request(InputCommand inputCommand)

execute

public void execute(RequestCommand requestCommand)

readMessage

public void readMessage(ExternalMessage message)

writeAndFlush

public void writeAndFlush(ExternalMessage message)

addListen

public void addListen(ListenCommand listenCommand)

closeChannel

public void closeChannel()

getMsgIdSeq

public AtomicInteger getMsgIdSeq()

getStarting

public AtomicBoolean getStarting()

getCallbackMap

public Map<Integer, RequestCommand> getCallbackMap()

请求回调

    key : msgId

getListenMap

public Map<Integer, ListenCommand> getListenMap()

广播监听

    key : cmdMerge

getChannelRead

public ClientChannelRead getChannelRead()

getClientUser

public DefaultClientUser getClientUser()

getCloseChannel

public Runnable getCloseChannel()

getChannelAccept

public ChannelAccept getChannelAccept()

getInetSocketAddress

public InetSocketAddress getInetSocketAddress()

Target server address.

setChannelRead

public void setChannelRead(ClientChannelRead channelRead)

setCloseChannel

public void setCloseChannel(Runnable closeChannel)

setChannelAccept

public void setChannelAccept(ChannelAccept channelAccept)

setInetSocketAddress

public void setInetSocketAddress(InetSocketAddress inetSocketAddress)

Target server address.