JGroups JGroups is a toolkit for reliable multicast communication.
Download

JGroups Ranking & Summary

JGroups Tags

Java protocol stack groups multicast communication Java groups JavaGroups

JGroups Description

JGroups is a toolkit for reliable multicast communication. JGroups is a toolkit for reliable multicast communication.JGroups is a toolkit for reliable multicast communication. (Note that this doesn't necessarily mean IP Multicast, JGroups can also use transports such as TCP).It can be used to create groups of processes whose members can send messages to each other.Here are some key features of "JGroups":· Group creation and deletion. Group members can be spread across LANs or WANs· Joining and leaving of groups· Membership detection and notification about joined/left/crashed members· Detection and removal of crashed members· Sending and receiving of member-to-group messages (point-to-multipoint)· Sending and receiving of member-to-member messages (point-to-point)Flexible Protocol StackThe most powerful feature of JGroups is its flexible protocol stack, which allows developers to adapt it to exactly match their application requirements and network characteristics.The benefit of this is that you only pay for what you use. By mixing and matching protocols, various differing application requirements can be satisfied.JGroups comes with a number of protocols (but anyone can write their own), for example:· Transport protocols: UDP (IP Multicast), TCP, JMS· Fragmentation of large messages· Reliable unicast and multicast message transmission. Lost messages are retransmitted· Failure detection: crashed members are excluded from the membership· Ordering protocols: Atomic (all-or-none message delivery), Fifo, Causal, Total Order (sequencer or token based)· Membership· EncryptionWhat Does JGroups Buy Me ?JGroups allows developers to create reliable multipoint (multicast) applications where reliability is a deployment issue, and does not have to be implemented by the application developer. This saves application developers significant amounts of time, and allows for the application to be deployed in different environments, without having to change code.Requirements:· Java Runtime Environment (JRE) 1.5 or laterWhat's New in This Release:Bug· - Deadlock condition in BARRIER· - Unable to recover from suspect/merge, with auto-reconnect· - NAKACK: merging of digests is incorrect· - GossipClient: make socket creation non-blocking· - Configurator.startProtocolStack() throws NPE if cluster_name is null· - with dynamic keys in ENCRYPT, a node taking over coordinator can block itself from taking over the view· - stats logic NPE in NAKACK· - FC.java was not handling view changes sent down from above· - timeout and num_ping_requests hardcoded in Discovery· - FD: temporary suspect (followed by unsuspect) leads to incorrect pingable_mbrs· - JChannel.connect(): check if already connected· - MPING: OutOfMemory exception can cause receiver thread to terminate· - GMS.ViewHandler.run() view bundling not correctly checking if requests can be processed together...· - Shared transport protocols use stack field from first channel created· - UNICAST connection trashing during merge· - FD: messages from members other than ping_dest causes missing-heartbeat count to be reset· - Deadlock between GroupRequest and FLUSH during concurrent startup.· - ReplicatedHashMap state becomes inconsistent after merge· - JGroups leaks thread context classloader to internal threads· - FC: ConcurrentModificationException in handleViewChange()· - FLUSH still needs work· - FLUSH: GMS potential problem· - UDP: when ip_mcast=false, the destination of a Message is not null· - Concurrent startup of many channels doesn't stabilize· - STATE_TRANSFER: state transfer broken for large states· - UNICAST: regular message not delivered (in some cases) until new message arrives· - NAKACK: regular message not delivered (in some cases) until new message arrives· - local_addr is null when reconnecting.· - UNICAST over TCP with xmit_off=true: sending message in synchronized block leads to deadlocks· - concurrent startup of multiple channels with shared transport is very slow, occasionally wedges.· - TP: setting an OOB thread pool shuts it downFeature Request· - Shared transport: add cluster name to thread name for easier logging· - VIEW_SYNC needs more statistics· - BARRIER jmx beans not exposed· - UNICAST: eager acks· - MessageDispatcher log message needs more information· - Message ordering protocol for TCP unicasts· - FRAG: option to discard output stream, so we don't keep large buffers around· - TP: add ID to individual threads in thread pool· - MPING: discard packets whose length is not 4 or 16· - JMX Registration of shared transport channels· - cache object returned from Message.getObject() (deserialization occurs on every call)· - RpcDispatcher should have a no-arg public constructor· - Transport: discard messages sent from self if Channel.LOCAL option is falseTask· - FLUSH: flushing should span merge· - persistence factory spits out error messages when it should be debug· - Include shared transport configuration in test suite· - TCP based configs need UNICAST for correct ordering· - JChannel: if auto_get_state is set to true, but no state transfer protocol is present, then don't get state· - Ship bouncycastle.jar without IDEA code· - Transport: create receiver threads on CONNECT, not on start()· - FD_SOCK: add timeout to create socket to peer· - Simplify view casting sequence· - Thread context classloaders: add ability to set TCCL when thread is created and unset it when thread is released· - STABLE: last message dropped issue ?· - UNICAST over TCP: xmit_off should not send ACKs What's New in This Release: Bug: · - Concurrent connect of multiple channels with shared transport fails · - Failure detection: multiple crashes not detected Feature Request: · - Eliminate Linux cross-talk in MPING · - GossipRouter/GossipClient: make sockets use SO_TIMEOUT and SO_LINGER Task: · - ExposedByteArrayOutputStream / ExposedDataOutputStream: override synchronized methods · - ExposedByteArrayInputStream / ExposedDataInputStream: override synchronized methods with unsynchronized ones

JGroups Related Software