分布式配置管理--百度disconf搭建过程和详细使用

先说官方文档:http://disconf.readthedocs.io/zh_CN/latest/index.html

不管是否要根据官方文档来搭建disconf,都应该看一下这一份文档.精炼清晰地介绍了disconf的功能和其他一些包含的东西.看完至少对disconf已经有了大概的了解

disconf: https://github.com/knightliao/disconf(管理端)
demos: https://github.com/knightliao/disconf-demos-java(客户端)
wiki: https://github.com/knightliao/disconf/wiki(wiki)

我搭建的页面:

开始步骤吧:

安装Mysql（Ver 14.12 Distrib 5.0.45, for unknown-linux-gnu (x86_64) using EditLine wrapper）
安装Tomcat（apache-tomcat-7.0.50）
安装Nginx（nginx/1.5.3）
安装 zookeeeper （zookeeper-3.3.0）
安装 Redis （2.4.5）

其中安装redis和nginx稍微麻烦一些,参考:

　　http://www.cnblogs.com/garfieldcgf/p/6438898.html

　　http://www.cnblogs.com/garfieldcgf/p/6438814.html

开始配置:

将你的配置文件放到此地址目录下（以下地址可自行设定）：

/home/work/dsp/disconf-rd/online-resources

我的路径与这个不同,为了避免引起不必要的贴图错误,按照官方的来

拷贝/disconf-web/profile/rd/目录下的文件，拷贝过去后修改即可。

配置文件包括

- jdbc-mysql.properties (数据库配置)
- redis-config.properties (Redis配置，主要用于web登录使用)
- zoo.properties (Zookeeper配置)
- application.properties (应用配置）

cp application-demo.properties application.properties

注意，即使只有一个redis，也应该配置两个redis client，否则将造成内部错误。*

设置War包将要被部署的地址（以下地址可自行设定）：

/home/work/dsp/disconf-rd/war

构建

ONLINE_CONFIG_PATH=/home/work/dsp/disconf-rd/online-resources
WAR_ROOT_PATH=/home/work/dsp/disconf-rd/war
export ONLINE_CONFIG_PATH
export WAR_ROOT_PATH
cd disconf-web
sh deploy/deploy.sh

这样会在 /home/work/dsp/disconf-rd/war 生成以下结果：

-disconf-web.war
-html
-META-INF
-WEB-INF

还有其他的配置文件也都会在这个目录下

上线前的初始化工作

初始化数据库：

可以参考 sql/readme.md 来进行数据库的初始化。注意顺序执行

0-init_table.sql

1-init_data.sql

201512/20151225.sql

20160701/20160701.sql

里面默认有6个用户（请注意线上环境删除这些用户以避免潜在的安全问题）

name	pwd
admin	admin
testUser1	MhxzKhl9209
testUser2	MhxzKhl167
testUser3	MhxzKhl783
testUser4	MhxzKhl8758
testUser5	MhxzKhl112

如果想自己设置初始化的用户名信息，可以参考代码来自己生成用户：

src/main/java/com/baidu/disconf/web/tools/UserCreateTools.java

部署War

修改server.xml文件，在Host结点下设定Context：

<Context path="" docBase="/home/work/dsp/disconf-rd/war"></Context>

并设置端口为 8015

启动Tomcat，即可。

部署前端

修改 nginx.conf

upstream disconf {server 127.0.0.1:8015;
}server {listen   8081;server_name disconf.com;access_log /home/work/var/logs/disconf/access.log;error_log /home/work/var/logs/disconf/error.log;location / {root /home/work/dsp/disconf-rd/war/html;if ($query_string) {expires max;}}location ~ ^/(api|export) {proxy_pass_header Server;proxy_set_header Host $http_host;proxy_redirect off;proxy_set_header X-Real-IP $remote_addr;proxy_set_header X-Scheme $scheme;proxy_pass http://disconf;
    }
}

这里的配置没有贴全,有些人可能会配错.我贴一份全的(因为对nginx不熟悉,我也遇到了一些小麻烦)

user  root;
worker_processes  1;#error_log  logs/error.log;
#error_log  logs/error.log  notice;
#error_log  logs/error.log  info;#pid        logs/nginx.pid;events {worker_connections  1024;
}http {include       mime.types;default_type  application/octet-stream;#log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '#                  '$status $body_bytes_sent "$http_referer" '#                  '"$http_user_agent" "$http_x_forwarded_for"';#access_log  logs/access.log  main;sendfile        on;#tcp_nopush     on;#keepalive_timeout  0;keepalive_timeout  65;gzip  on;gzip_http_version 1.0;gzip_disable "MSIE [1-6].";gzip_types text/plain application/x-javascript text/css text/javascript application/x-httpd-php image/jpeg image/gif image/png;upstream disconf {server 10.10.10.10:8015;
}server {listen   8081;server_name disconftest.com;access_log /home/work/dsp/access.log;error_log /home/work/dsp/error.log;location / {root /home/docker/garfield/war/html;if ($query_string) {expires max;}}location ~ ^/(api|export) {proxy_pass_header Server;proxy_set_header Host $http_host;proxy_redirect off;proxy_set_header X-Real-IP $remote_addr;proxy_set_header X-Scheme $scheme;proxy_pass http://disconf;
    }
}
}

这里我把server name改成了disconftest.com,跟application.properties里面的配置保持一样即可,

注意:

　　1.须保证日志文件的写入有权限哦,日志文件夹提前建好,否则会报错

　　2.开头是运行权限,这边因为没有用root运行会导致页面持续被拦截,报403,有遇到的人注意下

服务管理端的部署到这里就结束了,启动zookeeper,redis,tomcat,mysql和nginx就可以访问页面了,输入

http://10.10.10.10:8081/

看到如下页面就成功了:

输入admin/admin发现里面已经有一些配置,但是没有机器在运行,接下来进行客户端应用

其实git下载下来的demo直接运行就可以看到配置文件的下载了,当然要配置访问的服务端地址.这方面就不赘述了,记录一下我的两个实践

1.将xml下载到指定路径--将mybatis.xml文件从平台上下载,统一管理

先写一个简单的mybatis应用程序(打印出数据库所有用户表名称),主要类:

@Service
@Transactional
public class UserService {private static Logger  logger  = LogManager.getLogger(UserService.class);@Autowiredprivate UserDao userMapper;public List<User> searchAll(){List<User> list = userMapper.findAll();for (User user : list) {System.out.println(user.getUsername());}return list;}
}

主函数:

/*** @author garfield* @version 2017-2-17*/
public class DisconfDemoMain {private static String[] fn = null;// 初始化spring文档private static void contextInitialized() {fn = new String[] {"applicationContext.xml"};}/*** @param args** @throws Exception*/public static void main(String[] args) throws Exception {contextInitialized();ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext(fn);UserService userService = ctx.getBean("userService", UserService.class);while (true){userService.searchAll();Thread.sleep(10000);}}
}

配置类:

import com.baidu.disconf.client.common.annotations.DisconfFile;
import com.baidu.disconf.client.common.annotations.DisconfUpdateService;
import com.baidu.disconf.client.common.update.IDisconfUpdate;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service;/*** Created by garfield on 2017/2/23.*/
@Service
@Scope("singleton")
@DisconfFile(filename = "UserMapper.xml",targetDirPath = "cloud/simple/service/dao")
@DisconfUpdateService(classes = {XMLConfig.class})
public class XMLConfig implements IDisconfUpdate {public void reload() throws Exception {System.out.println("=====================================================================");}
}

targetDirPath是配置下载到指定的路径中,这种情况下,profile里面的disconf.enable_local_download_dir_in_class_path配置项须置为true,运行后效果如下:

输出:

16:40:47.484 [main] DEBUG o.m.s.t.SpringManagedTransaction - JDBC Connection [ProxyConnection[PooledConnection[com.mysql.jdbc.JDBC4Connection@1f6f7075]]] will not be managed by Spring
16:40:47.489 [main] DEBUG c.simple.service.dao.UserDao.findAll - ==>  Preparing: select * from user
16:40:47.513 [main] DEBUG c.simple.service.dao.UserDao.findAll - ==> Parameters:
16:40:47.532 [main] DEBUG c.simple.service.dao.UserDao.findAll - <==      Total: 2
16:40:47.533 [main] DEBUG org.mybatis.spring.SqlSessionUtils - Closing non transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@7eadb544]
username = 1
username = 2

2.第二个实例,将log4j2.xml日志配置文件统一管理

这个例子其实关键在于手动加载日志,本身实际上也是一个下载xml文件的过程

配置类:

import com.baidu.disconf.client.common.annotations.DisconfFile;
import com.baidu.disconf.client.common.annotations.DisconfUpdateService;
import com.baidu.disconf.client.common.update.IDisconfUpdate;
import org.springframework.context.annotation.Scope;
import org.springframework.stereotype.Service;/*** Created by garfield on 2017/2/23.*/
@Service
@Scope("singleton")
@DisconfFile(filename = "log4j2.xml")
@DisconfUpdateService(classes = {XMLConfig.class})
public class LogConfig implements IDisconfUpdate {public void reload() throws Exception {System.out.println("=====================================================================");}
}

下载下来之后log4j.xml文件的位置:(与工程同级)

在主函数做一个加载动作:

import cloud.simple.service.domain.UserService;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.core.config.Configurator;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.apache.logging.log4j.core.config.ConfigurationSource;
import java.io.File;
import java.io.FileInputStream;
import java.net.URL;/*** @author garfield* @version 2017-2-17*/
public class DisconfDemoMain {private static String[] fn = null;private static Logger logger;// 初始化spring文档private static void contextInitialized() {fn = new String[] {"applicationContext.xml"};}/*** @param args** @throws Exception*/public static void main(String[] args) throws Exception {contextInitialized();ClassPathXmlApplicationContext ctx = new ClassPathXmlApplicationContext(fn);
        //此处加载日志文件URL url=DisconfDemoMain.class.getResource("/log4j2.xml");System.out.println(url.getPath());ConfigurationSource  source = new ConfigurationSource(new FileInputStream(new File(url.getPath())),url);Configurator.initialize(null, source);logger  = LogManager.getLogger(DisconfDemoMain.class);UserService userService = ctx.getBean("userService", UserService.class);logger.info("begin to search...");while (true){userService.searchAll();Thread.sleep(10000);}}
}

运行后查看一下日志文件是否生效:

2017-02-24 16:46:01,467 INFO  main (cloud.simple.service.DisconfDemoMain) - begin to search...
2017-02-24 16:46:01,820 INFO  main (cloud.simple.service.domain.UserService) - =========================
2017-02-24 16:46:01,820 INFO  main (cloud.simple.service.domain.UserService) - username = 1
2017-02-24 16:46:01,820 INFO  main (cloud.simple.service.domain.UserService) - =========================
2017-02-24 16:46:01,820 INFO  main (cloud.simple.service.domain.UserService) - username = 2

demo中还有一些其他的例子,不过看文档大概也能明白,就不说明了.

done!

转载于:https://www.cnblogs.com/garfieldcgf/p/6439221.html