Jgroup-白红宇

Jgroup

阅读量：2171 次

发布时间：2019-05-01

本文共 3536 字，大约阅读时间需要 11 分钟。

服务器开发中，经常要同步几台数据库服务器的数据，同步数据要好几种，比如说在linux中，经常用rsync来同步数据或者写几个 Servlet来同步服务器数据，因为我最近学习到JGroup这个通讯工具，所以利用它来更新一些不同服务器上的memcache的数据。

一、JGroups 简介

JGroups是一个基于Java语言的提供可靠多播(组播)的开发工具包。在IP Multicast基础上提供可靠服务，也可以构建在TCP或者WAN上。主要是由Bela Ban开发，属于JBoss.org，在JBoss的网站也有一些相关文档。目前在 SourceForge上还是比较活跃，经常保持更新。JGroups 适合使用场合---服务器集群cluster、多服务器通讯、服务器replication(复制)等，分布式cache缓存。

二、JGroups 配置

下面我列出几种各个配置参数意义，详细的配置具体参考JGroup的文档：

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，分包，将大的数据包分拆成适合网络层传输。

三、JGroup原理

JGroups是一个可靠的组间通讯工具，进程可以加入一个通讯组，给组内所有的成员或单独的成员发送消息，同样，也可以从组中的成员处接收消息。系统会记录组的每一个成员，在新成员加入或是现有的成员离开或是崩溃时，会通知组内的其他成员，这样我们就不必自己去管理这些事情，要想加入一个组，并与组内其他的成员交互，必须建立一个Channel连接到组，同一个组内的所有成员使用相同的组名称，这样才能进行通信。

四、发送端的数据类

package ceshi; import org.jgroups.ChannelClosedException; import org.jgroups.ChannelNotConnectedException; import org.jgroups.JChannel; import org.jgroups.Message; /**  * 发送数据的服务器端  * @author chenhaibin  *  */ public class Send {
      JChannel channel;     //得到本机电脑的 用户名字     String user_name=System.getProperty("user.name", "n/a");     private void start() throws Exception     {
       /**       * 参数里指定Channel使用的协议栈，如果是空的，则使用默认的协议栈，       * 位于JGroups包里的udp.xml。参数可以是一个以冒号分隔的字符串，       * 或是一个XML文件，在XML文件里定义协议栈。       */         //创建一个通道         channel=new JChannel();                //加入一个群         channel.connect("ChatCluster");         //发送事件         sendEvent();         //关闭通道         channel.close();     }     /**      * 主要发送事件      */     private void sendEvent()     {
        try   {
        String str="chenhaibin";//发送的字符串       //这里的Message的第一个参数是发送端地址       //第二个是接收端地址       //第三个是发送的字符串          //具体参见jgroup send API       Message msg=new Message(null, null, str);       //发送    channel.send(msg);   } catch (ChannelNotConnectedException e)   {
     e.printStackTrace();   } catch (ChannelClosedException e)   {      e.printStackTrace();   }     }     public static void main(String[] args) throws Exception     {
          //开始发送事件         new Send().start();     } }

五、接收端的数据类

package ceshi; import org.jgroups.JChannel; import org.jgroups.Message; import org.jgroups.ReceiverAdapter; import org.jgroups.View; /**  * 接收收据包  * @author chenhaibin  *  */ public class Receive extends ReceiverAdapter {
   JChannel channel;  String user_name = System.getProperty("user.name", "n/a");   public static void main(String[] args) throws Exception  {
    //接收收据端   new Receive().start();  }   private void start() throws Exception  {
    //创建一个通道   channel = new JChannel();   //创建一个接收器   channel.setReceiver(this);   //加入一个群   channel.connect("ChatCluster");  }  //覆盖父类的方法  @Override  public void receive(Message msg)  {
    //具体参见msg的参数   String receiveData=(String)msg.getObject();   System.out.println("  发过来的数据是:  " +receiveData);  }  @Override  public void viewAccepted(View new_view)  {
    System.out.println("** view: " + new_view);  } }

六、执行

服务器执行后的数据：

-------------------------------------------------------- GMS: address=PC-200909181147-46154, cluster=ChatCluster,  physical address=127.0.0.1:1107 --------------------------------------------------------

客户端执行后的数据：

** view: [PC-200909181147-34071|3] [PC-200909181147-34071, PC-200909181147-46154]

发过来的数据是:

chenhaibin  //接收过来的数据 ** view: [PC-200909181147-34071|4] [PC-200909181147-34071]

这样就可以同步数据了。

转载地址：http://cwqzb.baihongyu.com/

你可能感兴趣的文章