利用JGroup同步Memcache文件

why

　　在服务器开发中，经常要同步几台数据库服务器的数据，同步数据要好几种，比如说在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]

　　这样就可以同步数据了。
   
版权声明：本文为博主原创文章，未经博主允许不得转载。