答复: 基于jgroup封装，方便rpc调用，失效通知

失效通知

一、服务端的使用

1.将接口com.sohu.sip.group.GroupBus进行初始化，对应的实现类为com.sohu.sip.group.impl.GroupBusImpl

 

2.初始化时，调用init() 方法。销毁时，调用destroy() 方法。

 

3.如果使用spring，则只需要在配置中添加

<bean id="groupBus" class="com.sohu.sip.group.impl.GroupBusImpl" 
    	init-method="init" destroy-method="destroy">
</bean>

 

 

4.服务端可以直接调用GroupBus接口的方法，通知组内所有成员。

void flushEntry(String region, String key);
	
void flushGroup(String region, String key);

 

5.在classpath下添加配置文件sipgroup-admin.properties

cache.cluster.multicast.ip=230.12.21.132
cache.cluster.bus.name=AdsenderCacheBus

 

 

二、客户端的使用

1.需要接受失效通知的实现类，继承接口com.sohu.sip.group.GroupBusListener

public class MyManagerImpl implements MyManager,GroupBusListener{
      ...
}

 

2.对接口的两个方法进行实现。即接受到消息时，需要进行的操作。

public void flushEntry(String region, String key) {
		if (log.isDebugEnabled()) {
			log.debug("flushEntry(region = " + region + ", key = " + key + ")");
		}
	}
	
	public void flushGroup(String region, String groupKey) {
		if (log.isDebugEnabled()) {
			log.debug("flushGroup(region = " + region + ", groupKey = "
					+ groupKey + ")");
		}
	}

 

 

3.和服务端一样，将接口com.sohu.sip.group.GroupBus进行初始化，对应的实现类为com.sohu.sip.group.impl.GroupBusImpl

 

4.初始化时，调用init() 方法。销毁时，调用destroy() 方法。

 

5.添加对应的相应列表listenerMap，

      key 为服务端调用时，使用的region

      value 为客户端对应的接口,即实现了GroupBusListener的类

     因为客户端，可能会有多个继承了GroupBusListener的类，而服务端调用失效通知时，应该客户端只有一个类的实现被调用才是正确的。所以通过listenerMap的对应关系，可以准确的定位到需要调用的实现类。

 

6.在classpath下添加配置文件sipgroup-client.properties

cache.cluster.multicast.ip=230.12.21.132
cache.cluster.bus.name=AdsenderCacheBus