PostgreSQL-集群管理器-pgclusteradmin__pgclusteradmin是一款基于go开发的PostgreSQL集群管理工具，当前主要功能是实现对PostgreSQL服务进行管理，主备切换进行管理；系统支持多用户,操作认证。<br> 操作人员通过浏览器从远程登录进入管理平台，前台界面使用easyui实现。: 世界上功能最强大的开源数据库...

PostgreSQL-集群管理器-pgclusteradmin

阿弟 2017-3-7

欢迎大家踊跃投稿，投稿信箱：press@postgres.cn

阿弟，自2001年就开始使用postgresql，为中国较早的postgresql使用者。自2003年底至2014年一直担任PGSQL中国社区论坛“PostgreSQL的论坛”板块版主、管理员，参与Postgresql讨论并发表专题文章7000多帖。拥有15年的erp设计、开发和实施经验，为开源mrp系统PostMRP的作者，该系统是一套基于Postgresql专业的制造业管理软件系统。目前任职于中国第一物流控股有限公司/运力宝（北京）科技有限公司，任研发部经理。

pgclusteradmin是一款基于go开发的PostgreSQL集群管理工具，当前主要功能是实现对PostgreSQL服务进行管理，主备切换进行管理；系统支持多用户，操作认证；操作人员通过浏览器从远程登录进入管理平台，前台界面使用easyui实现。

功能列表

节点资料增加、编辑、删除
单一节点服务start、stop、restart、reload及显示服务状态
主备节点一键切换

部署环境

IP：192.168.1.10
OS：centos 7.0
golang: go version go1.7.4 linux/amd64
Postgresql：9.6.1

部署方法

安装golang

[root@ad ~]# yum install golang-1.7.4-1.el6.x86_64.rpm  
[root@ad ~]# yum install golang-src-1.7.4-1.el6.noarch.rpm
[root@ad ~]# yum install golang-bin-1.7.4-1.el6.x86_64.rpm

安装PostgreSQL

使用PostgreSQL主要是用于存储管理节点资料，操作员资料及操作日志

－－下载源码

wget https://ftp.postgresql.org/pub/source/v9.6.1/postgresql-9.6.1.tar.gz

－－解压

tar zxf postgresql-9.6.1.tar.gz

－－编译

cd postgresql-9.6.1
./configure --prefix=/usr/local/pgsql9.6.1 --with-perl --with-tcl --with-python 
 --with-openssl --with-pam --without-ldap --with-libxml --with-libxslt
gmake 
gmake install

－－初始化

su postgres
/usr/local/pgsql9.6.1/bin/initdb -D /home/postgres/data9.6.1 -E utf8 -U postgres -W

－－postgresql.conf配置

listen_addresses = '*'
log_destination = 'stderr'
logging_collector = on

－－pg_hba.conf配置

# IPv4 local connections:
host    all             all             192.168.1.0/24          md5

配置完成后需要重启服务,其它参数视需要自己配置

建立pgclusteradmin库并导入建立资料表

/usr/local/pgsql9.6.1/bin/psql -h 192.168.1.10 -U postgres -d postgres -p 5432 
postgres=# create database pgcluster ENCODING 'utf8' template template0;
\c pgcluster

－－导入下面数据表及数据

－－节点资料表

create table nodes (
   id serial not null unique,
   node_name text not null unique,    
   createtime timestamp not null default now(),
   host text not null,          
   ssh_port integer not null,
   ssh_user text not null,
   ssh_password text not null,  
   pg_bin text not null,
   pg_data text not null,
   pg_port integer not null,
   pg_database text not null,
   pg_user text not null,
   pg_password text not null,
   master_vip text,
   master_vip_networkcard text,
   slave_vip text,
   slave_vip_networkcard text,
   bind_vip_user text,
   bind_vip_password text,   
   remark text 
);

COMMENT ON TABLE nodes IS '节点资料表';
COMMENT ON COLUMN nodes.id IS '系统编号';
COMMENT ON COLUMN nodes.node_name IS '节点名称';   
COMMENT ON COLUMN nodes.createtime IS '建立时间';   
COMMENT ON COLUMN nodes.host IS '主机名或ip';   
COMMENT ON COLUMN nodes.ssh_port IS 'ssh服务端口号';   
COMMENT ON COLUMN nodes.ssh_user IS 'ssh用户';   
COMMENT ON COLUMN nodes.ssh_password IS 'ssh密码';  
COMMENT ON COLUMN nodes.pg_bin IS 'pg管理程序所在路径';    
COMMENT ON COLUMN nodes.pg_data IS 'pgDATA所在路径';      
COMMENT ON COLUMN nodes.pg_port IS 'pg服务端口号';   
COMMENT ON COLUMN nodes.pg_user IS 'pg用户';   
COMMENT ON COLUMN nodes.pg_password IS 'pg密码';   
COMMENT ON COLUMN nodes.master_vip IS '主节点时绑定VIP'; 
COMMENT ON COLUMN nodes.master_vip_networkcard IS '主节点时绑定网卡设备号';                  
COMMENT ON COLUMN nodes.slave_vip IS '备节点时绑定VIP';                  
COMMENT ON COLUMN nodes.slave_vip_networkcard IS '备节点时绑定网卡设备号';                  
COMMENT ON COLUMN nodes.bind_vip_user IS '绑定网卡操作用户';                  
COMMENT ON COLUMN nodes.bind_vip_password IS '绑定网卡操作密码';

--操作员资料表

CREATE TABLE users (
    id serial not null unique,
    username text not null unique,
    password text not null
);

COMMENT ON TABLE users IS '操作员资料表';
COMMENT ON COLUMN users.id IS '系统编号';
COMMENT ON COLUMN users.username IS '登录账号';
COMMENT ON COLUMN users.password IS '登录密码md5值';

--增加一个操作员记录表

INSERT INTO users (username,password) values('admin',md5('admin'));

--操作日志表

CREATE TABLE log (
    id serial not null unique,
    createtime timestamp not null default now(),
    remote_ip text,
    modlename text,
    username text,
    log_level text,
    remark text 
);

COMMENT ON TABLE log IS '日志表';
COMMENT ON COLUMN log.id IS '系统编号';
COMMENT ON COLUMN log.createtime IS '访问时间';
COMMENT ON COLUMN log.remote_ip IS '访问客户端ip地址';
COMMENT ON COLUMN log.username IS '用户名';  
COMMENT ON COLUMN log.modlename IS '模块名称';
COMMENT ON COLUMN log.log_level IS '日志级别';
COMMENT ON COLUMN log.remark IS '日志内容';

下载pgclusteradmin所需要的go支持包

－－ssh支持包

[root@ad ~]# cd /usr/lib/golang/src
[root@ad src]# mkdir golang.org
[root@ad src]# cd golang.org/
[root@ad golang.org]# mkdir x
[root@ad src]# cd x/
[root@ad x]# git clone https://github.com/golang/crypto.git
正克隆到 'crypto'...
remote: Counting objects: 3256, done.
remote: Total 3256 (delta 0), reused 0 (delta 0), pack-reused 3255
接收对象中: 100% (3256/3256), 2.31 MiB | 958.00 KiB/s, done.
处理 delta 中: 100% (2106/2106), done.

－－session支持包

[root@ad x]# cd /usr/lib/golang/src
[root@ad src]# mkdir github.com
[root@ad src]# cd github.com
[root@ad github.com]# mkdir astaxie
[root@ad github.com]# cd astaxie/
[root@ad astaxie]# git clone https://github.com/astaxie/session
正克隆到 'session'...
remote: Counting objects: 50, done.
remote: Total 50 (delta 0), reused 0 (delta 0), pack-reused 50
Unpacking objects: 100% (50/50), done.
[root@ad astaxie]# ll
总用量 8

－－postgresql操作支持包

[root@ad astaxie]# cd /usr/lib/golang/src/github.com/
[root@ad github.com]# mkdir jackc
[root@ad github.com]# cd jackc
[root@ad jackc]# git clone https://github.com/jackc/pgx
正克隆到 'pgx'...
remote: Counting objects: 3613, done.
remote: Compressing objects: 100% (243/243), done.
remote: Total 3613 (delta 157), reused 0 (delta 0), pack-reused 3370
接收对象中: 100% (3613/3613), 1.24 MiB | 228.00 KiB/s, done.
处理 delta 中: 100% (2481/2481), done.

部署配置和访问

下载pgclusteradmin源码

[root@ad pgclusteradmin]# cd /home/ad
[root@ad ad]# git clone https://github.com/chenaisheng/pgclusteradmin
正克隆到 'pgclusteradmin'...
remote: Counting objects: 374, done.
remote: Compressing objects: 100% (177/177), done.
remote: Total 374 (delta 201), reused 348 (delta 185), pack-reused 0
接收对象中: 100% (374/374), 284.09 KiB | 197.00 KiB/s, done.
处理 delta 中: 100% (201/201), done.
[root@ad ad]#

配置连接数据库参数

打开pgclusteradmin.go文件，拉下最后面，找到函数extractConfig()，代码如下所示

/*
功能描述：配置postgresql连接参数 
            
参数说明：无  

返回值说明： 
pgx.ConnConfig -- pg连接参数结构体
*/

func extractConfig() pgx.ConnConfig {

    var config pgx.ConnConfig

    config.Host = "192.168.1.10" //数据库主机host或ip
    config.User = "postgres"     //连接用户
    config.Password = "pgsql"    //用户密码
    config.Database = "pgcluster" //连接数据库名
    config.Port = 5432            //端口号
    
    return config       
}

修改成上面部署postgresql的相应参数即可

运行pgclusteradmin

[root@ad ad]# cd pgclusteradmin/
[root@ad pgclusteradmin]# go run pgclusteradmin.g

访问pgclusteradmin

打开一个浏览器，输入 http://192.168.1.10:10001即可进入管理器，192.168.1.10换成你自己ip地址即可。

使用说明

主界面说明

增加要维护的节点资料

编辑窗口如下所示

说明：

1、要维护的节点如果非主备节点，则不需要配置vip相关参数

2、Vip绑定和解绑“设备号”如果不清楚请询问你们的sa,千万别配置错了，用命令ip a可查询“设备号”

3、编辑完成后按“保存”即可

编辑节点资料

说明：节点资料维护窗口跟新增节点资料一致，说明请参考“增加节点”

删除节点资料

节点服务管理

弹出窗口如下所示

说明：

1、关闭模式只能stop/restart操作有作用

2、执行返回的结果显示在“执行结果”显示框中

主备节点切换管理

弹出窗口如下所示，下面是显示“主节点”信息

说明：

1、点击“刷新ip绑定详情”，可以把节点的最新ip绑定情况显示到“IP绑定详情”框里面

2、主备切换只能同时勾选两个节点记录

3、两个节点必需是一主一备

4、要切换的两个节点当前状态必需是处于“运行中”

5、系统自动判断两个节点是否为主备关系

6、如果需要解绑和绑定vip的话，则需要配置绑定vip的操作用户和密码，一般为root

7、系统自动检测绑定的vip是否被其它节点使用

8、设置完参数后，按“一键切换”即可

下图是“切换参数配置”框

修改登录密码

下面是修改登录密码窗口

说明：

1、修改登录密码需要先输入旧的登录密码

2、新的密码需要连续连接两次

3、录入完成后按“确认修改”即可完成登录密码的修改

退出登录状态

退出后系统返回到登录页面

开发计划

短期

1、增加单节点vip管理

2、增加postgresql参数配置

3、增加操作员管理

4、增加权限管理

5、根据go的异步执行特性，重写部分代码，提高应用执行效率

长期

1、数据库相关对象管理模块

2、数据库一些指标监控模块

3、数据库巡检相关模块