如何利用jgroups实现分布式环境下消息的接受和发送

《如何利用jgroups实现分布式环境下消息的接受和发送》由会员上传分享，免费在线阅读，更多相关内容在工程资料-天天文库。

1、如何利用jgroups实现分布式环境下消息的接受和发送为了提高应用的性能,我们准备实现分布式cache,所以我特别研究了oscache关于分布式实现的部分.我们知道为了实现分布式环境下消息的通知,目前两种比较流行的做法是使用JavaGroups[http://www.jgroups.org]和JMS。这两种方式都在底层实现了广播发布消息。由于JGroups可以提供可靠的广播通信.所以我们准备采用JGroups.我自己写了一个JavaGroupBroadcastingManager.java类实现消

2、息的管理(包括发送和接收),代码参考了oscache的相关代码,在其基础上进行了改进.代码如下:1、JavaGroupBroadcastingManager.javapackagecom.yz;importcom.opensymphony.oscache.base.FinalizationException;importcom.opensymphony.oscache.base.InitializationException;importcom.opensymphony.oscache.plugi

3、ns.clustersupport.JavaGroupsBroadcastingListener;importorg.apache.commons.logging.Log;importorg.apache.commons.logging.LogFactory;importorg.jgroups.Address;importorg.jgroups.Channel;importorg.jgroups.blocks.NotificationBus;importjava.io.Serializable;i

4、mportjava.util.Properties;/***@authoryangzheng*@version$Revision$*@since2005-7-14*/publicclassJavaGroupBroadcastingManagerimplementsNotificationBus.Consumer{privatestaticfinalLoglog=LogFactory.getLog(JavaGroupsBroadcastingListener.class);privatestatic

5、finalStringBUS_NAME="OSCacheBus";privatestaticfinalStringCHANNEL_PROPERTIES="cache.cluster.properties";privatestaticfinalStringMULTICAST_IP_PROPERTY="cache.cluster.multicast.ip";privateNotificationBusbus;/***Initializesthebroadcastinglistenerbystartin

6、gupaJavaGroupsnotification*businstancetohandleincomingandoutgoingmessages.**/publicsynchronizedvoidinitialize(Propertiesconfig)throwsInitializationException{Stringproperties=config.getProperty(CHANNEL_PROPERTIES);StringmulticastIP=config.getProperty(M

7、ULTICAST_IP_PROPERTY);if(log.isInfoEnabled()){log.info("StartinganewJavaGroupsbroadcastinglistenerwithproperties="+properties);}try{bus=newNotificationBus(BUS_NAME,properties);bus.start();bus.getChannel().setOpt(Channel.LOCAL,newBoolean(false));bus.se

8、tConsumer(this);log.info("JavaGroupsclusteringsupportstartedsuccessfully");}catch(Exceptione){thrownewInitializationException("Initializationfailed:"+e);}}/***ShutsdowntheJavaGroupsbeingmanaged*/publicsynchronizedvoidfinialize()throwsFinalizat