| 程序包 | 说明 |
|---|---|
| com.fr.ehcache.cluster | |
| 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.demos.wb |
A distributed whiteboard applet implemented using JGroups.
|
| 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.relay | |
| com.fr.third.jgroups.tests | |
| com.fr.third.jgroups.tests.perf | |
| com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
JGroupsCacheReceiver
Handles
Receiver functions around for a CacheManager
消息接受处理Receiver |
| 限定符和类型 | 接口和说明 |
|---|---|
interface |
Receiver
Defines the callbacks that are invoked when messages, views etc are received on a channel
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
ReceiverAdapter
An adapter implementing the Receiver interface with no-op implementations.
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
PartitionedHashMap<K,V>
Hashmap which distributes its keys and values across the cluster.
|
static class |
PartitionedHashMap.ConsistentHashFunction<K> |
class |
ReplCache<K,V>
Cache which allows for replication factors per data items; the factor determines how many replicas
of a key/value we create across the cluster.
|
class |
ReplicatedHashMap<K,V>
Implementation of a
ConcurrentMap with replication of the contents across a cluster. |
class |
ReplicatedTree
A tree-like structure that is replicated across several members.
|
| 限定符和类型 | 字段和说明 |
|---|---|
protected MembershipListener |
MessageDispatcher.membership_listener |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
ReplCache.addMembershipListener(MembershipListener l) |
void |
PartitionedHashMap.addMembershipListener(MembershipListener l) |
void |
ReplCache.removeMembershipListener(MembershipListener l) |
void |
PartitionedHashMap.removeMembershipListener(MembershipListener l) |
void |
MessageDispatcher.setMembershipListener(MembershipListener l) |
| 构造器和说明 |
|---|
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2) |
MessageDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
RequestHandler req_handler) |
RpcDispatcher(Channel channel,
MessageListener l,
MembershipListener l2,
java.lang.Object server_obj) |
| 构造器和说明 |
|---|
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) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
Chat |
class |
Draw
Shared whiteboard, each new instance joins the same group.
|
class |
QuoteClient
Used in conjunction with QuoteServer: a client is member of a group of quote servers which replicate
stock quotes among themselves.
|
class |
QuoteServer
Example of a replicated quote server.
|
class |
RelayDemoRpc
Demos RELAY.
|
class |
ViewDemo
Demos the reception of views using a PullPushAdapter.
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
Whiteboard
Shared whiteboard: members are represented by rectangles that contain their names and the OS/arch of
the machine they are working on.
|
| 限定符和类型 | 类和说明 |
|---|---|
protected class |
RELAY.Receiver |
| 限定符和类型 | 类和说明 |
|---|---|
protected class |
Relayer.Bridge |
| 限定符和类型 | 类和说明 |
|---|---|
class |
FlowControlTest
Interactive test for MFC and UFC
|
class |
LargeState
Tests transfer of large states.
|
class |
MessageDispatcherSpeedTest |
class |
PingPong
Simple protocol to test round trip times.
|
class |
RoundTrip
Class that measure RTT between a client and server
|
class |
RoundTripMulticast
Class that measure RTT between a client and server using multicast sockets
|
class |
RpcDispatcherBlocking
Tests synchronous group RPCs. 2 main test cases:
Member crashes during invocation of sync group RPC: start 3 instances (A,
B,C), set the timeout to be 30 seconds.
|
class |
RpcDispatcherSpeedTest
Test for measuring performance of group RPCs.
|
protected class |
UnicastTest.MyReceiver |
class |
UnicastTestRpc
Tests performance of unicast RPCs between a caller and a recipient
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
MPerf
Dynamic tool to measure multicast performance of JGroups; every member sends N messages and we measure how long it
takes for all receivers to receive them.
|
class |
MPerfRpc
Dynamic tool to measure multicast RPC performance of JGroups; every member invokes N RPCs and we measure how long it
takes for all receivers to receive them.
|
class |
UPerf
Tests the UNICAST by invoking unicast RPCs between a sender and a receiver.
|
class |
UUPerf
Tests the UNICAST by invoking unicast RPCs from all the nodes to a single node.
|
| 限定符和类型 | 类和说明 |
|---|---|
class |
MyReceiver<T>
Generic receiver for a JChannel
|