`
yangzb
  • 浏览: 3506700 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

转:JGroups 简介、适用场合、配置、程序例子Demo等完全使用指南

    博客分类:
  • Java
阅读更多

目前项目中在克服JGroups初期使用的困难之后,已经使用比较稳定了。感觉比较烦琐和容易出错的还是JGroups配置。感觉中文的资源较少,现将自己总结的经验总结如下
Tim http://hi.baidu.com/jabber/blog/item/7e879852a23efd0f0cf3e3ea.html

JGroups 适合使用场合
服务器集群cluster、多服务器通讯、服务器replication(复制)等,分布式cache缓存

JGroups 简介
JGroups是一个基于Java语言的提供可靠多播(组播)的开发工具包。在IP Multicast基础上提供可靠服务,也可以构建在TCP或者WAN上。主要是由Bela Ban开发,属于JBoss.org,在JBoss的网站也有一些相关文档。目前在 SourceForge上还是比较活跃,经常保持更新。

JGroups 配置

PING: 发现初始成员
MERGE2: 将网络层切分的包重新合并。
FD_SOCK: Failure Dectection 错误检测,基于TCP
FD:Failure Dectection 错误检测,基于心跳
VERIFY_SUSPECT: 检查貌似失败的节点
pbcast.NAKACK: 应答,提供可靠传输
UNICAST: 可靠的UNICAST
pbcast.STABLE: 计算广播信息是否稳定
VIEW_SYNC: 定期广播view(成员名单)
pbcast.GMS: Group membership, 处理joins/leaves/crashes等
FC: 流量控制
FRAG2:Fragmentation layer,分包,将大的数据包分拆成适合网络层传输

以上一些是比较重要的配置,基本上不能少。如果要深入研究可以在 org.jgroups.protocols 里面查看源代码

JGroups使用例子, JGroups demo, Tim的hello world例子
Timreceiver.java

import org.jgroups.tests.perf.Receiver;
import org.jgroups.tests.perf.Transport;
import org.jgroups.util.Util;

public class TimReceiver implements Receiver {
      private Transport transport = null;
      
      public static void main(String[] args) {
            TimReceiver t = new TimReceiver();
            try {
                  int sendMsgCount = 5000;
                  int msgSize = 1000;
                  t.start();

                  t.sendMessages(sendMsgCount, msgSize);
                  System.out.println("########## Begin to recv...");
                  Thread.currentThread().join();
            } catch (Exception e) {
                  e.printStackTrace();
            } finally {
                  if (t != null) {
                        t.stop();
                  }
            }
      }
      
      public void start()
                  throws Exception {
            transport = (Transport) new TimTransport();
            transport.create(null);
            transport.setReceiver(this);
            transport.start();
      }

      public void stop() {
            if (transport != null) {
                  transport.stop();
                  transport.destroy();
            }
      }

      private int count = 0;
      public void receive(Object sender, byte[] data) {
            System.out.print(".");
            if (++count == 5000) {
                  System.out.println("\r\nRECV DONE.");
                  System.exit(0);
            }
            
      }

      private void sendMessages(int count, int msgSize)
                  throws Exception {
            byte[] buf = new byte[msgSize];
            for (int k = 0; k < msgSize; k++)
                  buf[k] = 'T';

            System.out.println("-- sending " + count + " " + Util.printBytes(msgSize) + " messages");

            for (int i = 0; i < count; i++) {
                  transport.send(null, buf);
            }
            
            System.out.println("######### send complete");
      }
}


TimTransport.java


import java.util.Map;
import java.util.Properties;

import org.jgroups.Address;
import org.jgroups.JChannel;
import org.jgroups.Message;
import org.jgroups.ReceiverAdapter;
import org.jgroups.tests.perf.Receiver;
import org.jgroups.tests.perf.Transport;

public class TimTransport extends ReceiverAdapter implements Transport{
      private JChannel channel = null;
      private String groupName = "TimDemo";
      private Receiver receiver = null;
      
      String PROTOCOL_STACK_UDP1 = "UDP(bind_addr=192.168.100.59";  
      String PROTOCOL_STACK_UDP2 = ";mcast_port=8888";
      String PROTOCOL_STACK_UDP3 = ";mcast_addr=225.1.1.1";
      String PROTOCOL_STACK_UDP4 = ";tos=8;loopback=false;max_bundle_size=64000;" +
                  "use_incoming_packet_handler=true;use_outgoing_packet_handler=false;ip_ttl=2;enable_bundling=true):"
           + "PING:MERGE2:FD_SOCK:FD:VERIFY_SUSPECT:"
             +"pbcast.NAKACK(gc_lag=50;max_xmit_size=50000;use_mcast_xmit=false;" +
                         "retransmit_timeout=300,600,1200,2400,4800;discard_delivered_msgs=true):"
             +"UNICAST:pbcast.STABLE:VIEW_SYNC:"
             +"pbcast.GMS(print_local_addr=false;join_timeout=3000;" +
                         "join_retry_timeout=2000;" +
                         "shun=true;view_bundling=true):"
             +"FC(max_credits=2000000;min_threshold=0.10):FRAG2(frag_size=50000)";

            
      public Object getLocalAddress() {
            return channel != null ? channel.getLocalAddress() : null;
      }

      public void start() throws Exception {
            channel.connect(groupName);            
      }

      public void stop() {
            if (channel != null) {
                  channel.shutdown();
            }
      }

      public void destroy() {
            if (channel != null) {
                  channel.close();
                  channel = null;
            }
      }

      public void setReceiver(Receiver r) {
            this.receiver = r;
      }

      public Map dumpStats() {
            return channel != null ? channel.dumpStats() : null;
      }

      public void send(Object destination, byte[] payload) throws Exception {
            byte[] tmp = new byte[payload.length];
            System.arraycopy(payload, 0, tmp, 0, payload.length);
            Message msg = null;
            msg = new Message((Address) destination, null, tmp);
            if (channel != null) {
                  channel.send(msg);
            }
      }

      public void receive(Message msg) {
            Address sender = msg.getSrc();
            byte[] payload = msg.getBuffer();
            if (receiver != null) {
                  try {
                        receiver.receive(sender, payload);
                  } catch (Throwable tt) {
                        tt.printStackTrace();
                  }
            }
      }

      public void create(Properties config) throws Exception {
            String PROTOCOL_STACK = PROTOCOL_STACK_UDP1 + PROTOCOL_STACK_UDP2 + PROTOCOL_STACK_UDP3 + PROTOCOL_STACK_UDP4;
            channel = new JChannel(PROTOCOL_STACK);
            channel.setReceiver(this);            
      }

      public void send(Object destination, byte[] payload, boolean oob) throws Exception {
            send(destination, payload);
      }
}


JGroups 下载 download
http://www.jgroups.org/

分享到:
评论

相关推荐

    jgroups-chat:JGroups 聊天

    - **协议栈(Protocol Stack)**: JGroups 使用协议栈来处理不同的任务,如组成员发现、消息传输和故障检测等。每个协议负责特定的职责,形成一个高效的通信链路。 2. **JGroups 的关键功能** - **成员发现...

    Jgroups 教程

    - `jgroups-all.jar`:核心JGroups功能库,包括demo和junit应用程序。如果需要更小的JAR包,可以下载源代码并执行“jar”目标,生成大约1MB大小的`jgroups-core.jar`。 - `log4j.jar`(可选):日志库,JGroups也...

    JGroups_集群.pdf

    JGroups的协议栈可以根据不同的需求进行定制,例如,如果选择使用IP Multicast作为传输协议,可以在协议栈中添加NAKACK协议以防止报文丢失和重复,添加TOTAL协议以保证报文的顺序,添加Group Membership Service ...

    Ehcache通过Jgroups做集群

    Ehcache是一款高效、流行的Java缓存库,它允许应用程序快速访问经常使用的数据,从而提高性能和响应速度。在分布式环境中,为了实现数据共享和高可用性,Ehcache提供了集群功能。而Jgroups则是Java中一个强大的集群...

    基于java的多播通讯框架 JGroups.zip

    5. **可配置的协议栈**:JGroups提供了丰富的协议栈,用户可以根据应用需求自由组合和配置。这些协议涵盖了网络层、传输层、可靠传输、故障检测、选举等各个方面。 6. **安全特性**:JGroups支持加密和身份验证,...

    Java多播通讯框架 JGroups

    JGroups完全用Java编写,因此可以无缝集成到任何Java应用中,无论是在企业级应用服务器、分布式数据库还是微服务架构中。 总的来说,JGroups是Java开发人员构建分布式系统时的强大工具,它简化了集群通信的复杂性,...

    jgroup master

    ### JGroups:可靠的组通信 #### 概览与核心概念 **JGroups**是一个用于创建分布式应用程序的Java库,它提供了可靠、高效的组播通信功能。JGroups支持多种传输层协议,包括TCP、UDP和多播等,并允许开发人员自定义...

    程序员的刷题软件-JGroups:JGroups项目

    - **分布式缓存**: 如在使用Infinispan或Hazelcast等分布式缓存时,JGroups提供了底层的通信支持。 - **协作工具**: 在程序员的刷题软件中,JGroups可以实现实时的问题讨论、答案同步和协作解题等功能。 ### 5. ...

    jgroups

    ### 关于JGroups 2.5教程:安装与开发简易应用程序 #### 安装与配置JGroups **JGroups**是一款高性能、可扩展且高度可靠的群集通信库,旨在为分布式系统提供消息传递功能。本教程将深入探讨如何安装配置JGroups,...

    dropwizard-jgroups:JGroups Dropwizard 包

    该项目提供了一个 Dropwizard Bundle,将 JGroups 配置集成到标准配置文件中。 还提供了一个项目来演示如何使用该包。 用法 Maven 要使用此项目的快照,您需要在 POM 中包含 sonatype 存储库。 &lt;enabled&gt;...

    JGroups的Raft实现jgroups-raft.zip

    jgroups-raft 项目是 JGroups 框架对 Raft 的实现。Maven:&lt;groupId&gt;org.jgroups &lt;artifactId&gt;jgroups-raft &lt;version&gt;0.2&lt;/version&gt;Raft 是一个容易理解的共识算法。在容错和性能方面它相当于 Paxos(Google 的一致...

    JGroups通讯框架 v4.2.27.zip

    开发者可以通过查阅源码了解其实现细节,利用文档学习如何配置和使用JGroups,从而更好地集成到自己的项目中。 总结来说,JGroups作为一款强大的通信框架,不仅提供了丰富的功能,还具有高度可定制性,对于构建高...

    基于Java的源码-多播通讯框架 JGroups.zip

    5. **协议栈**:JGroups使用可配置的协议栈,用户可以根据实际需求选择或自定义协议,如TCP、UDP、TLS等,以满足不同性能和安全要求。 6. **API简单易用**:JGroups提供了一个简单直观的API,使得开发者可以轻松地...

    jgroups-raft:JGroups中RAFT共识协议的实现

    jgroups-raft JGroups中RAFT [1]共识算法的实现。 对于设计,请查看doc 。 要生成手册,请执行ant manual (需要asciidoctor )。 关于设计和实现的讨论在[2]。 网页在这里:[3]。 #jgroups-raft上有一个IRC。 [1] ...

    jgroups源代码

    《深入解析JGroups开源框架:基于belaban-JGroups-19d7183源代码》 JGroups是一个用于构建高可用性集群的Java框架,它提供了可靠的消息传递、组成员管理和故障检测等功能,广泛应用于分布式系统中。本文将基于bela...

    JGroups群组通讯工具包 v5.3.4.zip

    2. **文档**:可能包含API文档、用户手册和开发者指南,帮助理解如何使用和集成JGroups。 3. **示例**:一些示例程序展示了JGroups的基本用法和高级功能,便于快速上手。 对于计算机科学的学生和研究人员来说,...

    JGroups实现聊天小程序

    总结来说,这个 JGroups 聊天小程序示例展示了如何使用 JGroups 建立分布式通信,包括节点之间的消息传递、视图管理和状态同步。通过这种方式,开发者可以构建出一个健壮的、容错的聊天系统,支持多个节点之间的实时...

    jgroups-3.0.2

    JGroups使用灵活的协议栈,这也是JGroups最强大(the most powerful)的功能,它允许开发人员配置协议栈来适用于他们自己的应用需求和网络特征。这样做的好处在于,开发人员只需要关注他们使用到的协议。通过组合和...

    JGROUPS集群框架源码分析之消息发送、处理、接收

    - **路由选择**:JGROUPS使用组协议栈来决定消息的路由。组协议栈是由多个协议层组成的,如UDP、TCP、FRAG等,每个协议层都有特定的职责,如网络传输、消息分片或重传。 - **协议处理**:消息通过协议栈时,每个...

Global site tag (gtag.js) - Google Analytics