程序包 com.alibaba.nacos.client.config.impl

类 ConfigTransportClient

  • 直接已知子类:
    ClientWorker.ConfigRpcTransportClient
    public abstract class ConfigTransportClient
extends java.lang.Object
    config transport client,include basic operations of config module.
    版本:
    $Id: ConfigTransportClient.java, v 0.1 2020年08月24日 2:01 PM liuzunfei Exp $
    作者:
    liuzunfei

    • 字段详细资料

      • LOGGER

        private static final org.slf4j.Logger LOGGER

      • SECURITY_TOKEN_HEADER

        private static final java.lang.String SECURITY_TOKEN_HEADER
        另请参阅:
        常量字段值

      • ACCESS_KEY_HEADER

        private static final java.lang.String ACCESS_KEY_HEADER
        另请参阅:
        常量字段值

      • CONFIG_INFO_HEADER

        private static final java.lang.String CONFIG_INFO_HEADER
        另请参阅:
        常量字段值

      • DEFAULT_CONFIG_INFO

        private static final java.lang.String DEFAULT_CONFIG_INFO
        另请参阅:
        常量字段值

      • encode

        java.lang.String encode

      • tenant

        java.lang.String tenant

      • executor

        java.util.concurrent.ScheduledExecutorService executor

      • maxRetry

        private int maxRetry

      • securityInfoRefreshIntervalMills

        private final long securityInfoRefreshIntervalMills

      • accessKey

        private java.lang.String accessKey

      • secretKey

        protected java.lang.String secretKey

    • 构造器详细资料

      • ConfigTransportClient

        public ConfigTransportClient​(java.util.Properties properties,
                             ServerListManager serverListManager)

    • 方法详细资料

      • shutdown

        public void shutdown()

      • getSpasHeaders

        protected java.util.Map<java.lang.String,​java.lang.String> getSpasHeaders()
                                                                         throws java.lang.Exception
        Spas-SecurityToken/Spas-AccessKey.
        返回:
        spas headers map.
        抛出:
        java.lang.Exception - exeption may throw.

      • getSecurityHeaders

        protected java.util.Map<java.lang.String,​java.lang.String> getSecurityHeaders()
        get accessToken from server of using username/password.
        返回:
        map that contains accessToken , null if acessToken is empty.

      • getCommonHeader

        protected java.util.Map<java.lang.String,​java.lang.String> getCommonHeader()
        get common header.
        返回:
        headers.

      • getAccessToken

        public java.lang.String getAccessToken()

      • getStsResponse

        private static java.lang.String getStsResponse()
                                        throws java.lang.Exception
        抛出:
        java.lang.Exception

      • initAkSk

        private void initAkSk​(java.util.Properties properties)

      • initMaxRetry

        private void initMaxRetry​(java.util.Properties properties)

      • setExecutor

        public void setExecutor​(java.util.concurrent.ScheduledExecutorService executor)

      • start

        public void start()
           throws com.alibaba.nacos.api.exception.NacosException
        base start client.
        抛出:
        com.alibaba.nacos.api.exception.NacosException

      • startInternal

        public abstract void startInternal()
                            throws com.alibaba.nacos.api.exception.NacosException
        start client inner.
        抛出:
        com.alibaba.nacos.api.exception.NacosException - exception may throw.

      • getName

        public abstract java.lang.String getName()
        get client name.
        返回:
        name.

      • getEncode

        public java.lang.String getEncode()
        get encode.
        返回:
        encode.

      • getTenant

        public java.lang.String getTenant()
        get tenant.
        返回:
        tenant.

      • notifyListenConfig

        public abstract void notifyListenConfig()
        notify listen config.

      • executeConfigListen

        public abstract void executeConfigListen()
        listen change .

      • removeCache

        public abstract void removeCache​(java.lang.String dataId,
                                 java.lang.String group)
        remove cache implements.
        参数:
        dataId - dataId.
        group - group

      • queryConfig

        public abstract ConfigResponse queryConfig​(java.lang.String dataId,
                                           java.lang.String group,
                                           java.lang.String tenat,
                                           long readTimeous,
                                           boolean notify)
                                    throws com.alibaba.nacos.api.exception.NacosException
        query config.
        参数:
        dataId - dataId.
        group - group.
        tenat - tenat.
        readTimeous - readTimeous.
        notify - query for notify sync.
        返回:
        content.
        抛出:
        com.alibaba.nacos.api.exception.NacosException - throw where query fail .

      • publishConfig

        public abstract boolean publishConfig​(java.lang.String dataId,
                                      java.lang.String group,
                                      java.lang.String tenant,
                                      java.lang.String appName,
                                      java.lang.String tag,
                                      java.lang.String betaIps,
                                      java.lang.String content,
                                      java.lang.String encryptedDataKey,
                                      java.lang.String casMd5,
                                      java.lang.String type)
                               throws com.alibaba.nacos.api.exception.NacosException
        publish config.
        参数:
        dataId - dataId.
        group - group.
        tenant - tenant.
        appName - appName.
        tag - tag.
        betaIps - betaIps.
        content - content.
        encryptedDataKey - encryptedDataKey
        casMd5 - casMd5.
        type - type.
        返回:
        success or not.
        抛出:
        com.alibaba.nacos.api.exception.NacosException - throw where publish fail.

      • removeConfig

        public abstract boolean removeConfig​(java.lang.String dataid,
                                     java.lang.String group,
                                     java.lang.String tenat,
                                     java.lang.String tag)
                              throws com.alibaba.nacos.api.exception.NacosException
        remove config.
        参数:
        dataid - dataid.
        group - group.
        tenat - tenat.
        tag - tag.
        返回:
        success or not.
        抛出:
        com.alibaba.nacos.api.exception.NacosException - throw where publish fail.