zoukankan      html  css  js  c++  java
  • springboot中引入zookeeper,生成 配置类

    1.application.properties

    zookeeper.address=@mvn.zookeeper.address@
    zookeeper.namespace=@mvn.zookeeper.namespace@
    

    2.pom.xml中多profile环境不同变量定义

    <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
    </properties>
    
    <profiles>
            <!-- 开发环境 -->
            <profile>
                <id>dev</id>
                <activation>
                    <activeByDefault>true</activeByDefault>
                </activation>
                <properties>
                    <mvn.zookeeper.address>localhost:2181</mvn.zookeeper.address>
                    <mvn.zookeeper.namespace>fama_server</mvn.zookeeper.namespace>
                </properties>
            </profile>
            <profile>
                <id>prod</id>
                <properties>
                    <mvn.zookeeper.address>10.176.83.32:2181,10.176.83.33:2181,10.176.83.34:2181</mvn.zookeeper.address>
                    <mvn.zookeeper.namespace>fama_server</mvn.zookeeper.namespace>
                </properties>
            </profile>
    </profiles>
    

    3.配置类

    ZookeeperConfig.java

    @Component
    @PropertySource("classpath:application.properties")
    public class ZookeeperConfig {
    
        //zk connect config
        @Value("${zookeeper.address}")
        private String serverList;
    
        @Value("${zookeeper.retry.base.sleep:100}")
        private int baseSleepTimeMs;
    
        @Value("${zookeeper.retry.max.sleep:30000}")
        private int maxSleepMs;
    
        @Value("${zookeeper.retry.maxtime:10}")
        private int maxRetries;
    
        @Value("${zookeeper.session.timeout:60000}")
        private int sessionTimeoutMs;
    
        @Value("${zookeeper.connection.timeout:30000}")
        private int connectionTimeoutMs;
    
        @Value("${zookeeper.connection.digest: }")
        private String digest;
    
        @Value("${zookeeper.fama.root:/fama}")
        private String dsRoot;
    
        @Value("${zookeeper.max.wait.time:10000}")
        private int maxWaitTime;
    
        @Value("${zookeeper.namespace}")
        private String nameSpace;
    
        public String getServerList() {
            return serverList;
        }
    
        public void setServerList(String serverList) {
            this.serverList = serverList;
        }
    
        public int getBaseSleepTimeMs() {
            return baseSleepTimeMs;
        }
    
        public void setBaseSleepTimeMs(int baseSleepTimeMs) {
            this.baseSleepTimeMs = baseSleepTimeMs;
        }
    
        public int getMaxSleepMs() {
            return maxSleepMs;
        }
    
        public void setMaxSleepMs(int maxSleepMs) {
            this.maxSleepMs = maxSleepMs;
        }
    
        public int getMaxRetries() {
            return maxRetries;
        }
    
        public void setMaxRetries(int maxRetries) {
            this.maxRetries = maxRetries;
        }
    
        public int getSessionTimeoutMs() {
            return sessionTimeoutMs;
        }
    
        public void setSessionTimeoutMs(int sessionTimeoutMs) {
            this.sessionTimeoutMs = sessionTimeoutMs;
        }
    
        public int getConnectionTimeoutMs() {
            return connectionTimeoutMs;
        }
    
        public void setConnectionTimeoutMs(int connectionTimeoutMs) {
            this.connectionTimeoutMs = connectionTimeoutMs;
        }
    
        public String getDigest() {
            return digest;
        }
    
        public void setDigest(String digest) {
            this.digest = digest;
        }
    
        public String getDsRoot() {
            return dsRoot;
        }
    
        public void setDsRoot(String dsRoot) {
            this.dsRoot = dsRoot;
        }
    
        public int getMaxWaitTime() {
            return maxWaitTime;
        }
    
        public void setMaxWaitTime(int maxWaitTime) {
            this.maxWaitTime = maxWaitTime;
        }
    
        public String getNameSpace() {
            return nameSpace;
        }
    
        public void setNameSpace(String nameSpace) {
            this.nameSpace = nameSpace;
        }
    }
    
  • 相关阅读:
    Gearman分布式任务处理系统(六)跨多种环境部署
    Gearman分布式任务处理系统(五)版本介绍、安装方法和使用说明
    Gearman分布式任务处理系统(四)Gearman协议
    Gearman分布式任务处理系统(三)libevent介绍
    Java课程笔记_4
    Lesson 13-14 How often do you exercise?
    Lesson 11-12 Men and Women
    Java课程笔记_3
    Lession 9-10 Cell Phone Taboos
    Lession 5-6 When you have a cold
  • 原文地址:https://www.cnblogs.com/PythonOrg/p/14596462.html
Copyright © 2011-2022 走看看