public class DefaultChannelGroup extends java.util.AbstractSet<Channel> implements ChannelGroup
ChannelGroup
实现。
Constructor and Description |
---|
DefaultChannelGroup(EventExecutor executor)
使用生成的名称创建一个新组,并提供 EventExecutor 以通知ChannelGroupFuture 。
|
DefaultChannelGroup(EventExecutor executor, boolean stayClosed)
使用生成的名称创建一个新组,并提供 EventExecutor 以通知ChannelGroupFuture 。
|
DefaultChannelGroup(java.lang.String name, EventExecutor executor)
用指定的 name 和EventExecutor 创建一个新组以通知ChannelGroupFuture 。
|
DefaultChannelGroup(java.lang.String name, EventExecutor executor, boolean stayClosed)
用指定的 name 和EventExecutor 创建一个新组以通知ChannelGroupFuture 。
|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public DefaultChannelGroup(EventExecutor executor)
EventExecutor
以通知ChannelGroupFuture
。
public DefaultChannelGroup(java.lang.String name, EventExecutor executor)
name
和EventExecutor
创建一个新组以通知ChannelGroupFuture
。
请注意,不同的组可以具有相同的名称,这意味着不会对组名称进行重复检查。
public DefaultChannelGroup(EventExecutor executor, boolean stayClosed)
EventExecutor
以通知ChannelGroupFuture
。
stayClosed
定义是否该组可以关闭多次。
将频道添加到已关闭的群组也会立即关闭它们。
这使得一次关闭服务器和子通道变得容易。
public DefaultChannelGroup(java.lang.String name, EventExecutor executor, boolean stayClosed)
name
和EventExecutor
创建一个新组,以通知ChannelGroupFuture
。
stayClosed
定义是否该组可以关闭多次。
将频道添加到已关闭的群组也会立即关闭它们。
这使得一次关闭服务器和子通道变得容易。
请注意,不同的组可以具有相同的名称,这意味着不会对组名称进行重复检查。
public java.lang.String name()
ChannelGroup
name
,界面
ChannelGroup
public Channel find(ChannelId id)
ChannelGroup
复制的描述
find
,界面
ChannelGroup
Channel
如果找到。
null
否则。
public boolean isEmpty()
public int size()
public boolean contains(java.lang.Object o)
public boolean add(Channel channel)
public boolean remove(java.lang.Object o)
public void clear()
public java.util.Iterator<Channel> iterator()
public java.lang.Object[] toArray()
public <T> T[] toArray(T[] a)
public ChannelGroupFuture close()
ChannelGroup
close
在界面
ChannelGroup
ChannelGroupFuture
实例通知所有通道何时完成操作
public ChannelGroupFuture disconnect()
ChannelGroup
Channel
与远程对等方断开连接。
disconnect
在界面
ChannelGroup
ChannelGroupFuture
实例通知所有通道何时完成操作
public ChannelGroupFuture deregister()
deregister
在界面
ChannelGroup
ChannelGroupFuture
实例通知所有通道何时完成操作
public ChannelGroupFuture write(java.lang.Object message)
ChannelGroup
message
写入此组中的所有Channel
。
如果指定的message
是一个实例ByteBuf
,它会自动为duplicated ,以避免出现竞争状况。
ByteBufHolder
也是如此。
请注意,此操作是异步的,因为ChannelOutboundInvoker.write(Object)
是。
write
在界面
ChannelGroup
public ChannelGroupFuture write(java.lang.Object message, ChannelMatcher matcher)
ChannelGroup
message
所有Channel
s此组由给定的匹配ChannelMatcher
。
如果指定的message
是message
的实例, 则会自动为duplicated来避免竞争状况。
ByteBufHolder
也是如此。
请注意,此操作是异步的,因为ChannelOutboundInvoker.write(Object)
是。
write
在界面
ChannelGroup
ChannelGroupFuture
实例通知所有通道何时完成操作
public ChannelGroupFuture write(java.lang.Object message, ChannelMatcher matcher, boolean voidPromise)
ChannelGroup
message
所有Channel
s此组由给定的匹配ChannelMatcher
。
如果指定的message
是一个实例ByteBuf
,它会自动为duplicated ,以避免出现竞争状况。
ByteBufHolder
也是如此。
请注意,该操作与ChannelOutboundInvoker.write(Object)
是异步的。
如果voidPromise
是true
ChannelOutboundInvoker.voidPromise()
用于写入,因此对返回的ChannelGroupFuture
的相同限制适用于无效承诺。
write
,界面
ChannelGroup
ChannelGroupFuture
实例通知所有通道何时完成操作
public ChannelGroup flush()
ChannelGroup
Channel
。
如果指定的messages
是messages
的实例, 则会自动为duplicated避免竞争状况。
请注意,此操作是异步的,因为ChannelOutboundInvoker.write(Object)
是。
flush
,界面
ChannelGroup
ChannelGroupFuture
实例通知所有通道何时完成操作
public ChannelGroupFuture flushAndWrite(java.lang.Object message)
flushAndWrite
,界面
ChannelGroup
public ChannelGroupFuture writeAndFlush(java.lang.Object message)
ChannelGroup
复制的描述
writeAndFlush
在界面
ChannelGroup
public ChannelGroupFuture disconnect(ChannelMatcher matcher)
ChannelGroup
Channel
与远程对等设备断开连接,并与给定的ChannelMatcher
匹配。
disconnect
在界面
ChannelGroup
ChannelGroupFuture
实例通知所有通道何时完成操作
public ChannelGroupFuture close(ChannelMatcher matcher)
ChannelGroup
Channel
s,与给定的ChannelMatcher
相匹配。
如果Channel
连接到远程对等端或绑定到本地地址,则会自动断开连接并解除绑定。
close
,界面
ChannelGroup
ChannelGroupFuture
实例通知所有通道何时完成操作
public ChannelGroupFuture deregister(ChannelMatcher matcher)
deregister
在界面
ChannelGroup
ChannelGroupFuture
实例通知所有通道何时完成操作
public ChannelGroup flush(ChannelMatcher matcher)
ChannelGroup
Channel
s此组由给定匹配的ChannelMatcher
。
如果指定的messages
是messages
的实例, 则会自动为duplicated来避免竞争状况。
请注意,此操作是异步的,因为ChannelOutboundInvoker.write(Object)
是。
flush
在界面
ChannelGroup
ChannelGroupFuture
实例通知所有通道何时完成操作
public ChannelGroupFuture flushAndWrite(java.lang.Object message, ChannelMatcher matcher)
flushAndWrite
在界面
ChannelGroup
public ChannelGroupFuture writeAndFlush(java.lang.Object message, ChannelMatcher matcher)
ChannelGroup
复制的描述
ChannelGroup.write(Object)
和ChannelGroup.flush()
的快捷方式,仅适用于与ChannelMatcher
匹配的Channel
。
writeAndFlush
在界面
ChannelGroup
public ChannelGroupFuture writeAndFlush(java.lang.Object message, ChannelMatcher matcher, boolean voidPromise)
ChannelGroup
ChannelGroup.write(Object, ChannelMatcher, boolean)
和ChannelGroup.flush()
的快捷方式,仅适用于与ChannelMatcher
匹配的Channel
。
writeAndFlush
在界面
ChannelGroup
public ChannelGroupFuture newCloseFuture()
ChannelGroup
ChannelGroupFuture
当所有这一切将被通知Channel
个 S中的这部分ChannelGroup
,在调用的时候,被关闭。
newCloseFuture
,界面
ChannelGroup
public ChannelGroupFuture newCloseFuture(ChannelMatcher matcher)
ChannelGroup
复制的描述
ChannelGroupFuture
当所有这一切将被通知Channel
个 S中的这部分ChannelGroup
,在调用的时候,被关闭。
newCloseFuture
,界面
ChannelGroup
public int hashCode()
public boolean equals(java.lang.Object o)
public int compareTo(ChannelGroup o)
compareTo
,界面
java.lang.Comparable<ChannelGroup>
public java.lang.String toString()
toString
在课堂
java.util.AbstractCollection<Channel>
Copyright © 2008–2018 The Netty Project. All rights reserved.