[享学Eureka] 六、InstanceInfo实例管理器：ApplicationInfoManager

public static interface StatusChangeListener {
    String getId();
    void notify(StatusChangeEvent statusChangeEvent);
}

public static interface InstanceStatusMapper {
    InstanceStatus map(InstanceStatus prev);
}

private static final InstanceStatusMapper NO_OP_MAPPER = prev -> prev;

public static class OptionalArgs {
    private InstanceStatusMapper instanceStatusMapper;
    @com.google.inject.Inject(optional = true)
    public void setInstanceStatusMapper(InstanceStatusMapper instanceStatusMapper) {
        this.instanceStatusMapper = instanceStatusMapper;
    }
    InstanceStatusMapper getInstanceStatusMapper() {
        return instanceStatusMapper == null ? NO_OP_MAPPER : instanceStatusMapper;
    }
}

@Singleton
public class ApplicationInfoManager {
	
    private static ApplicationInfoManager instance = new ApplicationInfoManager(null, null, null);
    // please use DI instead
    @Deprecated
    public static ApplicationInfoManager getInstance() {
        return instance;
    }

    protected final Map<String, StatusChangeListener> listeners;
    private final InstanceStatusMapper instanceStatusMapper;
    private InstanceInfo instanceInfo;
    private EurekaInstanceConfig config;


	// 初始化一个ApplicationInfoManager对象
	// OptionalArgs目的就是传递一个`InstanceStatusMapper`实例
    @Inject
    public ApplicationInfoManager(EurekaInstanceConfig config, InstanceInfo instanceInfo, OptionalArgs optionalArgs) {
        this.config = config;
        this.instanceInfo = instanceInfo;
        this.listeners = new ConcurrentHashMap<>();
        if (optionalArgs != null) {
            this.instanceStatusMapper = optionalArgs.getInstanceStatusMapper();
        } else {
            this.instanceStatusMapper = NO_OP_MAPPER;
        }
        // 把通过DI生成的实例重新赋值给它，已达到统一的效果
        instance = this;
    }

}

ApplicationInfoManager：

	// 如果你使用getInstance()得到的实例，记得调用它完成初始化
	// 如果是DI方式，就不用啦
    public void initComponent(EurekaInstanceConfig config) {
        try {
            this.config = config;
            this.instanceInfo = new EurekaConfigBasedInstanceInfoProvider(config).get();
        } catch (Throwable e) {
            throw new RuntimeException("Failed to initialize ApplicationInfoManager", e);
        }
    }

	// 获取管理的实例
    public InstanceInfo getInfo() {
        return instanceInfo;
    }
    public EurekaInstanceConfig getEurekaInstanceConfig() {
        return config;
    }


	// 给实例**添加**  最终会进入到InstanceInfo#metadata元数据的Map里
    public void registerAppMetadata(Map<String, String> appMetadata) {
        instanceInfo.registerRuntimeMetadata(appMetadata);
    }


	// =================最重要的一个方法=================
	// 设置此实例的状态。应用程序可以使用它来指示是否准备接收流量。
	// 在这里设置状态也会通知所有已注册的侦听器状态更改事件的。
	// 如果你是自己通过InstanceInfo.setStatus去设置状态，那监听器啥的都不会触发的~~~~~

	// 另外：设进来的状态需要经过instanceStatusMapper策略处理一下（默认策略是不处理）
    public synchronized void setInstanceStatus(InstanceStatus status) {
        InstanceStatus next = instanceStatusMapper.map(status);
        if (next == null) {
            return;
        }

		// 如果prev不为null，那就证明状态发生了变更，就要触发变更的监听器
        InstanceStatus prev = instanceInfo.setStatus(next);
        if (prev != null) {
            for (StatusChangeListener listener : listeners.values()) {
                try {
                    listener.notify(new StatusChangeEvent(prev, next));
                } catch (Exception e) {
                    logger.warn("failed to notify listener: {}", listener.getId(), e);
                }
            }
        }
    }

	// 注册状态变更监听器
	// DiscoveryClient里会通过此方法注册一个监听器来监控实例状态：若状态变更变为Down了就立马同步给Server
    public void registerStatusChangeListener(StatusChangeListener listener) {
        listeners.put(listener.getId(), listener);
    }
    public void unregisterStatusChangeListener(String listenerId) {
        listeners.remove(listenerId);
    }


	// 重新获取主机名以检查它是否已更改  也就是维护实例的setHostName、setIPAddr
	// 说明：只有当你数据中心使用的AmazonInfo 
	// 或者 是RefreshableInstanceConfig动态配置时，才有可能有newAddress的可能，否则不可能变的
	public void refreshDataCenterInfoIfRequired() { ... }
	// 续租信息同步一把，若有需要的话。
	// 这主要考虑到`EurekaInstanceConfig`可能是个可动态刷新的实例，所以通过这个方法去判断一把是否需要同步
	// 这两个方法的调用处是：DiscoveryClient#refreshInstanceInfo
	public void refreshLeaseInfoIfRequired() { ... }