public final class NioDatagramChannel extends AbstractNioMessageChannel implements DatagramChannel
Channel that sends and receives an
AddressedEnvelope.AddressedEnvelope,
DatagramPacketAbstractNioChannel.AbstractNioUnsafe, AbstractNioChannel.NioUnsafeAbstractChannel.AbstractUnsafeChannel.UnsafereadInterestOp| 构造器和说明 |
|---|
NioDatagramChannel()
Create a new instance which will use the Operation Systems default
InternetProtocolFamily. |
NioDatagramChannel(java.nio.channels.DatagramChannel socket)
Create a new instance from the given
DatagramChannel. |
NioDatagramChannel(InternetProtocolFamily ipFamily)
Create a new instance using the given
InternetProtocolFamily. |
NioDatagramChannel(java.nio.channels.spi.SelectorProvider provider)
Create a new instance using the given
SelectorProvider
which will use the Operation Systems default InternetProtocolFamily. |
NioDatagramChannel(java.nio.channels.spi.SelectorProvider provider,
InternetProtocolFamily ipFamily)
Create a new instance using the given
SelectorProvider and InternetProtocolFamily. |
| 限定符和类型 | 方法和说明 |
|---|---|
ChannelFuture |
block(java.net.InetAddress multicastAddress,
java.net.InetAddress sourceToBlock)
Block the given sourceToBlock address for the given multicastAddress
|
ChannelFuture |
block(java.net.InetAddress multicastAddress,
java.net.InetAddress sourceToBlock,
ChannelPromise promise)
Block the given sourceToBlock address for the given multicastAddress
|
ChannelFuture |
block(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress sourceToBlock)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface
|
ChannelFuture |
block(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress sourceToBlock,
ChannelPromise promise)
Block the given sourceToBlock address for the given multicastAddress on the given networkInterface
|
protected boolean |
closeOnReadError(java.lang.Throwable cause) |
DatagramChannelConfig |
config()
Returns the configuration of this channel.
|
protected boolean |
continueOnWriteError()
Returns
true if we should continue the write loop on a write error. |
protected boolean |
continueReading(RecvByteBufAllocator.Handle allocHandle) |
protected void |
doBind(java.net.SocketAddress localAddress)
Bind the
Channel to the SocketAddress |
protected void |
doClose()
Close the
Channel |
protected boolean |
doConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
Connect to the remote peer
|
protected void |
doDisconnect()
Disconnect this
Channel from its remote peer |
protected void |
doFinishConnect()
Finish the connect
|
protected int |
doReadMessages(java.util.List<java.lang.Object> buf)
Read messages into the given array and return the amount which was read.
|
protected boolean |
doWriteMessage(java.lang.Object msg,
ChannelOutboundBuffer in)
Write a message to the underlying
Channel. |
protected java.lang.Object |
filterOutboundMessage(java.lang.Object msg)
Invoked when a new message is added to a
ChannelOutboundBuffer of this AbstractChannel, so that
the Channel implementation converts the message to another. |
boolean |
isActive()
Return
true if the Channel is active and so connected. |
boolean |
isConnected()
Return
true if the DatagramChannel is connected to the remote peer. |
protected java.nio.channels.DatagramChannel |
javaChannel() |
ChannelFuture |
joinGroup(java.net.InetAddress multicastAddress)
Joins a multicast group and notifies the
ChannelFuture once the operation completes. |
ChannelFuture |
joinGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise)
Joins a multicast group and notifies the
ChannelFuture once the operation completes. |
ChannelFuture |
joinGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source)
Joins the specified multicast group at the specified interface and notifies the
ChannelFuture
once the operation completes. |
ChannelFuture |
joinGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source,
ChannelPromise promise)
Joins the specified multicast group at the specified interface and notifies the
ChannelFuture
once the operation completes. |
ChannelFuture |
joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface)
Joins the specified multicast group at the specified interface and notifies the
ChannelFuture
once the operation completes. |
ChannelFuture |
joinGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise)
Joins the specified multicast group at the specified interface and notifies the
ChannelFuture
once the operation completes. |
ChannelFuture |
leaveGroup(java.net.InetAddress multicastAddress)
Leaves a multicast group and notifies the
ChannelFuture once the operation completes. |
ChannelFuture |
leaveGroup(java.net.InetAddress multicastAddress,
ChannelPromise promise)
Leaves a multicast group and notifies the
ChannelFuture once the operation completes. |
ChannelFuture |
leaveGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source)
Leave the specified multicast group at the specified interface using the specified source and notifies
the
ChannelFuture once the operation completes. |
ChannelFuture |
leaveGroup(java.net.InetAddress multicastAddress,
java.net.NetworkInterface networkInterface,
java.net.InetAddress source,
ChannelPromise promise)
Leave the specified multicast group at the specified interface using the specified source and notifies
the
ChannelFuture once the operation completes. |
ChannelFuture |
leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface)
Leaves a multicast group on a specified local interface and notifies the
ChannelFuture once the
operation completes. |
ChannelFuture |
leaveGroup(java.net.InetSocketAddress multicastAddress,
java.net.NetworkInterface networkInterface,
ChannelPromise promise)
Leaves a multicast group on a specified local interface and notifies the
ChannelFuture once the
operation completes. |
java.net.InetSocketAddress |
localAddress()
Returns the local address where this channel is bound to.
|
protected java.net.SocketAddress |
localAddress0()
Returns the
SocketAddress which is bound locally. |
ChannelMetadata |
metadata()
|
java.net.InetSocketAddress |
remoteAddress()
Returns the remote address where this channel is connected to.
|
protected java.net.SocketAddress |
remoteAddress0()
Return the
SocketAddress which the Channel is connected to. |
protected void |
setReadPending(boolean readPending)
已过时。
|
doBeginRead, doWrite, newUnsafeclearReadPending, doDeregister, doRegister, eventLoop, isCompatible, isOpen, isReadPending, newDirectBuffer, newDirectBuffer, selectionKey, unsafealloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, equals, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlushattr, hasAttralloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isOpen, isRegistered, isWritable, parent, pipeline, read, unsafeattr, hasAttrbind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlushpublic NioDatagramChannel()
InternetProtocolFamily.public NioDatagramChannel(java.nio.channels.spi.SelectorProvider provider)
SelectorProvider
which will use the Operation Systems default InternetProtocolFamily.public NioDatagramChannel(InternetProtocolFamily ipFamily)
InternetProtocolFamily. If null is used it will depend
on the Operation Systems default which will be chosen.public NioDatagramChannel(java.nio.channels.spi.SelectorProvider provider,
InternetProtocolFamily ipFamily)
SelectorProvider and InternetProtocolFamily.
If InternetProtocolFamily is null it will depend on the Operation Systems default
which will be chosen.public NioDatagramChannel(java.nio.channels.DatagramChannel socket)
DatagramChannel.public ChannelMetadata metadata()
Channelpublic DatagramChannelConfig config()
Channelconfig 在接口中 Channelconfig 在接口中 DatagramChannelpublic boolean isActive()
Channeltrue if the Channel is active and so connected.public boolean isConnected()
DatagramChanneltrue if the DatagramChannel is connected to the remote peer.isConnected 在接口中 DatagramChannelprotected java.nio.channels.DatagramChannel javaChannel()
javaChannel 在类中 AbstractNioChannelprotected java.net.SocketAddress localAddress0()
AbstractChannelSocketAddress which is bound locally.localAddress0 在类中 AbstractChannelprotected java.net.SocketAddress remoteAddress0()
AbstractChannelSocketAddress which the Channel is connected to.remoteAddress0 在类中 AbstractChannelprotected void doBind(java.net.SocketAddress localAddress)
throws java.lang.Exception
AbstractChannelChannel to the SocketAddressdoBind 在类中 AbstractChanneljava.lang.Exceptionprotected boolean doConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
throws java.lang.Exception
AbstractNioChanneldoConnect 在类中 AbstractNioChanneljava.lang.Exceptionprotected void doFinishConnect()
throws java.lang.Exception
AbstractNioChanneldoFinishConnect 在类中 AbstractNioChanneljava.lang.Exceptionprotected void doDisconnect()
throws java.lang.Exception
AbstractChannelChannel from its remote peerdoDisconnect 在类中 AbstractChanneljava.lang.Exceptionprotected void doClose()
throws java.lang.Exception
AbstractChannelChanneldoClose 在类中 AbstractNioChanneljava.lang.Exceptionprotected int doReadMessages(java.util.List<java.lang.Object> buf)
throws java.lang.Exception
AbstractNioMessageChanneldoReadMessages 在类中 AbstractNioMessageChanneljava.lang.Exceptionprotected boolean doWriteMessage(java.lang.Object msg,
ChannelOutboundBuffer in)
throws java.lang.Exception
AbstractNioMessageChannelChannel.doWriteMessage 在类中 AbstractNioMessageChanneltrue if and only if the message has been writtenjava.lang.Exceptionprotected java.lang.Object filterOutboundMessage(java.lang.Object msg)
AbstractChannelChannelOutboundBuffer of this AbstractChannel, so that
the Channel implementation converts the message to another. (e.g. heap buffer -> direct buffer)filterOutboundMessage 在类中 AbstractChannelprotected boolean continueOnWriteError()
AbstractNioMessageChanneltrue if we should continue the write loop on a write error.public java.net.InetSocketAddress localAddress()
ChannelSocketAddress is supposed to be down-cast into more concrete
type such as InetSocketAddress to retrieve the detailed
information.localAddress 在接口中 ChannellocalAddress 在接口中 DatagramChannellocalAddress 在类中 AbstractChannelnull if this channel is not bound.public java.net.InetSocketAddress remoteAddress()
ChannelSocketAddress is supposed to be down-cast into more
concrete type such as InetSocketAddress to retrieve the detailed
information.remoteAddress 在接口中 ChannelremoteAddress 在接口中 DatagramChannelremoteAddress 在类中 AbstractChannelnull 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.public ChannelFuture joinGroup(java.net.InetAddress multicastAddress)
DatagramChannelChannelFuture once the operation completes.joinGroup 在接口中 DatagramChannelpublic ChannelFuture joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
DatagramChannelChannelFuture once the operation completes.
The given ChannelFuture will be notified and also returned.joinGroup 在接口中 DatagramChannelpublic ChannelFuture joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface)
DatagramChannelChannelFuture
once the operation completes.joinGroup 在接口中 DatagramChannelpublic ChannelFuture joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
DatagramChannelChannelFuture
once the operation completes.
The given ChannelFuture will be notified and also returned.joinGroup 在接口中 DatagramChannelpublic ChannelFuture joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
DatagramChannelChannelFuture
once the operation completes.joinGroup 在接口中 DatagramChannelpublic ChannelFuture joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
DatagramChannelChannelFuture
once the operation completes.
The given ChannelFuture will be notified and also returned.joinGroup 在接口中 DatagramChannelpublic ChannelFuture leaveGroup(java.net.InetAddress multicastAddress)
DatagramChannelChannelFuture once the operation completes.leaveGroup 在接口中 DatagramChannelpublic ChannelFuture leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
DatagramChannelChannelFuture once the operation completes.
The given ChannelFuture will be notified and also returned.leaveGroup 在接口中 DatagramChannelpublic ChannelFuture leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface)
DatagramChannelChannelFuture once the
operation completes.leaveGroup 在接口中 DatagramChannelpublic ChannelFuture leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
DatagramChannelChannelFuture once the
operation completes.
The given ChannelFuture will be notified and also returned.leaveGroup 在接口中 DatagramChannelpublic ChannelFuture leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
DatagramChannelChannelFuture once the operation completes.leaveGroup 在接口中 DatagramChannelpublic ChannelFuture leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
DatagramChannelChannelFuture once the operation completes.
The given ChannelFuture will be notified and also returned.leaveGroup 在接口中 DatagramChannelpublic ChannelFuture block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock)
block 在接口中 DatagramChannelpublic ChannelFuture block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
block 在接口中 DatagramChannelpublic ChannelFuture block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock)
block 在接口中 DatagramChannelpublic ChannelFuture block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)
block 在接口中 DatagramChannel@Deprecated protected void setReadPending(boolean readPending)
setReadPending 在类中 AbstractNioChannelprotected boolean closeOnReadError(java.lang.Throwable cause)
protected boolean continueReading(RecvByteBufAllocator.Handle allocHandle)