public interface DataCenterInfo {
/**
* 数据中心名枚举
*/
enum Name {
   Netflix,
   Amazon,
   MyOwn
}
 
/**
* @return 归属的数据中心名
*/
Name getName();
}

public abstract class AbstractInstanceConfig implements EurekaInstanceConfig {
 
    /**
     * 契约过期时间，单位：秒
     */
    private static final int LEASE_EXPIRATION_DURATION_SECONDS = 90;
    /**
     * 租约续约频率，单位：秒。
     */
    private static final int LEASE_RENEWAL_INTERVAL_SECONDS = 30;
    /**
     * 应用 https 端口关闭
     */
    private static final boolean SECURE_PORT_ENABLED = false;
    /**
     * 应用 http 端口开启
     */
    private static final boolean NON_SECURE_PORT_ENABLED = true;
    /**
     * 应用 http 端口
     */
    private static final int NON_SECURE_PORT = 80;
    /**
     * 应用 https 端口
     */
    private static final int SECURE_PORT = 443;
    /**
     * 应用初始化后开启
     */
    private static final boolean INSTANCE_ENABLED_ON_INIT = false;
    /**
     * 主机信息
     * key：主机 IP 地址
     * value：主机名
     */
    private static final Pair<String, String> hostInfo = getHostInfo();
    /**
     * 数据中心信息
     */
    private DataCenterInfo info = new DataCenterInfo() {
        @Override
        public Name getName() {
            return Name.MyOwn;
        }
    };
 
    private static Pair<String, String> getHostInfo() {
        Pair<String, String> pair;
        try {
            InetAddress localHost = InetAddress.getLocalHost();
            pair = new Pair<String, String>(localHost.getHostAddress(), localHost.getHostName());
        } catch (UnknownHostException e) {
            logger.error("Cannot get host info", e);
            pair = new Pair<String, String>("", "");
        }
        return pair;
    }
 
    // .... 省略 setting / getting 方法
}

public abstract class PropertiesInstanceConfig extends AbstractInstanceConfig implements EurekaInstanceConfig {
 
    /**
     * 命名空间
     */
    protected final String namespace;
    /**
     * 配置文件对象
     */
    protected final DynamicPropertyFactory configInstance;
    /**
     * 应用分组
     * 从 环境变量 获取
     */
    private String appGrpNameFromEnv;
 
    public PropertiesInstanceConfig() {
        this(CommonConstants.DEFAULT_CONFIG_NAMESPACE);
    }
 
    public PropertiesInstanceConfig(String namespace) {
        this(namespace, new DataCenterInfo() {
            @Override
            public Name getName() {
                return Name.MyOwn;
            }
        });
    }
 
    public PropertiesInstanceConfig(String namespace, DataCenterInfo info) {
        super(info);
        // 设置 namespace，为 "." 结尾
        this.namespace = namespace.endsWith(".")
                ? namespace
                : namespace + ".";
        // 从 环境变量 获取 应用分组
        appGrpNameFromEnv = ConfigurationManager.getConfigInstance()
                .getString(FALLBACK_APP_GROUP_KEY, Values.UNKNOWN_APPLICATION);
        // 初始化 配置文件对象
        this.configInstance = Archaius1Utils.initConfig(CommonConstants.CONFIG_FILE_NAME);
    }
 
    @Override
    public String getAppGroupName() {
        return configInstance.getStringProperty(namespace + APP_GROUP_KEY, appGrpNameFromEnv).get().trim();
    }
}

public final class Archaius1Utils {
private static final Logger logger = LoggerFactory.getLogger(Archaius1Utils.class);
 
private static final String ARCHAIUS_DEPLOYMENT_ENVIRONMENT = "archaius.deployment.environment";
private static final String EUREKA_ENVIRONMENT = "eureka.environment";
 
public static DynamicPropertyFactory initConfig(String configName) {
   // 配置文件对象
   DynamicPropertyFactory configInstance = DynamicPropertyFactory.getInstance();
   // 配置文件名
   DynamicStringProperty EUREKA_PROPS_FILE = configInstance.getStringProperty("eureka.client.props", configName);
   // 配置文件环境
   String env = ConfigurationManager.getConfigInstance().getString(EUREKA_ENVIRONMENT, "test");
   ConfigurationManager.getConfigInstance().setProperty(ARCHAIUS_DEPLOYMENT_ENVIRONMENT, env);
   // 将配置文件加载到环境变量
   String eurekaPropsFile = EUREKA_PROPS_FILE.get();
   try {
       ConfigurationManager.loadCascadedPropertiesFromResources(eurekaPropsFile);
   } catch (IOException e) {
       logger.warn(
               "Cannot find the properties specified : {}. This may be okay if there are other environment "
                       + "specific properties or the configuration is installed with a different mechanism.",
               eurekaPropsFile);
 
   }
   return configInstance;
}
}

public class MyDataCenterInstanceConfig extends PropertiesInstanceConfig implements EurekaInstanceConfig {
 
    public MyDataCenterInstanceConfig() {
    }
 
    public MyDataCenterInstanceConfig(String namespace) {
        super(namespace);
    }
 
    public MyDataCenterInstanceConfig(String namespace, DataCenterInfo dataCenterInfo) {
        super(namespace, dataCenterInfo);
    }
 
}

  @Singleton
  public class EurekaConfigBasedInstanceInfoProvider implements Provider<InstanceInfo> {
      private static final Logger LOG = LoggerFactory.getLogger(EurekaConfigBasedInstanceInfoProvider.class);
   
      private final EurekaInstanceConfig config;
   
      private InstanceInfo instanceInfo;
   
      @Inject(optional = true)
      private VipAddressResolver vipAddressResolver = null;
 
      @Inject
      public EurekaConfigBasedInstanceInfoProvider(EurekaInstanceConfig config) {
          this.config = config;
      }
 
      @Override
      public synchronized InstanceInfo get() {
          if (instanceInfo == null) {
              // Build the lease information to be passed to the server based on config
              // 创建 租约信息构建器，并设置属性
              LeaseInfo.Builder leaseInfoBuilder = LeaseInfo.Builder.newBuilder()
                      .setRenewalIntervalInSecs(config.getLeaseRenewalIntervalInSeconds())
                      .setDurationInSecs(config.getLeaseExpirationDurationInSeconds());
 
              // 创建 VIP地址解析器
              if (vipAddressResolver == null) {
                  vipAddressResolver = new Archaius1VipAddressResolver();
              }
 
              // Builder the instance information to be registered with eureka server
              // 创建 应用实例信息构建器
              InstanceInfo.Builder builder = InstanceInfo.Builder.newBuilder(vipAddressResolver);
 
              // 应用实例编号
              // set the appropriate id for the InstanceInfo, falling back to datacenter Id if applicable, else hostname
              String instanceId = config.getInstanceId();
              DataCenterInfo dataCenterInfo = config.getDataCenterInfo();
              if (instanceId == null || instanceId.isEmpty()) {
                  if (dataCenterInfo instanceof UniqueIdentifier) {
                      instanceId = ((UniqueIdentifier) dataCenterInfo).getId();
                  } else {
                      instanceId = config.getHostName(false);
                  }
              }
 
              // 获得 主机名
              String defaultAddress;
              if (config instanceof RefreshableInstanceConfig) {
                  // Refresh AWS data center info, and return up to date address
                  defaultAddress = ((RefreshableInstanceConfig) config).resolveDefaultAddress(false);
              } else {
                  defaultAddress = config.getHostName(false);
              }
              // fail safe
              if (defaultAddress == null || defaultAddress.isEmpty()) {
                  defaultAddress = config.getIpAddress();
              }
 
              // 设置 应用实例信息构建器 的 属性
              builder.setNamespace(config.getNamespace())
                      .setInstanceId(instanceId)
                      .setAppName(config.getAppname())
                      .setAppGroupName(config.getAppGroupName())
                      .setDataCenterInfo(config.getDataCenterInfo())
                      .setIPAddr(config.getIpAddress())
                      .setHostName(defaultAddress) // 主机名
                      .setPort(config.getNonSecurePort())
                      .enablePort(PortType.UNSECURE, config.isNonSecurePortEnabled())
                      .setSecurePort(config.getSecurePort())
                      .enablePort(PortType.SECURE, config.getSecurePortEnabled())
                      .setVIPAddress(config.getVirtualHostName()) // VIP 地址
                      .setSecureVIPAddress(config.getSecureVirtualHostName())
                      .setHomePageUrl(config.getHomePageUrlPath(), config.getHomePageUrl())
                      .setStatusPageUrl(config.getStatusPageUrlPath(), config.getStatusPageUrl())
                      .setASGName(config.getASGName())
                      .setHealthCheckUrls(config.getHealthCheckUrlPath(),
                              config.getHealthCheckUrl(), config.getSecureHealthCheckUrl());
 
              // 应用初始化后是否开启
              // Start off with the STARTING state to avoid traffic
              if (!config.isInstanceEnabledOnit()) {
                  InstanceStatus initialStatus = InstanceStatus.STARTING;
                  LOG.info("Setting initial instance status as: " + initialStatus);
                  builder.setStatus(initialStatus);
              } else {
                  LOG.info("Setting initial instance status as: {}. This may be too early for the instance to advertise "
                           + "itself as available. You would instead want to control this via a healthcheck handler.",
                           InstanceStatus.UP);
              }
 
              // 设置 应用实例信息构建器 的 元数据( Metadata )集合
              // Add any user-specific metadata information
              for (Map.Entry<String, String> mapEntry : config.getMetadataMap().entrySet()) {
                  String key = mapEntry.getKey();
                  String value = mapEntry.getValue();
                  builder.add(key, value);
              }
 
             // 创建 应用实例信息
             instanceInfo = builder.build();
 
             // 设置 应用实例信息 的 租约信息
             instanceInfo.setLeaseInfo(leaseInfoBuilder.build());
         }
         return instanceInfo;
     }
 
 }

public class ApplicationInfoManager {
 
    /**
     * 单例
     */
    private static ApplicationInfoManager instance = new ApplicationInfoManager(null, null, null);
 
    /**
     * 状态变更监听器
     */
    protected final Map<String, StatusChangeListener> listeners;
    /**
     * 应用实例状态匹配
     */
    private final InstanceStatusMapper instanceStatusMapper;
    /**
     * 应用实例信息
     */
    private InstanceInfo instanceInfo;
    /**
     * 应用实例配置
     */
    private EurekaInstanceConfig config;
 
    // ... 省略其它构造方法
 
    public ApplicationInfoManager(EurekaInstanceConfig config, InstanceInfo instanceInfo, OptionalArgs optionalArgs) {
        this.config = config;
        this.instanceInfo = instanceInfo;
        this.listeners = new ConcurrentHashMap<String, StatusChangeListener>();
        if (optionalArgs != null) {
            this.instanceStatusMapper = optionalArgs.getInstanceStatusMapper();
        } else {
            this.instanceStatusMapper = NO_OP_MAPPER;
        }
 
        // Hack to allow for getInstance() to use the DI'd ApplicationInfoManager
        instance = this;
    }
 
    // ... 省略其它方法
}