类 com.fr.third.jgroups.Channel
的使用

使用Channel的程序包

程序包	说明
com.fr.cluster.engine.transport.context.impl
com.fr.ehcache.cluster.peer
com.fr.third.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
com.fr.third.jgroups.blocks	Provides building blocks that are layered on top of channels.
com.fr.third.jgroups.blocks.mux
com.fr.third.jgroups.demos	Provides demonstrations of JGroups functionality.
com.fr.third.jgroups.fork
com.fr.third.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

com.fr.cluster.engine.transport.context.impl中Channel的使用

参数类型为Channel的com.fr.cluster.engine.transport.context.impl中的构造器

构造器和说明
FineClusterMessageSender(Channel jChannel, MessageDispatcher jDispatcher, MessageWrapper<?> wrapper)

com.fr.ehcache.cluster.peer中Channel的使用

参数类型为Channel的com.fr.ehcache.cluster.peer中的构造器

构造器和说明
JGroupsCachePeer(Channel channel, java.lang.String clusterName) Create a new CachePeer

com.fr.third.jgroups中Channel的使用

com.fr.third.jgroups中Channel的子类

限定符和类型	类和说明
class	JChannel JChannel is a default implementation of a Channel abstraction.

返回Channel的com.fr.third.jgroups中的方法

限定符和类型	方法和说明
abstract Channel	Channel.name(java.lang.String name) Names a channel, same as setName(String)

参数类型为Channel的com.fr.third.jgroups中的方法

限定符和类型	方法和说明
void	ChannelListener.channelClosed(Channel channel) Channel has been closed notification callback
void	ChannelListener.channelConnected(Channel channel) Channel has been connected notification callback
void	ChannelListener.channelDisconnected(Channel channel) Channel has been disconnected notification callback
protected void	Channel.notifyChannelClosed(Channel c)
protected void	Channel.notifyChannelConnected(Channel c)
protected void	Channel.notifyChannelDisconnected(Channel c)

com.fr.third.jgroups.blocks中Channel的使用

声明为Channel的com.fr.third.jgroups.blocks中的字段

限定符和类型	字段和说明
protected Channel	MessageDispatcher.channel

返回Channel的com.fr.third.jgroups.blocks中的方法

限定符和类型	方法和说明
Channel	ReplicatedTree.getChannel() Returns the Channel the DistributedTree is connected to
Channel	ReplicatedHashMap.getChannel()
Channel	MessageDispatcher.getChannel()

参数类型为Channel的com.fr.third.jgroups.blocks中的方法

限定符和类型	方法和说明
void	MessageDispatcher.channelClosed(Channel channel)
void	MessageDispatcher.channelConnected(Channel channel)
void	MessageDispatcher.channelDisconnected(Channel channel)
void	MessageDispatcher.setChannel(Channel ch)

参数类型为Channel的com.fr.third.jgroups.blocks中的构造器

构造器和说明
MessageDispatcher(Channel channel, MessageListener l, MembershipListener l2)
MessageDispatcher(Channel channel, MessageListener l, MembershipListener l2, RequestHandler req_handler)
MessageDispatcher(Channel channel, RequestHandler req_handler)
ReplicatedHashMap(Channel channel) Constructs a new ReplicatedHashMap with channel.
ReplicatedHashMap(java.util.concurrent.ConcurrentMap<K,V> map, Channel channel) Constructs a new ReplicatedHashMap using provided map instance.
RpcDispatcher(Channel channel, MessageListener l, MembershipListener l2, java.lang.Object server_obj)
RpcDispatcher(Channel channel, java.lang.Object server_obj)

com.fr.third.jgroups.blocks.mux中Channel的使用

参数类型为Channel的com.fr.third.jgroups.blocks.mux中的构造器

构造器和说明
MuxMessageDispatcher(short scopeId, Channel channel, MessageListener messageListener, MembershipListener membershipListener, RequestHandler handler)
MuxRpcDispatcher(short scopeId, Channel channel, MessageListener messageListener, MembershipListener membershipListener, java.lang.Object serverObject)
MuxRpcDispatcher(short scopeId, Channel channel, MessageListener messageListener, MembershipListener membershipListener, java.lang.Object serverObject, MethodLookup method_lookup)

com.fr.third.jgroups.demos中Channel的使用

参数类型为Channel的com.fr.third.jgroups.demos中的方法

限定符和类型	方法和说明
void	Draw.channelClosed(Channel channel)
void	Draw.channelConnected(Channel channel)
void	Draw.channelDisconnected(Channel channel)

com.fr.third.jgroups.fork中Channel的使用

com.fr.third.jgroups.fork中Channel的子类

限定符和类型	类和说明
class	ForkChannel Implementation of a ForkChannel, which is a light-weight channel.

声明为Channel的com.fr.third.jgroups.fork中的字段

限定符和类型	字段和说明
protected Channel	ForkChannel.main_channel

参数类型为Channel的com.fr.third.jgroups.fork中的方法

限定符和类型	方法和说明
void	ForkChannel.channelClosed(Channel channel)
void	ForkChannel.channelConnected(Channel channel)
void	ForkChannel.channelDisconnected(Channel channel)
protected static FORK	ForkChannel.getFORK(Channel ch, int position, java.lang.Class<? extends Protocol> neighbor, boolean create_fork_if_absent)

参数类型为Channel的com.fr.third.jgroups.fork中的构造器

构造器和说明
ForkChannel(Channel main_channel, java.lang.String fork_stack_id, java.lang.String fork_channel_id, boolean create_fork_if_absent, int position, java.lang.Class<? extends Protocol> neighbor, Protocol... protocols) Creates a new fork-channel from a main-channel.
ForkChannel(Channel main_channel, java.lang.String fork_stack_id, java.lang.String fork_channel_id, Protocol... protocols) Creates a new fork-channel from a main-channel.

com.fr.third.jgroups.util中Channel的使用

参数类型为Channel的com.fr.third.jgroups.util中的方法

限定符和类型	方法和说明
static void	Util.shutdown(Channel ch) Drops messages to/from other members and then closes the channel.
static boolean	Util.startFlush(Channel c) Performs the flush of the given channel
static boolean	Util.startFlush(Channel c, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling) Performs the flush of the given channel within the specfied number of attempts along with random sleep time after each such attempt.
static boolean	Util.startFlush(Channel c, java.util.List<Address> flushParticipants) Performs the flush of the given channel and the specified flush participants
static boolean	Util.startFlush(Channel c, java.util.List<Address> flushParticipants, int numberOfAttempts, long randomSleepTimeoutFloor, long randomSleepTimeoutCeiling) Performs the flush of the given channel for the specified flush participants and the given number of attempts along with random sleep time after each such attempt.
static void	Util.waitUntilAllChannelsHaveSameSize(long timeout, long interval, Channel... channels) Blocks until all channels have the same view