边缘云K8S离线高可用设计

public class CustomConfigFactory implements ConfigFactory {

    private static final Logger logger = LoggerFactory.getLogger(CustomConfigFactory.class);

    private final ConfigUtil configUtil = ApolloInjector.getInstance(ConfigUtil.class);

    public Config create(String namespace) {

        ConfigFileFormat format = this.determineFileFormat(namespace);
        long start = System.currentTimeMillis();
        ConfigRepository configRepository = ConfigFileFormat.isPropertiesCompatible(format)
            ? this.createPropertiesCompatibleFileConfigRepository(namespace, format)
            : this.createLocalConfigRepository(namespace);
        logger.debug("Create config repository spent {} ms", System.currentTimeMillis() - start);
        return this.createRepositoryConfig(namespace, configRepository);
    }

    protected Config createRepositoryConfig(String namespace, ConfigRepository configRepository) {

        return new DefaultConfig(namespace, configRepository);
    }

    public ConfigFile createConfigFile(String namespace, ConfigFileFormat configFileFormat) {

        ConfigRepository configRepository = this.createLocalConfigRepository(namespace);
        switch (configFileFormat) {
            case Properties:
                return new PropertiesConfigFile(namespace, configRepository);
            case XML:
                return new XmlConfigFile(namespace, configRepository);
            case JSON:
                return new JsonConfigFile(namespace, configRepository);
            case YAML:
                return new YamlConfigFile(namespace, configRepository);
            case YML:
                return new YmlConfigFile(namespace, configRepository);
            case TXT:
                return new TxtConfigFile(namespace, configRepository);
            default:
                return null;
        }
    }

    ConfigRepository createLocalConfigRepository(String namespace) {

        if (this.configUtil.isInLocalMode()) {
            logger.warn("==== Apollo is in local mode! Won't pull configs from remote server for namespace {} ! ====", namespace);
            return new LocalFileConfigRepository(namespace);
        } else if (ConfigSourceType.MONGO.name().equals(Foundation.server().getEnvType())) {
            logger.warn("==== Apollo is in mongo mode! Won't pull configs from remote server for namespace {} ! ====", namespace);
            return new LocalFileConfigRepository(namespace, new MongoConfigRepository(namespace, this.createRemoteConfigRepository(namespace)));
        } else {
            return new LocalFileConfigRepository(namespace, this.createRemoteConfigRepository(namespace));
        }
    }

    RemoteConfigRepository createRemoteConfigRepository(String namespace) {

        return new RemoteConfigRepository(namespace);
    }

    PropertiesCompatibleFileConfigRepository createPropertiesCompatibleFileConfigRepository(String namespace, ConfigFileFormat format) {

        String actualNamespaceName = this.trimNamespaceFormat(namespace, format);
        PropertiesCompatibleConfigFile configFile = (PropertiesCompatibleConfigFile)ConfigService.getConfigFile(actualNamespaceName, format);
        return new PropertiesCompatibleFileConfigRepository(configFile);
    }

    ConfigFileFormat determineFileFormat(String namespaceName) {

        String lowerCase = namespaceName.toLowerCase();
        ConfigFileFormat[] formats = ConfigFileFormat.values();
        for (ConfigFileFormat format : formats) {
            if (lowerCase.endsWith("." + format.getValue())) {
                return format;
            }
        }
        return ConfigFileFormat.Properties;
    }

    String trimNamespaceFormat(String namespaceName, ConfigFileFormat format) {

        String extension = "." + format.getValue();
        return !namespaceName.toLowerCase().endsWith(extension) ? namespaceName
            : namespaceName.substring(0, namespaceName.length() - extension.length());
    }
}

LIB_DIR=$DEPLOY_DIR/lib
#LIB_JARS=$LIB_DIR/*
LIB_JARS=$LIB_DIR/`ls $LIB_DIR | grep riemann-commons-apollo`:$LIB_DIR/*

if [ -z $JAVA_HOME ]; then
  JAVA=${SERVER_JAVA_HOME}
else
  JAVA=$JAVA_HOME/bin/java
fi
if [ -z "$DEPLOYMENT_NAME" ]; then
  JAVA=/usr/bin/java
fi
nohup $JAVA $JAVA_OPTS $JAVA_MEM_OPTS $JAVA_DEBUG_OPTS $JAVA_JMX_OPTS $JAVA_DUMP_OPTS $APP_ARGS -classpath $CONF_DIR:$LIB_JARS $MAINCLASS >$STDOUT_FILE 2>&1 &

PIDS=`ps -f | grep java | grep -v grep | grep "$DEPLOY_DIR" | awk '{print $2}'`
if [ -n "$PIDS" ]; then
    echo "start success!PID: $PIDS"
else
    echo "fail to start"
fi

if [ -n "$DEPLOYMENT_NAME" ]; then
EMERGENCY_NAME=riemann-emergency-app
mkdir -p /app/deploy/logs/${EMERGENCY_NAME}/
fs=`find /app/deploy -maxdepth 1 -mindepth 1 -print | grep -v logs | grep -v com | grep -v iast`;
for f in $fs;do
    echo "cp -Rf $f /app/deploy/logs/${EMERGENCY_NAME}/";
    cp -Rf $f /app/deploy/logs/${EMERGENCY_NAME}/;
done;
sed -i '4a\RIEMANN_BASE_ZNO='$RIEMANN_BASE_ZNO /app/deploy/logs/${EMERGENCY_NAME}/bin/start.sh
fi