JChannel

java.lang.Object
- com.fr.third.jgroups.Channel
- - com.fr.third.jgroups.JChannel

所有已实现的接口:

java.io.Closeable, java.lang.AutoCloseable

直接已知子类:

ForkChannel
```
public class JChannel
extends Channel
```
JChannel is a default implementation of a Channel abstraction.

JChannel is instantiated using an appropriate form of a protocol stack description. Protocol stack can be described using a file, URL or a stream containing XML stack description.

从以下版本开始:

2.0

作者:

Bela Ban

嵌套类概要
- 从类继承的嵌套类/接口 com.fr.third.jgroups.Channel
  Channel.State

字段概要

字段
限定符和类型	字段和说明
`protected java.util.List<AddressGenerator>`	`address_generators`
`protected java.lang.String`	`cluster_name`
`protected java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Object>`	`config`
`static java.lang.String`	`DEFAULT_PROTOCOL_STACK` The default protocol stack used by the default constructor
`protected boolean`	`flush_supported` True if a flush protocol is available, false otherwise (set by CONFIG event from FLUSH protocol)
`protected Address`	`local_addr`
`protected View`	`my_view`
`protected java.lang.String`	`name`
`protected DiagnosticsHandler.ProbeHandler`	`probe_handler`
`protected ProtocolStack`	`prot_stack`
`protected long`	`received_bytes`
`protected long`	`received_msgs`
`protected long`	`sent_bytes`
`protected long`	`sent_msgs`
`protected Promise<StateTransferResult>`	`state_promise`
`protected boolean`	`state_transfer_supported` True if a state transfer protocol is available, false otherwise (set by CONFIG event from STATE_TRANSFER protocol)
`protected boolean`	`stats` Collect statistics

从类继承的字段 com.fr.third.jgroups.Channel
channel_listeners, discard_own_messages, log, receiver, socket_factory, state, up_handler

构造器概要

构造器
构造器和说明
`JChannel()` Constructs a `JChannel` instance with the protocol stack specified by the `DEFAULT_PROTOCOL_STACK` member.
`JChannel(boolean create_protocol_stack)` Creates a JChannel without a protocol stack; used for programmatic creation of channel and protocol stack
`JChannel(java.util.Collection<Protocol> protocols)` Creates a channel from an array of protocols.
`JChannel(org.w3c.dom.Element properties)` Constructs a JChannel instance with the protocol stack configuration contained by the specified XML element.
`JChannel(java.io.File properties)` Constructs a JChannel instance with the protocol stack configuration contained by the specified file.
`JChannel(java.io.InputStream input)` Creates a channel with a configuration based on an input stream.
`JChannel(JChannel ch)` Creates a channel with the same configuration as the channel passed to this constructor.
`JChannel(Protocol... protocols)` Creates a channel from an array of protocols.
`JChannel(ProtocolStackConfigurator configurator)` Constructs a JChannel with the protocol stack configuration contained by the protocol stack configurator parameter.
`JChannel(java.lang.String props)` Constructs a JChannel instance with the protocol stack configuration based upon the specified properties parameter.
`JChannel(java.net.URL properties)` Constructs a JChannel instance with the protocol stack configuration indicated by the specified URL.

方法概要

方法
限定符和类型	方法和说明
`protected void`	`_close(boolean disconnect)` Disconnects and closes the channel.
`protected void`	`_connect(Event connect_event)`
`protected boolean`	`_preConnect(java.lang.String cluster_name)`
`void`	`addAddressGenerator(AddressGenerator address_generator)` Sets the new `AddressGenerator`.
`protected void`	`checkClosed()` health check throws a ChannelClosed exception if the channel is closed
`protected void`	`checkClosedOrNotConnected()`
`void`	`close()` Destroys the channel and its associated resources (e.g., the protocol stack).
`void`	`connect(java.lang.String cluster_name)` Connects the channel to a group.
`void`	`connect(java.lang.String cluster_name, Address target, long timeout)` Connects this channel to a group and gets a state from a specified state provider.
`void`	`connect(java.lang.String cluster_name, Address target, long timeout, boolean useFlushIfPresent)` Connects this channel to a group and gets a state from a specified state provider.
`protected void`	`connect(java.lang.String cluster_name, boolean useFlushIfPresent)` Connects the channel to a group.
`void`	`disconnect()` Disconnects the channel if it is connected.
`java.lang.Object`	`down(Event evt)` Sends an event down the protocol stack.
`protected java.util.Map<java.lang.String,java.lang.Long>`	`dumpChannelStats()`
`java.util.Map<java.lang.String,java.lang.Object>`	`dumpStats()` Returns a map of statistics of the various protocols and of the channel itself.
`java.util.Map<java.lang.String,java.lang.Object>`	`dumpStats(java.lang.String protocol_name)`
`java.util.Map<java.lang.String,java.lang.Object>`	`dumpStats(java.lang.String protocol_name, java.util.List<java.lang.String> attrs)`
`java.lang.String`	`dumpTimerQueue()`
`void`	`enableStats(boolean stats)`
`boolean`	`flushSupported()`
`protected Address`	`generateAddress()`
`Address`	`getAddress()` Returns the channel's own address.
`java.lang.String`	`getAddressAsString()`
`java.lang.String`	`getAddressAsUUID()`
`AddressGenerator`	`getAddressGenerator()` 已过时。 Doesn't make any sense as there's list of address generators, will be removed in 4.0
`java.lang.String`	`getClusterName()` Returns the cluster name of the group of which the channel is a member.
`java.lang.String`	`getName()` Returns the logical name of this channel if set.
`java.lang.String`	`getName(Address member)` Returns the logical name of a given member.
`int`	`getNumberOfTasksInTimer()`
`java.lang.String`	`getProperties()` Returns the protocol stack configuration in string format.
`ProtocolStack`	`getProtocolStack()` Returns the protocol stack
`long`	`getReceivedBytes()`
`long`	`getReceivedMessages()`
`long`	`getSentBytes()`
`long`	`getSentMessages()`
`void`	`getState(Address target, long timeout)` Retrieves the full state from the target member.
`void`	`getState(Address target, long timeout, boolean useFlushIfPresent)` Retrieves state from the target member.
`protected void`	`getState(Address target, long timeout, java.util.concurrent.Callable<java.lang.Boolean> flushInvoker)`
`protected TimeScheduler`	`getTimer()`
`int`	`getTimerThreads()`
`static java.lang.String`	`getVersion()`
`View`	`getView()` Gets the current view.
`java.lang.String`	`getViewAsString()`
`protected void`	`init()` Initializes all variables.
`protected void`	`init(JChannel ch)`
`protected void`	`init(ProtocolStackConfigurator configurator)`
`protected java.lang.Object`	`invokeCallback(int type, java.lang.Object arg)`
`JChannel`	`name(java.lang.String name)` Names a channel, same as `Channel.setName(String)`
`java.lang.String`	`printProtocolSpec(boolean include_properties)` Returns a pretty-printed form of all the protocols.
`JChannel`	`receiver(Receiver r)`
`boolean`	`removeAddressGenerator(AddressGenerator address_generator)`
`void`	`resetStats()`
`void`	`send(Address dst, byte[] buf)` Sends a message.
`void`	`send(Address dst, byte[] buf, int offset, int length)` Sends a message to a destination.
`void`	`send(Address dst, java.lang.Object obj)` Helper method to create a Message with given parameters and invoke `Channel.send(Message)`.
`void`	`send(Message msg)` Sends a message.
`protected void`	`setAddress()` Generates new UUID and sets local address.
`void`	`setAddressGenerator(AddressGenerator address_generator)` 已过时。 Use `addAddressGenerator(AddressGenerator)` instead
`void`	`setName(java.lang.String name)` Sets the logical name for the channel.
`void`	`setProtocolStack(ProtocolStack stack)`
`void`	`startFlush(boolean automatic_resume)` Performs the flush of the cluster, ie. all pending application messages are flushed out of the cluster and all members ack their reception.
`void`	`startFlush(java.util.List<Address> flushParticipants, boolean automatic_resume)` Performs the flush of the cluster but only for the specified flush participants.
`protected void`	`startStack(java.lang.String cluster_name)`
`boolean`	`statsEnabled()`
`void`	`stopFlush()` Stops the current flush of the cluster.
`void`	`stopFlush(java.util.List<Address> flushParticipants)` Stops the current flush of the cluster for the specified flush participants.
`protected void`	`stopStack(boolean stop, boolean destroy)`
`java.lang.String`	`toString(boolean details)`
`java.lang.Object`	`up(Event evt)` Callback method Called by the ProtocolStack when a message is received.
`void`	`up(MessageBatch batch)` Callback invoked by the protocol stack to deliver a message batch

从类继承的方法 com.fr.third.jgroups.Channel
addChannelListener, clearChannelListeners, getDiscardOwnMessages, getReceiver, getSocketFactory, getState, getUpHandler, isClosed, isConnected, isConnecting, isOpen, notifyChannelClosed, notifyChannelConnected, notifyChannelDisconnected, removeChannelListener, setDiscardOwnMessages, setReceiver, setSocketFactory, setUpHandler

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 字段详细资料
  - DEFAULT_PROTOCOL_STACK
```
public static final java.lang.String DEFAULT_PROTOCOL_STACK
```
    The default protocol stack used by the default constructor
    
    另请参阅:
    常量字段值
  - local_addr
```
protected Address local_addr
```
  - address_generators
```
protected java.util.List<AddressGenerator> address_generators
```
  - name
```
protected java.lang.String name
```
  - cluster_name
```
protected java.lang.String cluster_name
```
  - my_view
```
protected View my_view
```
  - prot_stack
```
protected ProtocolStack prot_stack
```
  - state_promise
```
protected final Promise<StateTransferResult> state_promise
```
  - state_transfer_supported
```
protected boolean state_transfer_supported
```
    True if a state transfer protocol is available, false otherwise (set by CONFIG event from STATE_TRANSFER protocol)
  - flush_supported
```
protected volatile boolean flush_supported
```
    True if a flush protocol is available, false otherwise (set by CONFIG event from FLUSH protocol)
  - config
```
protected final java.util.concurrent.ConcurrentMap<java.lang.String,java.lang.Object> config
```
  - stats
```
protected boolean stats
```
    Collect statistics
  - sent_msgs
```
protected long sent_msgs
```
  - received_msgs
```
protected long received_msgs
```
  - sent_bytes
```
protected long sent_bytes
```
  - received_bytes
```
protected long received_bytes
```
  - probe_handler
```
protected final DiagnosticsHandler.ProbeHandler probe_handler
```
- 构造器详细资料
  - JChannel
```
public JChannel(boolean create_protocol_stack)
```
    Creates a JChannel without a protocol stack; used for programmatic creation of channel and protocol stack
    
    参数:
    create_protocol_stack - If true, the default configuration will be used. If false, no protocol stack will be created
    create_protocol_stack - Creates the default stack if true, or no stack if false
  - JChannel
```
public JChannel()
         throws java.lang.Exception
```
    Constructs a JChannel instance with the protocol stack specified by the DEFAULT_PROTOCOL_STACK member.
    
    抛出:
    
    java.lang.Exception - If problems occur during the initialization of the protocol stack.
  - JChannel
```
public JChannel(java.io.File properties)
         throws java.lang.Exception
```
    Constructs a JChannel instance with the protocol stack configuration contained by the specified file.
    
    参数:
    properties - A file containing a JGroups XML protocol stack configuration.
    
    抛出:
    
    java.lang.Exception - If problems occur during the configuration or initialization of the protocol stack.
  - JChannel
```
public JChannel(org.w3c.dom.Element properties)
         throws java.lang.Exception
```
    Constructs a JChannel instance with the protocol stack configuration contained by the specified XML element.
    
    参数:
    properties - An XML element containing a JGroups XML protocol stack configuration.
    
    抛出:
    
    java.lang.Exception - If problems occur during the configuration or initialization of the protocol stack.
  - JChannel
```
public JChannel(java.net.URL properties)
         throws java.lang.Exception
```
    Constructs a JChannel instance with the protocol stack configuration indicated by the specified URL.
    
    参数:
    properties - A URL pointing to a JGroups XML protocol stack configuration.
    
    抛出:
    
    java.lang.Exception - If problems occur during the configuration or initialization of the protocol stack.
  - JChannel
```
public JChannel(java.lang.String props)
         throws java.lang.Exception
```
    Constructs a JChannel instance with the protocol stack configuration based upon the specified properties parameter.
    
    参数:
    props - A file containing a JGroups XML configuration, a URL pointing to an XML configuration, or an old style plain configuration string.
    
    抛出:
    
    java.lang.Exception - If problems occur during the configuration or initialization of the protocol stack.
  - JChannel
```
public JChannel(java.io.InputStream input)
         throws java.lang.Exception
```
    Creates a channel with a configuration based on an input stream.
    
    参数:
    input - An input stream, pointing to a streamed configuration
    
    抛出:
    
    java.lang.Exception
  - JChannel
```
public JChannel(ProtocolStackConfigurator configurator)
         throws java.lang.Exception
```
    Constructs a JChannel with the protocol stack configuration contained by the protocol stack configurator parameter.
    All of the public constructors of this class eventually delegate to this method.
    
    参数:
    configurator - A protocol stack configurator containing a JGroups protocol stack configuration.
    
    抛出:
    
    java.lang.Exception - If problems occur during the initialization of the protocol stack.
  - JChannel
```
public JChannel(Protocol... protocols)
         throws java.lang.Exception
```
    Creates a channel from an array of protocols. Note that after a close(), the protocol list should not be reused, ie. new JChannel(protocols) would reuse the same protocol list, and this might lead to problems !
    
    参数:
    protocols - The list of protocols, from bottom to top, ie. the first protocol in the list is the transport, the last the top protocol
    
    抛出:
    
    java.lang.Exception
  - JChannel
```
public JChannel(java.util.Collection<Protocol> protocols)
         throws java.lang.Exception
```
    Creates a channel from an array of protocols. Note that after a close(), the protocol list should not be reused, ie. new JChannel(protocols) would reuse the same protocol list, and this might lead to problems !
    
    参数:
    protocols - The list of protocols, from bottom to top, ie. the first protocol in the list is the transport, the last the top protocol
    
    抛出:
    
    java.lang.Exception
  - JChannel
```
public JChannel(JChannel ch)
         throws java.lang.Exception
```
    Creates a channel with the same configuration as the channel passed to this constructor. This is used by testing code, and should not be used by clients !
    
    参数:
    ch -
    
    抛出:
    
    java.lang.Exception
- 方法详细资料
  - getProtocolStack
```
public ProtocolStack getProtocolStack()
```
    Returns the protocol stack
    
    指定者:
    
    getProtocolStack 在类中 Channel
  - setProtocolStack
```
public void setProtocolStack(ProtocolStack stack)
```
  - getProperties
```
public java.lang.String getProperties()
```
    Returns the protocol stack configuration in string format. An example of this property is
    "UDP:PING:FD:STABLE:NAKACK:UNICAST:FRAG:FLUSH:GMS:VIEW_ENFORCER:STATE_TRANSFER:QUEUE"
    
    覆盖:
    
    getProperties 在类中 Channel
  - statsEnabled
```
public boolean statsEnabled()
```
  - enableStats
```
public void enableStats(boolean stats)
```
  - resetStats
```
public void resetStats()
```
  - getSentMessages
```
public long getSentMessages()
```
  - getSentBytes
```
public long getSentBytes()
```
  - getReceivedMessages
```
public long getReceivedMessages()
```
  - getReceivedBytes
```
public long getReceivedBytes()
```
  - getNumberOfTasksInTimer
```
public int getNumberOfTasksInTimer()
```
  - getTimerThreads
```
public int getTimerThreads()
```
  - dumpTimerQueue
```
public java.lang.String dumpTimerQueue()
```
  - printProtocolSpec
```
public java.lang.String printProtocolSpec(boolean include_properties)
```
    Returns a pretty-printed form of all the protocols. If include_properties is set, the properties for each protocol will also be printed.
  - connect
```
public void connect(java.lang.String cluster_name)
             throws java.lang.Exception
```
    从类复制的说明: Channel
    
    Connects the channel to a group. The client is now able to receive group messages, views and to send messages to (all or single) group members. This is a null operation if already connected.
    
    All channels with the same name form a group, that means all messages sent to the group will be received by all channels connected to the same cluster name.
    
    指定者:
    
    connect 在类中 Channel
    
    参数:
    cluster_name - The name of the channel to connect to.
    
    抛出:
    
    java.lang.Exception - The protocol stack cannot be started
    
    java.lang.IllegalStateException - The channel is closed
  - connect
```
protected void connect(java.lang.String cluster_name,
           boolean useFlushIfPresent)
                throws java.lang.Exception
```
    Connects the channel to a group.
    
    抛出:
    
    java.lang.Exception
    另请参阅:
    connect(String)
  - connect
```
public void connect(java.lang.String cluster_name,
           Address target,
           long timeout)
             throws java.lang.Exception
```
    从类复制的说明: Channel
    
    Connects this channel to a group and gets a state from a specified state provider.
    
    This method essentially invokes connect and getState methods successively. If FLUSH protocol is in channel's stack definition only one flush is executed for both connecting and fetching state rather than two flushes if we invoke connect and getState in succession.
    If the channel is closed an exception will be thrown.
    指定者: connect 在类中 Channel 参数: cluster_name - the cluster name to connect to. Cannot be null. target - the state provider. If null state will be fetched from coordinator, unless this channel is coordinator. timeout - the timeout for state transfer. 抛出: java.lang.Exception - Connecting to the cluster or state transfer was not successful java.lang.IllegalStateException - The channel is closed and therefore cannot be used
  connect public void connect(java.lang.String cluster_name, Address target, long timeout, boolean useFlushIfPresent) throws java.lang.Exception Connects this channel to a group and gets a state from a specified state provider. This method invokes connect() and then getState. If the FLUSH protocol is in the channel's stack definition, only one flush round is executed for both connecting and fetching the state rather than two flushes if we invoke connect and getState in succession. If the channel is already connected, an error message will be printed to the error log. If the channel is closed a ChannelClosed exception will be thrown. 参数: cluster_name - The cluster name to connect to. Cannot be null. target - The state provider. If null, the state will be fetched from the coordinator, unless this channel is the coordinator. timeout - The timeout for the state transfer. 抛出: java.lang.Exception - The protocol stack cannot be started, or the JOIN failed java.lang.IllegalStateException - The channel is closed or disconnected StateTransferException - State transfer was not successful disconnect public void disconnect() 从类复制的说明: Channel Disconnects the channel if it is connected. If the channel is closed or disconnected, this operation is ignored The channel can then be connected to the same or a different cluster again. 指定者: disconnect 在类中 Channel 另请参阅: Channel.connect(String) close public void close() 从类复制的说明: Channel Destroys the channel and its associated resources (e.g., the protocol stack). After a channel has been closed, invoking methods on it throws the ChannelClosed exception (or results in a null operation). It is a null operation if the channel is already closed. If the channel is connected to a group, disconnect() will be called first. 指定者: close 在接口中 java.io.Closeable 指定者: close 在接口中 java.lang.AutoCloseable 指定者: close 在类中 Channel dumpStats public java.util.Map<java.lang.String,java.lang.Object> dumpStats() 从类复制的说明: Channel Returns a map of statistics of the various protocols and of the channel itself. 指定者: dumpStats 在类中 Channel 返回: Map. A map where the keys are the protocols ("channel" pseudo key is used for the channel itself") and the values are property maps. dumpStats public java.util.Map<java.lang.String,java.lang.Object> dumpStats(java.lang.String protocol_name, java.util.List<java.lang.String> attrs) dumpStats public java.util.Map<java.lang.String,java.lang.Object> dumpStats(java.lang.String protocol_name) dumpChannelStats protected java.util.Map<java.lang.String,java.lang.Long> dumpChannelStats() send public void send(Message msg) throws java.lang.Exception 从类复制的说明: Channel Sends a message. The message contains a destination address (Address). A null address sends the message to all group members. a source address. Can be left empty as it will be assigned automatically a byte buffer. The message contents. several additional fields. They can be used by application programs (or patterns). E.g. a message ID, flags etc 指定者: send 在类中 Channel 参数: msg - The message to be sent. Destination and buffer should be set. A null destination means to send to all group members. 抛出: java.lang.IllegalStateException - thrown if the channel is disconnected or closed java.lang.Exception send public void send(Address dst, java.lang.Object obj) throws java.lang.Exception 从类复制的说明: Channel Helper method to create a Message with given parameters and invoke Channel.send(Message). 指定者: send 在类中 Channel 参数: dst - Destination address for message. If null, message will be sent to all current group members obj - A serializable object. Will be marshalled into the byte buffer of the Message. If it is not serializable, an exception will be thrown 抛出: java.lang.Exception - exception thrown if message sending was not successful send public void send(Address dst, byte[] buf) throws java.lang.Exception 从类复制的说明: Channel Sends a message. See Channel.send(Address, byte[], int, int) for details 指定者: send 在类中 Channel 参数: dst - destination address for message. If null, message will be sent to all current group members buf - buffer message payload 抛出: java.lang.Exception - exception thrown if message sending was not successful send public void send(Address dst, byte[] buf, int offset, int length) throws java.lang.Exception 从类复制的说明: Channel Sends a message to a destination. 指定者: send 在类中 Channel 参数: dst - The destination address. If null, the message will be sent to all cluster nodes (= group members) buf - The buffer to be sent offset - The offset into the buffer length - The length of the data to be sent. Has to be <= buf.length - offset. This will send length bytes starting at offset 抛出: java.lang.Exception - If send() failed getView public View getView() 从类复制的说明: Channel Gets the current view. The view may only be available after a successful connect(). The result of calling this method on an unconnected channel is implementation defined (may return null). Calling this method on a closed channel returns a null view. 指定者: getView 在类中 Channel 返回: The current view. getViewAsString public java.lang.String getViewAsString() getVersion public static java.lang.String getVersion() getAddress public Address getAddress() 从类复制的说明: Channel Returns the channel's own address. The result of calling this method on an unconnected channel is implementation defined (may return null). Calling this method on a closed channel returns null. Addresses can be used as destination in the send() operation. 指定者: getAddress 在类中 Channel 返回: The channel's address (opaque) getAddressAsString public java.lang.String getAddressAsString() getAddressAsUUID public java.lang.String getAddressAsUUID() getName public java.lang.String getName() 从类复制的说明: Channel Returns the logical name of this channel if set. 指定者: getName 在类中 Channel 返回: The logical name or null (if not set) getName public java.lang.String getName(Address member) 从类复制的说明: Channel Returns the logical name of a given member. The lookup is from the local cache of logical address / logical name mappings and no remote communication is performed. 指定者: getName 在类中 Channel 返回: The logical name for member setName public void setName(java.lang.String name) 从类复制的说明: Channel Sets the logical name for the channel. The name will stay associated with this channel for the channel's lifetime (until close() is called). This method should be called before calling connect(). 指定者: setName 在类中 Channel name public JChannel name(java.lang.String name) 从类复制的说明: Channel Names a channel, same as Channel.setName(String) 指定者: name 在类中 Channel receiver public JChannel receiver(Receiver r) getClusterName public java.lang.String getClusterName() 从类复制的说明: Channel Returns the cluster name of the group of which the channel is a member. This is the object that was the argument to connect(). Calling this method on a closed channel returns null. 指定者: getClusterName 在类中 Channel 返回: The cluster name getAddressGenerator @Deprecated public AddressGenerator getAddressGenerator() 已过时。 Doesn't make any sense as there's list of address generators, will be removed in 4.0 Returns the first AddressGenerator in the list, or null if none is set 返回: 从以下版本开始: 2.12 setAddressGenerator @Deprecated public void setAddressGenerator(AddressGenerator address_generator) 已过时。 Use addAddressGenerator(AddressGenerator) instead addAddressGenerator public void addAddressGenerator(AddressGenerator address_generator) Sets the new AddressGenerator. New addresses will be generated using the new generator. This should not be done while a channel is connected, but before connecting. 参数: address_generator - 从以下版本开始: 2.12 removeAddressGenerator public boolean removeAddressGenerator(AddressGenerator address_generator) getState public void getState(Address target, long timeout) throws java.lang.Exception 从类复制的说明: Channel Retrieves the full state from the target member. State transfer is initiated by invoking getState on this channel. The state provider in turn invokes MessageListener.getState(java.io.OutputStream) callback and sends a state to this node, the state receiver. After the state arrives to the state receiver MessageListener.setState(java.io.InputStream) callback is invoked to install the state. 指定者: getState 在类中 Channel 参数: target - The state provider. If null the coordinator is used by default timeout - The number of milliseconds to wait for the operation to complete successfully. 0 waits until the state has been received 抛出: java.lang.IllegalStateException - The channel was closed or disconnected, or the flush (if present) failed StateTransferException - raised if there was a problem during the state transfer java.lang.Exception 另请参阅: MessageListener.getState(java.io.OutputStream), MessageListener.setState(java.io.InputStream) getState public void getState(Address target, long timeout, boolean useFlushIfPresent) throws java.lang.Exception Retrieves state from the target member. See getState(Address, long) for details. 抛出: java.lang.Exception _preConnect protected boolean _preConnect(java.lang.String cluster_name) throws java.lang.Exception 抛出: java.lang.Exception _connect protected void _connect(Event connect_event) throws java.lang.Exception 抛出: java.lang.Exception getState protected void getState(Address target, long timeout, java.util.concurrent.Callable<java.lang.Boolean> flushInvoker) throws java.lang.Exception 抛出: java.lang.Exception up public java.lang.Object up(Event evt) Callback method Called by the ProtocolStack when a message is received. 参数: evt - the event carrying the message from the protocol stack up public void up(MessageBatch batch) Callback invoked by the protocol stack to deliver a message batch down public java.lang.Object down(Event evt) Sends an event down the protocol stack. Note that - contrary to send(Message), if the event is a message, no checks are performed whether the channel is closed or disconnected. 覆盖: down 在类中 Channel 参数: evt - the message to send down, encapsulated in an event 返回: a response from a particular protocol layer targeted by Event parameter toString public java.lang.String toString(boolean details) invokeCallback protected java.lang.Object invokeCallback(int type, java.lang.Object arg) init protected final void init(ProtocolStackConfigurator configurator) throws java.lang.Exception 抛出: java.lang.Exception init protected final void init(JChannel ch) throws java.lang.Exception 抛出: java.lang.Exception init protected void init() Initializes all variables. Used after close() or disconnect(), to be ready for new connect() startStack protected void startStack(java.lang.String cluster_name) throws java.lang.Exception 抛出: java.lang.Exception setAddress protected void setAddress() Generates new UUID and sets local address. Sends down a REMOVE_ADDRESS (if existing address was present) and a SET_LOCAL_ADDRESS generateAddress protected Address generateAddress() checkClosed protected void checkClosed() health check throws a ChannelClosed exception if the channel is closed checkClosedOrNotConnected protected void checkClosedOrNotConnected() _close protected void _close(boolean disconnect) Disconnects and closes the channel. This method does the following things Calls this.disconnect if the disconnect parameter is true Calls ProtocolStack.stop on the protocol stack Calls ProtocolStack.destroy on the protocol stack Sets the channel closed and channel connected flags to true and false Notifies any channel listener of the channel close operation stopStack protected void stopStack(boolean stop, boolean destroy) flushSupported public boolean flushSupported() 指定者: flushSupported 在类中 Channel startFlush public void startFlush(boolean automatic_resume) throws java.lang.Exception 从类复制的说明: Channel Performs the flush of the cluster, ie. all pending application messages are flushed out of the cluster and all members ack their reception. After this call returns, no member will be allowed to send any messages until Channel.stopFlush() is called. In the case of flush collisions (another member attempts flush at roughly the same time) start flush will fail by throwing an Exception. Applications can re-attempt flushing after certain back-off period. JGroups provides a helper random sleep time backoff algorithm for flush using Util class. 指定者: startFlush 在类中 Channel 参数: automatic_resume - if true call Channel.stopFlush() after the flush 抛出: java.lang.Exception 另请参阅: Util.startFlush(Channel, List, int, long, long) startFlush public void startFlush(java.util.List<Address> flushParticipants, boolean automatic_resume) throws java.lang.Exception 从类复制的说明: Channel Performs the flush of the cluster but only for the specified flush participants. All pending messages are flushed out but only for the flush participants. The remaining members in the cluster are not included in the flush. The list of flush participants should be a proper subset of the current view. If this flush is not automatically resumed it is an obligation of the application to invoke the matching Channel.stopFlush(List) method with the same list of members used in Channel.startFlush(List, boolean). 指定者: startFlush 在类中 Channel automatic_resume - if true call Channel.stopFlush() after the flush 抛出: java.lang.Exception 另请参阅: Channel.startFlush(boolean), Util.startFlush(Channel, List, int, long, long) stopFlush public void stopFlush() 从类复制的说明: Channel Stops the current flush of the cluster. Cluster members are unblocked and allowed to send new and pending messages. 指定者: stopFlush 在类中 Channel 另请参阅: Channel.startFlush(boolean), Channel.startFlush(List, boolean) stopFlush public void stopFlush(java.util.List<Address> flushParticipants) 从类复制的说明: Channel Stops the current flush of the cluster for the specified flush participants. Flush participants are unblocked and allowed to send new and pending messages. It is an obligation of the application to invoke the matching Channel.startFlush(List, boolean) method with the same list of members prior to invocation of this method. 指定者: stopFlush 在类中 Channel 参数: flushParticipants - the flush participants getTimer protected TimeScheduler getTimer()

类 JChannel

嵌套类概要

从类继承的嵌套类/接口 com.fr.third.jgroups.Channel

字段概要

从类继承的字段 com.fr.third.jgroups.Channel

构造器概要

方法概要

从类继承的方法 com.fr.third.jgroups.Channel

从类继承的方法 java.lang.Object

字段详细资料

DEFAULT_PROTOCOL_STACK

local_addr

address_generators

name

cluster_name

my_view

prot_stack

state_promise

state_transfer_supported

flush_supported

config

stats

sent_msgs

received_msgs

sent_bytes

received_bytes

probe_handler

构造器详细资料

JChannel

JChannel

JChannel

JChannel

JChannel

JChannel

JChannel

JChannel

JChannel

JChannel

JChannel

方法详细资料

getProtocolStack

setProtocolStack

getProperties

statsEnabled

enableStats

resetStats

getSentMessages

getSentBytes

getReceivedMessages

getReceivedBytes

getNumberOfTasksInTimer

getTimerThreads

dumpTimerQueue

printProtocolSpec

connect

connect

connect

connect

disconnect

close

dumpStats

dumpStats

dumpStats

dumpChannelStats

send

send

send

send

getView

getViewAsString

getVersion

getAddress

getAddressAsString

getAddressAsUUID

getName

getName

setName

name

receiver

getClusterName