Reliable Multicasting with the JGroups Toolkit
   Next

Reliable Multicasting with the JGroups Toolkit

Bela Ban

JGroups Project


                        
                    

Copyright © 1998-2006 Bela Ban

Copyright © 2006-2011 Red Hat Inc

This document is licensed under the Creative Commons Attribution-ShareAlike (CC-BY-SA) 3.0

Jan 2011

Table of Contents

Foreword
Acknowledgments
1. Overview
1.1. Channel
1.2. Building Blocks
1.3. The Protocol Stack
1.4. Header
1.5. Event
2. Installation and Configuration
2.1. Requirements
2.2. Installing the binary distribution
2.3. Installing the source distribution
2.4. Building JGroups (source distribution only)
2.5. Testing your Setup
2.6. Running a Demo Program
2.7. Using IP Multicasting without a network connection
2.8. It doesn't work !
2.9. The instances still don't find each other !
2.10. Problems with IPv6
2.11. Wiki
2.12. I have discovered a bug !
2.13. Supported classes
2.13.1. Experimental
2.13.2. Unsupported
3. API
3.1. Utility classes
3.1.1. objectToByteBuffer(), objectFromByteBuffer()
3.2. Interfaces
3.2.1. MessageListener
3.2.2. ExtendedMessageListener
3.2.3. MembershipListener
3.2.4. ExtendedMembershipListener
3.2.5. ChannelListener
3.2.6. Receiver
3.2.7. ExtendedReceiver
3.2.8. ReceiverAdapter and ExtendedReceiverAdapter
3.3. Address
3.4. Message
3.5. View
3.5.1. ViewId
3.5.2. MergeView
3.6. JChannel
3.6.1. Creating a channel
3.6.1.1. Programmatic creation
3.6.2. Setting options
3.6.3. Giving the channel a logical name
3.6.4. Generating custom addresses
3.6.5. Connecting to a channel
3.6.6. Connecting to a channel and getting the state in one operation
3.6.7. Getting the local address and the group name
3.6.8. Getting the current view
3.6.9. Sending a message
3.6.10. Receiving a message
3.6.11. Using a Receiver to receive messages
3.6.12. Peeking at a message
3.6.13. Getting the group's state
3.6.14. Getting the state with a Receiver
3.6.15. Partial state transfer
3.6.16. Streaming state transfer
3.6.17. Disconnecting from a channel
3.6.18. Closing a channel
4. Building Blocks
4.1. PullPushAdapter
4.1.1. Example
4.2. MessageDispatcher
4.2.1. Example
4.3. RpcDispatcher
4.3.1. Example
4.3.1.1. RequestOptions
4.3.1.2. Asynchronous calls with futures
4.4. ReplicatedHashMap
4.5. NotificationBus
4.6. Distributed locking
4.6.1. Locking and merges
4.7. Distributed ExecutionService
5. Advanced Concepts
5.1. Using multiple channels
5.2. The shared transport: sharing a transport between multiple channels in a JVM
5.3. Transport protocols
5.3.1. UDP
5.3.1.1. Using UDP and plain IP multicasting
5.3.1.2. Using UDP without IP multicasting
5.3.2. TCP
5.3.2.1. Using TCP and TCPPING
5.3.2.2. Using TCP and TCPGOSSIP
5.3.3. TUNNEL
5.3.3.1. Using TUNNEL to tunnel a firewall
5.4. The concurrent stack
5.4.1. Overview
5.4.1.1. Configuration
5.4.2. Elimination of up and down threads
5.4.3. Concurrent message delivery
5.4.4. Scopes: concurrent message delivery for messages from the same sender
5.4.5. Out-of-band messages
5.4.6. Replacing the default and OOB thread pools
5.4.7. Sharing of thread pools between channels in the same JVM
5.5. Misc
5.5.1. Shunning
5.5.2. Using a custom socket factory
5.6. Handling network partitions
5.6.1. Merging substates
5.6.2. The primary partition approach
5.6.3. The Split Brain syndrome and primary partitions
5.7. Flushing: making sure every node in the cluster received a message
5.8. Large clusters
5.8.1. Reducing chattiness
5.8.1.1. Discovery
5.8.1.2. Failure detection protocols
5.8.1.2.1. FD_SOCK
5.8.1.2.2. FD_ALL
5.9. Bridging between remote clusters
5.9.1. Views
5.9.2. Configuration
5.10. Daisychaining
5.10.1. Traditional N-1 approach
5.10.2. Daisychaining approach
5.10.3. Switch usage
5.10.4. Performance
5.10.5. Configuration
5.11. Ergonomics
6. Writing protocols
6.1. Anatomy of a protocol
6.2. Writing user defined headers
7. List of Protocols
7.1. Transport
7.1.1. UDP
7.1.2. TCP
7.1.3. TUNNEL
7.2. Initial membership discovery
7.2.1. PING
7.2.2. FILE_PING
7.2.3. JDBC_PING
7.2.4. TCPPING
7.2.5. TCPGOSSIP
7.2.6. MPING
7.2.7. BPING
7.2.8. S3_PING
7.3. Merging after a network partition
7.3.1. MERGE2
7.4. Failure Detection
7.4.1. FD
7.4.2. FD_ALL
7.4.3. FD_SIMPLE
7.4.4. FD_PING
7.4.5. FD_ICMP
7.4.6. FD_SOCK
7.4.7. VERIFY_SUSPECT
7.5. Reliable message transmission
7.5.1. pbcast.NAKACK
7.5.2. UNICAST
7.5.3. UNICAST2
7.6. Fragmentation
7.6.1. FRAG and FRAG2
7.7. Ordering
7.7.1. SEQUENCER
7.8. Group Membership
7.8.1. pbcast.GMS
7.8.1.1. Disabling the initial coordinator
7.9. Security
7.9.1. ENCRYPT
7.9.2. AUTH
7.10. State Transfer
7.10.1. pbcast.STATE_TRANSFER
7.10.2. pbcast.STREAMING_STATE_TRANSFER
7.10.2.1. Overview
7.10.2.2. API
7.10.2.3. Configuration
7.10.2.4. Other considerations
7.11. Flow control
7.11.1. FC
7.11.2. SFC
7.11.3. MFC and UFC
7.11.3.1. MFC
7.11.3.2. UFC
7.12. Message stability
7.12.1. STABLE
7.13. Misc
7.13.1. COMPRESS
7.13.2. pbcast.FLUSH
7.13.3. SCOPE
7.13.4. RELAY
7.13.5. STOMP
7.13.6. DAISYCHAIN
7.13.7. RATE_LIMITER
7.13.8. Locking protocols
7.13.8.1. CENTRAL_LOCK
7.13.8.2. PEER_LOCK
7.13.9. CENTRAL_EXECUTOR
Bibliography
   Next
   Foreword