接口 com.fr.third.jgroups.util.Streamable
的使用

使用Streamable的程序包

程序包	说明
com.fr.cluster.engine.core.jchannel
com.fr.third.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
com.fr.third.jgroups.auth
com.fr.third.jgroups.blocks	Provides building blocks that are layered on top of channels.
com.fr.third.jgroups.blocks.executor
com.fr.third.jgroups.blocks.mux
com.fr.third.jgroups.demos	Provides demonstrations of JGroups functionality.
com.fr.third.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
com.fr.third.jgroups.protocols.pbcast	Supports probabilistic broadcasts.
com.fr.third.jgroups.protocols.relay
com.fr.third.jgroups.protocols.tom
com.fr.third.jgroups.stack	Support for managing protocol stacks.
com.fr.third.jgroups.tests.perf
com.fr.third.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

com.fr.cluster.engine.core.jchannel中Streamable的使用

实现Streamable的com.fr.cluster.engine.core.jchannel中的类

限定符和类型	类和说明
class	MachineMarker Created by juhaoyu on 2018/1/16.

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

com.fr.third.jgroups中Streamable的子接口

限定符和类型	接口和说明
interface	Address Address identifies cluster member.
interface	PhysicalAddress Represents a physical (as opposed to logical) address

实现Streamable的com.fr.third.jgroups中的类

限定符和类型	类和说明
class	AnycastAddress This type of address represents a subset of the cluster members in which the total order properties must be applied, e.g. if the cluster membership is {A,B,C,D,E}, an AnycastAddress could be {D,E}.
class	Header Header is a JGroups internal base class for all JGroups headers.
class	MergeView A view that is sent as a result of a cluster merge.
class	Message A Message encapsulates data sent to members of a group.
class	View A view is a local representation of the current membership of a group.
class	ViewId ViewIds are used for ordering views (each view has a ViewId and a list of members).

com.fr.third.jgroups.auth中Streamable的使用

实现Streamable的com.fr.third.jgroups.auth中的类

限定符和类型	类和说明
class	AuthToken Abstract AuthToken class used by implementations of AUTH, e.g.
class	DemoToken AuthToken implementation which shows how to send messages back and forth in order to perform authentication.
static class	DemoToken.DemoHeader
class	FixedMembershipToken The FixedMemberShipToken object predefines a list of IP addresses and ports that can join the group.
class	Krb5Token JGroups AuthToken Class to for Kerberos v5 authentication.
class	MD5Token This is an example of using a preshared token that is encrypted using an MD5/SHA hash for authentication purposes.
class	RegexMembership Matches the IP address or logical name of a joiner against a regular expression and accepts or rejects based on pattern matching
class	SimpleToken This is an example of using a preshared token for authentication purposes.
class	X509Token This is an example of using a preshared token that is encrypted using an X509 certificate for authentication purposes.

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

实现Streamable的com.fr.third.jgroups.blocks中的类

限定符和类型	类和说明
static class	GridFile.Metadata
class	MethodCall A method call is the JGroups representation of a remote method.
static class	RequestCorrelator.Header The header for RequestCorrelator messages
static class	RequestCorrelator.MultiDestinationHeader

com.fr.third.jgroups.blocks.executor中Streamable的使用

实现Streamable的com.fr.third.jgroups.blocks.executor中的类

限定符和类型	类和说明
protected static class	Executions.StreamableCallable
protected static class	ExecutionService.RunnableAdapter<T> This is copied from Executors class which contains RunnableAdapter.

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

实现Streamable的com.fr.third.jgroups.blocks.mux中的类

限定符和类型	类和说明
class	MuxHeader Header that identifies the target handler for multiplexed dispatches.

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

实现Streamable的com.fr.third.jgroups.demos中的类

限定符和类型	类和说明
class	DrawCommand Encapsulates information about a draw command.
protected static class	ExecutionServiceDemo.ByteBufferStreamable
static class	ExecutionServiceDemo.SortingByteCallable
static class	ExecutionServiceDemo.SortingTwoByteCallable Sorts 2 byte arrys into a larger byte array

com.fr.third.jgroups.protocols中Streamable的使用

实现Streamable的com.fr.third.jgroups.protocols中的类

限定符和类型	类和说明
class	AuthHeader AuthHeader is a holder object for the token that is passed from the joiner to the coordinator
static class	COMPRESS.CompressHeader
protected static class	COUNTER.AddAndGetRequest
protected static class	COUNTER.BooleanResponse
protected static class	COUNTER.CompareAndSetRequest
static class	COUNTER.CounterHeader
protected static class	COUNTER.DeleteRequest
protected static class	COUNTER.ExceptionResponse
protected static class	COUNTER.GetOrCreateRequest
protected static class	COUNTER.GetOrCreateResponse
protected static class	COUNTER.ReconcileRequest
protected static class	COUNTER.ReconcileResponse
protected static class	COUNTER.Request
protected static class	COUNTER.ResendPendingRequests
protected static class	COUNTER.Response
protected static class	COUNTER.SetRequest
protected static class	COUNTER.SimpleRequest
protected static class	COUNTER.SimpleResponse Response without data
protected static class	COUNTER.UpdateRequest
protected static class	COUNTER.ValueResponse
static class	DAISYCHAIN.DaisyHeader
static class	ENCRYPT.EncryptHeader
static class	EXAMPLE.ExampleHeader
static class	Executing.ExecutorHeader
protected static class	Executing.Request
protected static class	Executing.RequestWithThread
class	FcHeader Header used by various flow control protocols
static class	FD_ALL.HeartbeatHeader
static class	FD_ALL2.HeartbeatHeader
static class	FD_SOCK.FdHeader
static class	FD.FdHeader
static class	FORK.ForkHeader
protected static class	FORWARD_TO_COORD.ForwardHeader
class	FragHeader
static class	Locking.LockingHeader
protected static class	Locking.Request
protected static class	MERGE2.MergeHeader 已过时。
static class	MERGE3.MergeHeader
protected static class	PDC.Mapping
protected static class	PERF.PerfHeader
class	PingData Encapsulates information about a cluster node, e.g. local address, coordinator's address, logical name and physical address(es)
class	PingHeader
class	PrioHeader This Header class is used in conjunction with the PRIO protocol to prioritize message sending/receiving Priority values are from 0 to 255 where 0 is the highest priority Example of setting a message priority: // Create a message to send to everyone Message message = new Message( null, null, messagePayload ); // Add the priority protocol header PrioHeader header = new PrioHeader( 1 ); short protocolId = ClassConfigurator.getProtocolId(PRIO.class); message.putHeader( protocolId, header);
static class	RELAY.RelayHeader
protected static class	RELAY.ViewData Contains local and remote views, and UUID information
protected static class	RSVP.RsvpHeader
class	SaslHeader
static class	SCOPE.ScopeHeader 已过时。
static class	SEQUENCER.SequencerHeader
static class	SEQUENCER2.SequencerHeader
static class	STOMP.StompHeader
class	TpHeader Generic transport header, used by TP.
static class	UNICAST.UnicastHeader The following types and fields are serialized: | DATA | seqno | conn_id | first | | ACK | seqno | | SEND_FIRST_SEQNO |
static class	UNICAST2.Unicast2Header The following types and fields are serialized: | DATA | seqno | conn_id | first | | ACK | seqno | | SEND_FIRST_SEQNO | seqno |
static class	UNICAST3.Header The following types and fields are serialized: | DATA | seqno | conn_id | first | | ACK | seqno | timestamp | | SEND_FIRST_SEQNO | timestamp | | CLOSE | conn_id |
static class	VERIFY_SUSPECT.VerifyHeader

返回Streamable的com.fr.third.jgroups.protocols中的方法

限定符和类型	方法和说明
protected static Streamable	COUNTER.streamableFromBuffer(byte[] buf, int offset, int length)

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

限定符和类型	方法和说明
protected static Buffer	COUNTER.streamableToBuffer(byte req_or_rsp, byte type, Streamable obj)

com.fr.third.jgroups.protocols.pbcast中Streamable的使用

实现Streamable的com.fr.third.jgroups.protocols.pbcast中的类

限定符和类型	类和说明
class	DeltaView Subclass of View with a null members field.
static class	FLUSH.FlushHeader
static class	GMS.GmsHeader
class	JoinRsp Result of a JOIN request (sent by the GMS client).
class	NakAckHeader
class	NakAckHeader2
static class	STABLE.StableHeader
static class	STATE_TRANSFER.StateHeader Wraps data for a state request/response.
static class	StreamingStateTransfer.StateHeader

com.fr.third.jgroups.protocols.relay中Streamable的使用

com.fr.third.jgroups.protocols.relay中Streamable的子接口

限定符和类型	接口和说明
interface	SiteAddress Address with a site suffix

实现Streamable的com.fr.third.jgroups.protocols.relay中的类

限定符和类型	类和说明
class	CanBeSiteMaster 已过时。 Use ExtendedUUID directly. This class will get dropped in 4.0.
class	CanBeSiteMasterTopology 已过时。 Use ExtendedUUID instead. This class will get dropped in 4.0.
static class	RELAY2.Relay2Header
class	SiteMaster Special address with the UUID part being 0: identifies the current (relay) coordinator of a given site.
class	SiteUUID Implementation of SiteAddress

com.fr.third.jgroups.protocols.tom中Streamable的使用

实现Streamable的com.fr.third.jgroups.protocols.tom中的类

限定符和类型	类和说明
class	MessageID The represents an unique identifier for the messages processed by the Total Order Anycast protocol Note: it is similar to the ViewId (address + counter)
class	ToaHeader The header for the Total Order Anycast (TOA) protocol

com.fr.third.jgroups.stack中Streamable的使用

实现Streamable的com.fr.third.jgroups.stack中的类

限定符和类型	类和说明
class	GossipData Encapsulates data sent between GossipRouter and GossipClient
class	IpAddress Network-dependent address (Internet).

com.fr.third.jgroups.tests.perf中Streamable的使用

实现Streamable的com.fr.third.jgroups.tests.perf中的类

限定符和类型	类和说明
protected static class	MPerf.ConfigChange
protected static class	MPerf.Configuration
protected static class	MPerf.MPerfHeader
protected static class	MPerf.Result
protected static class	MPerfRpc.ConfigChange
protected static class	MPerfRpc.Configuration
protected static class	MPerfRpc.Result
static class	UPerf.Config
static class	UPerf.Results
static class	UUPerf.ConfigOptions
static class	UUPerf.Results

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

com.fr.third.jgroups.util中Streamable的子接口

限定符和类型	接口和说明
interface	SizeStreamable Interface implementing Streamable and returning the size of the marshalled object.

实现Streamable的com.fr.third.jgroups.util中的类

限定符和类型	类和说明
class	AdditionalDataUUID 已过时。 Use ExtendedUUID instead. Will get dropped in 4.0.
class	Digest A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).
class	ExtendedUUID Subclass of UUID accommodating additional data such as a flag and a small hashmap.
class	MergeId ID to uniquely identify a merge
class	MutableDigest A mutable version of Digest.
class	Owner Represents an 'owner', which is an address and thread ID
class	PayloadUUID 已过时。 Use ExtendedUUID instead. Will get dropped in 4.0.
class	Range
class	SeqnoList A list of sequence numbers (seqnos).
class	SingletonAddress Address with a cluster name.
class	TopologyUUID 已过时。 Use ExtendedUUID instead. This class will be dropped in 4.0.
class	UUID Logical address which is unique over space and time.

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

限定符和类型	方法和说明
static <T extends Streamable> T	Util.streamableFromBuffer(java.lang.Class<T> clazz, byte[] buffer, int offset, int length)
static <T extends Streamable> Streamable	Util.streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl, byte[] buffer, int offset, int length)

返回Streamable的com.fr.third.jgroups.util中的方法

限定符和类型	方法和说明
static Streamable	Util.readGenericStreamable(java.io.DataInput in)
static Streamable	Util.readGenericStreamable(java.io.DataInput in, java.lang.ClassLoader loader)
static Streamable	Util.readStreamable(java.lang.Class clazz, java.io.DataInput in)
static Streamable	Util.streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl, byte[] buffer)
static <T extends Streamable> Streamable	Util.streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl, byte[] buffer, int offset, int length)

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

限定符和类型	方法和说明
static Buffer	Util.streamableToBuffer(Streamable obj)
static byte[]	Util.streamableToByteBuffer(Streamable obj)
static void	Util.writeGenericStreamable(Streamable obj, java.io.DataOutput out)
static void	Util.writeStreamable(Streamable obj, java.io.DataOutput out)

类型变量类型为Streamable的com.fr.third.jgroups.util中的方法参数

限定符和类型	方法和说明
static Streamable	Util.streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl, byte[] buffer)
static <T extends Streamable> Streamable	Util.streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl, byte[] buffer, int offset, int length)