import org.jgroups.MembershipListener; //导入依赖的package包/类
@ManagedOperation
public void start() throws Exception {
    hash_function=new ConsistentHashFunction<>();
    addMembershipListener((MembershipListener)hash_function);
    ch=new JChannel(props);
    disp=new RpcDispatcher(ch, null, this, this);
    RpcDispatcher.Marshaller marshaller=new CustomMarshaller();
    disp.setRequestMarshaller(marshaller);
    disp.setResponseMarshaller(marshaller);
    disp.setMethodLookup(new MethodLookup() {
        public Method findMethod(short id) {
            return methods.get(id);
        }
    });

    ch.connect(cluster_name);
    local_addr=ch.getAddress();
    view=ch.getView();
}
 

import org.jgroups.MembershipListener; //导入依赖的package包/类
public void viewAccepted(final View new_view) {
    final List<Address> old_nodes=this.view != null? new ArrayList<>(this.view.getMembers()) : null;

    this.view=new_view;
    if(log.isDebugEnabled())
        log.debug("new view: " + new_view);

    if(hash_function != null)
        hash_function.installNodes(new_view.getMembers());

    for(MembershipListener l: membership_listeners)
        l.viewAccepted(new_view);

    if(old_nodes != null) {
        timer.schedule(new Runnable() {
            public void run() {
                rebalance(old_nodes, new ArrayList<>(new_view.getMembers()));
            }
        }, 100, TimeUnit.MILLISECONDS);
    }
}
 

import org.jgroups.MembershipListener; //导入依赖的package包/类
public void viewAccepted(View new_view) {
    System.out.println("view = " + new_view);
    this.view=new_view;
    for(MembershipListener l: membership_listeners) {
        l.viewAccepted(new_view);
    }

    if(migrate_data) {
        migrateData();
    }
}
 

import org.jgroups.MembershipListener; //导入依赖的package包/类
private ReplicatorRpcDispatcher(Channel channel, MessageListener l,
		MembershipListener l2, Object serverObj, S object,
		HashMap<Method, Short> methodMap, ArrayList<Method> methodList) {
	super(channel, l, l2, serverObj);
	this.object = object;
	this.methodMap = methodMap;
	this.methodList = methodList;
	setMarshaller(new ContextAwareMarshaller(getClass().getClassLoader()));
}
 

import org.jgroups.MembershipListener; //导入依赖的package包/类
public void addMembershipListener(MembershipListener l) {
    membership_listeners.add(l);
}
 

import org.jgroups.MembershipListener; //导入依赖的package包/类
public void removeMembershipListener(MembershipListener l) {
    membership_listeners.remove(l);
}