jgroup例子

编程技术  /  houtizong 发布于 3年前   204

参考http://express.ruanko.com/ruanko-express_18/webpage/tech7.html
http://puras.iteye.com/blog/81783

下载jgroups-2.12.0.CR2.jar

Receive建立一个线程一直等待
send后，Receive有响应

package com.jgroups;import org.jgroups.ChannelClosedException;import org.jgroups.ChannelNotConnectedException;import org.jgroups.JChannel;import org.jgroups.Message;/** * 发送数据的服务器端 * */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="mytest";//发送的字符串    //这里的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 com.jgroups;import org.jgroups.JChannel;import org.jgroups.Message;import org.jgroups.ReceiverAdapter;import org.jgroups.View;/** * 接收收据包 * */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");}//覆盖父类的方法@Overridepublic void receive(Message msg){//具体参见msg的参数String receiveData=(String)msg.getObject();System.out.println("  发过来的数据是:  " +receiveData);}@Overridepublic void viewAccepted(View new_view){System.out.println("** view: " + new_view);}}

---------------------------
http://www.jgroups.org/tutorial/html/ch01.html#d0e122

D:\>java -cp jgroups-2.12.0.CR2.jar org.jgroups.demos.Draw
执行两次，看到两个窗口，画图会同步到另一个窗口

-------------------------------------------
看官方是2.5的，先弄下2.5吧，

E:\java\jgroups\JGroups-2.5.0.bin>java -cp  jgroups-all.jar;commons-logging.jar -Djgroups.bind_addr=127.0.0.1 -Djava.net.preferIPv4Stack=true org.jgroups.demos.Draw2011-3-1 10:33:47 org.jgroups.JChannel init信息: JGroups version: 2.5.0-------------------------------------------------------GMS: address is 127.0.0.1:1936-------------------------------------------------------** View=[127.0.0.1:1936|0] [127.0.0.1:1936]

jgroups.bind_addr如果机器上多ip，指定 一个
java.net.preferIPv4Stack=true 关闭ipv6