import org.jgroups.fork.ForkChannel; //导入依赖的package包/类
@Override
public Channel getJGroupsChannel(Properties p) {
	try {
		if (ApplicationProperty.OnlineSchedulingClusterForkChannel.isTrue()) {
			return new ForkChannel(super.getJGroupsChannel(p), "forked-stack", "sectioning-channel",
					true, ProtocolStack.ABOVE, FRAG2.class,
					new RSVP().setValue("timeout", 60000).setValue("resend_interval", 500).setValue("ack_on_delivery", false));
		} else {
			return new JChannel(JGroupsUtils.getConfigurator(ApplicationProperty.OnlineSchedulingClusterConfiguration.value()));
		}
	} catch (Exception e) {
		Debug.error(e.getMessage(), e);
		return null;
	}
}
 

import org.jgroups.fork.ForkChannel; //导入依赖的package包/类
@Synchronized
@Override
public void joinCluster() {
    if (isConnected()) {
        log.info("Already joined the cluster {}.", settings.getClusterName());
        return;
    }
    try {
        log.debug("Joining cluster {}...", settings.getClusterName());
        this.channel = new JChannel(settings.getJgroupsConfigFile());
        channel.setName(settings.getHostname());
        channel.connect(settings.getClusterName());

        ForkChannel taskChannel = new ForkChannel(channel, "tasks", "tasks_ch");
        taskChannel.connect(settings.getClusterName());
        taskState.initialize(taskChannel, channel.getAddressAsString());

        ForkChannel rpcChannel = new ForkChannel(channel, "rpc", "rpc_ch");
        rpcChannel.connect(settings.getClusterName());
        messageDispatcher.initialize(rpcChannel, channel.getAddressAsString());

        if (executor != null) executor.shutdown();
        executor = Executors.newSingleThreadScheduledExecutor();
        executor.scheduleAtFixedRate(taskState::removeOrphanTasks, 1, 1, TimeUnit.MINUTES);

        log.info("Joined cluster {} with {} member(s).",
            channel.getClusterName(), channel.getView().getMembers().size());
        log.info("Cluster address: {}", channel.getAddress());
    } catch (Exception e) {
        channel = null;
        log.catching(XLogger.Level.WARN, e);
        log.info("Could not create or join cluster. Will work as single node.");
    }
}