@Deprecated public class NioUdtMessageConnectorChannel extends AbstractNioMessageChannel implements UdtChannel
注意:发送/接收必须在管道中使用UdtMessage
AbstractNioChannel.AbstractNioUnsafe, AbstractNioChannel.NioUnsafe
AbstractChannel.AbstractUnsafe
Channel.Unsafe
readInterestOp
Constructor and Description |
---|
NioUdtMessageConnectorChannel()
已过时。
|
NioUdtMessageConnectorChannel(Channel parent, com.barchart.udt.nio.SocketChannelUDT channelUDT)
已过时。
|
NioUdtMessageConnectorChannel(com.barchart.udt.nio.SocketChannelUDT channelUDT)
已过时。
|
NioUdtMessageConnectorChannel(com.barchart.udt.TypeUDT type)
已过时。
|
Modifier and Type | Method and Description |
---|---|
UdtChannelConfig |
config()
已过时。
返回频道的 UdtChannelConfig 。
|
protected void |
doBind(java.net.SocketAddress localAddress)
已过时。
将 Channel 绑定到SocketAddress
|
protected void |
doClose()
已过时。
关闭 Channel
|
protected boolean |
doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
已过时。
连接到远程对等
|
protected void |
doDisconnect()
已过时。
将此 Channel 从其远程对等方断开
|
protected void |
doFinishConnect()
已过时。
完成连接
|
protected int |
doReadMessages(java.util.List<java.lang.Object> buf)
已过时。
将消息读入给定数组并返回读取的数量。
|
protected boolean |
doWriteMessage(java.lang.Object msg, ChannelOutboundBuffer in)
已过时。
写下消息到底层
Channel 。
|
boolean |
isActive()
已过时。
如果 Channel 处于活动状态且已连接,则返回true 。
|
protected com.barchart.udt.nio.SocketChannelUDT |
javaChannel()
已过时。
|
java.net.InetSocketAddress |
localAddress()
已过时。
返回此通道绑定的本地地址。
|
protected java.net.SocketAddress |
localAddress0()
已过时。
返回本地绑定的
SocketAddress 。
|
ChannelMetadata |
metadata()
已过时。
返回 ChannelMetadata 的的Channel 其描述的性质Channel 。
|
java.net.InetSocketAddress |
remoteAddress()
已过时。
返回此通道连接到的远程地址。
|
protected java.net.SocketAddress |
remoteAddress0()
已过时。
返回 SocketAddress 其中Channel 被连接到。
|
closeOnReadError, continueOnWriteError, doBeginRead, doWrite, newUnsafe
clearReadPending, doDeregister, doRegister, eventLoop, isCompatible, isOpen, isReadPending, newDirectBuffer, newDirectBuffer, selectionKey, setReadPending, unsafe
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, equals, filterOutboundMessage, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, voidPromise, write, write, writeAndFlush, writeAndFlush
attr, hasAttr
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isOpen, isRegistered, isWritable, parent, pipeline, read, unsafe
attr, hasAttr
bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush
public NioUdtMessageConnectorChannel()
public NioUdtMessageConnectorChannel(Channel parent, com.barchart.udt.nio.SocketChannelUDT channelUDT)
public NioUdtMessageConnectorChannel(com.barchart.udt.nio.SocketChannelUDT channelUDT)
public NioUdtMessageConnectorChannel(com.barchart.udt.TypeUDT type)
public UdtChannelConfig config()
UdtChannel
UdtChannelConfig
。
config
在界面
Channel
config
在界面
UdtChannel
protected void doBind(java.net.SocketAddress localAddress) throws java.lang.Exception
AbstractChannel
Channel
绑定到SocketAddress
doBind
在课堂上
AbstractChannel
java.lang.Exception
protected void doClose() throws java.lang.Exception
AbstractChannel
Channel
doClose
在课堂
AbstractNioChannel
java.lang.Exception
protected boolean doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress) throws java.lang.Exception
AbstractNioChannel
doConnect
AbstractNioChannel
java.lang.Exception
protected void doDisconnect() throws java.lang.Exception
AbstractChannel
Channel
从其远程对等端断开
doDisconnect
在课堂上
AbstractChannel
java.lang.Exception
protected void doFinishConnect() throws java.lang.Exception
AbstractNioChannel
doFinishConnect
在类
AbstractNioChannel
java.lang.Exception
protected int doReadMessages(java.util.List<java.lang.Object> buf) throws java.lang.Exception
AbstractNioMessageChannel
doReadMessages
在课堂上
AbstractNioMessageChannel
java.lang.Exception
protected boolean doWriteMessage(java.lang.Object msg, ChannelOutboundBuffer in) throws java.lang.Exception
AbstractNioMessageChannel
Channel
。
doWriteMessage
AbstractNioMessageChannel
true
当且仅当消息已被写入
java.lang.Exception
protected com.barchart.udt.nio.SocketChannelUDT javaChannel()
protected java.net.SocketAddress localAddress0()
AbstractChannel
SocketAddress
。
localAddress0
在课堂上
AbstractChannel
public ChannelMetadata metadata()
Channel
复制的描述
ChannelMetadata
的的Channel
其描述的性质Channel
。
protected java.net.SocketAddress remoteAddress0()
AbstractChannel
SocketAddress
其中Channel
被连接到。
remoteAddress0
AbstractChannel
public java.net.InetSocketAddress localAddress()
Channel
SocketAddress
应该被下调为更具体的类型,例如InetSocketAddress
以检索详细信息。
localAddress
,界面
Channel
localAddress
,界面
UdtChannel
localAddress
在课堂上
AbstractChannel
null
如果这个频道没有绑定。
public java.net.InetSocketAddress remoteAddress()
Channel
SocketAddress
应该被放入更具体的类型,如InetSocketAddress
以检索详细信息。
remoteAddress
,界面
Channel
remoteAddress
,界面
UdtChannel
remoteAddress
在课堂上
AbstractChannel
null
if this channel is not connected. If this channel is not connected but it can receive messages from arbitrary remote addresses (e.g.
DatagramChannel
, use
DefaultAddressedEnvelope.recipient()
to determine the origination of the received message as this method will return
null
.
Copyright © 2008–2018 The Netty Project. All rights reserved.