public class OioDatagramChannel extends AbstractOioMessageChannel implements DatagramChannel
Channel ,发送和接收AddressedEnvelope
。
AddressedEnvelope , DatagramPacket
AbstractChannel.AbstractUnsafeChannel.UnsafeSO_TIMEOUT| Constructor and Description |
|---|
OioDatagramChannel()
用新的
MulticastSocket创建一个新实例。
|
OioDatagramChannel(java.net.MulticastSocket socket)
从给定的
MulticastSocket创建一个新实例。
|
| Modifier and Type | Method and Description |
|---|---|
ChannelFuture |
block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock)
阻止给定多播地址的给定sourceToBlock地址,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)
阻止给定多播地址的给定sourceToBlock地址,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock)
在给定networkInterface上阻止给定的多播地址的给定sourceToBlock地址,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
在给定networkInterface上阻止给定多播地址的给定sourceToBlock地址,并在操作完成后通知 ChannelFuture 。
|
DatagramChannelConfig |
config()
返回此频道的配置。
|
protected void |
doBind(java.net.SocketAddress localAddress)
将 Channel绑定到SocketAddress
|
protected void |
doClose()
关闭 Channel
|
protected void |
doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
如果指定了localAddress,则使用给定的localAddress连接到远程对等,否则连接到
null 。
|
protected void |
doDisconnect()
断开此 Channel与其远程对等端的连接
|
protected int |
doReadMessages(java.util.List<java.lang.Object> buf)
将消息读入给定数组并返回读取的数量。
|
protected void |
doWrite(ChannelOutboundBuffer in)
将给定缓冲区的内容刷新到远程对等体。
|
protected java.lang.Object |
filterOutboundMessage(java.lang.Object msg)
在将新消息添加到此 AbstractChannel的ChannelOutboundBuffer时调用 ,以便Channel实现将消息转换为另一个消息。
|
boolean |
isActive()
如果 Channel处于活动状态且已连接,则返回true 。
|
boolean |
isConnected()
如果 DatagramChannel连接到远程对等端,则返回true 。
|
boolean |
isOpen()
如果 Channel已打开并且稍后可能会激活,则返回true
|
ChannelFuture |
joinGroup(java.net.InetAddress multicastAddress)
加入一个多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
一旦操作完成,就加入多播组并通知 ChannelFuture 。
|
ChannelFuture |
joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
在指定的接口加入指定的组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
在指定的接口加入指定的组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface)
在指定的接口加入指定的组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
在指定的接口加入指定的组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
leaveGroup(java.net.InetAddress multicastAddress)
一个操作完成后,离开多播组并通知 ChannelFuture 。
|
ChannelFuture |
leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
一个操作完成后,留下多播组并通知 ChannelFuture 。
|
ChannelFuture |
leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
在指定的接口上使用指定的源保留指定的多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
在指定的接口上使用指定的源保留指定的多播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface)
在指定的本地接口上留下组播组,并在操作完成后通知 ChannelFuture 。
|
ChannelFuture |
leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
在指定的本地接口上留下多播组,并在操作完成后通知 ChannelFuture 。
|
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被连接到。
|
doReadclearReadPending, doBeginRead, isCompatible, isReadPending, newUnsafe, setReadPendingalloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doDeregister, doRegister, doShutdownOutput, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushattr, hasAttrclone, finalize, getClass, notify, notifyAll, wait, wait, waitalloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, 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 OioDatagramChannel()
MulticastSocket创建一个新实例。
public OioDatagramChannel(java.net.MulticastSocket socket)
MulticastSocket创建一个新实例。
socket - 此实例使用的
MulticastSocket
public ChannelMetadata metadata()
Channel
ChannelMetadata的的Channel其描述的性质Channel 。
public DatagramChannelConfig config()
OioDatagramChannelConfig 。
config在界面
Channel
config在界面
DatagramChannel
public boolean isConnected()
DatagramChannel
DatagramChannel连接到远程对等端,则返回true 。
isConnected在界面
DatagramChannel
protected java.net.SocketAddress localAddress0()
AbstractChannel
SocketAddress 。
localAddress0在课堂上
AbstractChannel
protected java.net.SocketAddress remoteAddress0()
AbstractChannel
SocketAddress其中Channel被连接到。
remoteAddress0在课堂上
AbstractChannel
protected void doBind(java.net.SocketAddress localAddress)
throws java.lang.Exception
AbstractChannel
Channel绑定到SocketAddress
doBind类
AbstractChannel
java.lang.Exception
public java.net.InetSocketAddress localAddress()
Channel
SocketAddress应该被放入更具体的类型,例如InetSocketAddress以检索详细信息。
localAddress在界面
Channel
localAddress在界面
DatagramChannel
localAddress在课堂上
AbstractChannel
null如果此通道未绑定。
public java.net.InetSocketAddress remoteAddress()
Channel
SocketAddress应该被下变为更具体的类型,例如InetSocketAddress来检索详细信息。
remoteAddress在界面
Channel
remoteAddress在界面
DatagramChannel
remoteAddress
AbstractChannel
null如果此通道未连接。
如果此通道未连接,但它可以接收来自任意远程地址的消息(例如DatagramChannel ,请使用DefaultAddressedEnvelope.recipient()来确定收到消息的来源,因为此方法将返回null 。
protected void doConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
throws java.lang.Exception
AbstractOioChannel
null 。
doConnect在课堂
AbstractOioChannel
java.lang.Exception
protected void doDisconnect()
throws java.lang.Exception
AbstractChannel
Channel从其远程对等端断开
doDisconnect
AbstractChannel
java.lang.Exception
protected void doClose()
throws java.lang.Exception
AbstractChannel
Channel
doClose的
AbstractChannel
java.lang.Exception
protected int doReadMessages(java.util.List<java.lang.Object> buf)
throws java.lang.Exception
AbstractOioMessageChannel
doReadMessages在课堂上
AbstractOioMessageChannel
java.lang.Exception
protected void doWrite(ChannelOutboundBuffer in) throws java.lang.Exception
AbstractChannel
doWrite在课堂上
AbstractChannel
java.lang.Exception
protected java.lang.Object filterOutboundMessage(java.lang.Object msg)
AbstractChannel
AbstractChannel的ChannelOutboundBuffer时调用 ,以便Channel实现将消息转换为另一个消息。
(例如堆缓冲区 - >直接缓冲区)
public ChannelFuture joinGroup(java.net.InetAddress multicastAddress)
DatagramChannel
ChannelFuture 。
joinGroup在界面
DatagramChannel
public ChannelFuture joinGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
DatagramChannel
ChannelFuture 。
给定的ChannelFuture将被通知并返回。
joinGroup接口
DatagramChannel
public ChannelFuture joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface)
DatagramChannel
ChannelFuture 。
joinGroup在界面
DatagramChannel
public ChannelFuture joinGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
DatagramChannel
ChannelFuture 。
给定的ChannelFuture将被通知并且返回。
joinGroup在界面
DatagramChannel
public ChannelFuture joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
DatagramChannel
ChannelFuture 。
joinGroup在界面
DatagramChannel
public ChannelFuture joinGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
DatagramChannel
ChannelFuture 。
给定的ChannelFuture将被通知并且返回。
joinGroup在界面
DatagramChannel
public ChannelFuture leaveGroup(java.net.InetAddress multicastAddress)
DatagramChannel
ChannelFuture 。
leaveGroup在界面
DatagramChannel
public ChannelFuture leaveGroup(java.net.InetAddress multicastAddress, ChannelPromise promise)
DatagramChannel复制的描述
ChannelFuture 。
给定的ChannelFuture将被通知并且返回。
leaveGroup ,界面
DatagramChannel
public ChannelFuture leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface)
DatagramChannel
ChannelFuture 。
leaveGroup在界面
DatagramChannel
public ChannelFuture leaveGroup(java.net.InetSocketAddress multicastAddress, java.net.NetworkInterface networkInterface, ChannelPromise promise)
DatagramChannel
ChannelFuture 。
给定的ChannelFuture将被通知并且返回。
leaveGroup接口
DatagramChannel
public ChannelFuture leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source)
DatagramChannel
ChannelFuture 。
leaveGroup在界面
DatagramChannel
public ChannelFuture leaveGroup(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress source, ChannelPromise promise)
DatagramChannel
ChannelFuture 。
给定的ChannelFuture将被通知并返回。
leaveGroup在界面
DatagramChannel
public ChannelFuture block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock)
DatagramChannel
ChannelFuture 。
给定的ChannelFuture将被通知并且返回。
block在界面
DatagramChannel
public ChannelFuture block(java.net.InetAddress multicastAddress, java.net.NetworkInterface networkInterface, java.net.InetAddress sourceToBlock, ChannelPromise promise)
DatagramChannel
ChannelFuture 。
给定的ChannelFuture将被通知并且返回。
block在界面
DatagramChannel
public ChannelFuture block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock)
DatagramChannel
ChannelFuture 。
给定的ChannelFuture将被通知并返回。
block接口
DatagramChannel
public ChannelFuture block(java.net.InetAddress multicastAddress, java.net.InetAddress sourceToBlock, ChannelPromise promise)
DatagramChannel
ChannelFuture 。
给定的ChannelFuture将被通知并且返回。
block在界面
DatagramChannel
Copyright © 2008–2018 The Netty Project. All rights reserved.