• Nacos集群搭建

    一、Window下单机搭建.

    1、Nacos官方文档:Nacos 快速开始

    2、Nacos基于Java开发，部署一个Java应用，版本2.1.0，实际开发使用企业版，有完整权限和运维.

    3、Nacos存储配置在数据库中，简历对应的数据库和表结构，对应SQL如下，这里使用mysql存储.

    1. /*
    2.  * Copyright 1999-2018 Alibaba Group Holding Ltd.
    3.  *
    4.  * Licensed under the Apache License, Version 2.0 (the "License");
    5.  * you may not use this file except in compliance with the License.
    6.  * You may obtain a copy of the License at
    7.  *
    8.  *      http://www.apache.org/licenses/LICENSE-2.0
    9.  *
    10.  * Unless required by applicable law or agreed to in writing, software
    11.  * distributed under the License is distributed on an "AS IS" BASIS,
    12.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    13.  * See the License for the specific language governing permissions and
    14.  * limitations under the License.
    15.  */
    16.  
    17. /******************************************/
    18. /*   数据库全名 = nacos_config   */
    19. /*   表名称 = config_info   */
    20. /******************************************/
    21. CREATE TABLE `config_info` (
    22.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
    23.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    24.   `group_id` varchar(255) DEFAULT NULL,
    25.   `content` longtext NOT NULL COMMENT 'content',
    26.   `md5` varchar(32) DEFAULT NULL COMMENT 'md5',
    27.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    28.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    29.   `src_user` text COMMENT 'source user',
    30.   `src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip',
    31.   `app_name` varchar(128) DEFAULT NULL,
    32.   `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',
    33.   `c_desc` varchar(256) DEFAULT NULL,
    34.   `c_use` varchar(64) DEFAULT NULL,
    35.   `effect` varchar(64) DEFAULT NULL,
    36.   `type` varchar(64) DEFAULT NULL,
    37.   `c_schema` text,
    38.   `encrypted_data_key` text NOT NULL COMMENT '秘钥',
    39.   PRIMARY KEY (`id`),
    40.   UNIQUE KEY `uk_configinfo_datagrouptenant` (`data_id`,`group_id`,`tenant_id`)
    41. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info';
    42.  
    43. /******************************************/
    44. /*   数据库全名 = nacos_config   */
    45. /*   表名称 = config_info_aggr   */
    46. /******************************************/
    47. CREATE TABLE `config_info_aggr` (
    48.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
    49.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    50.   `group_id` varchar(255) NOT NULL COMMENT 'group_id',
    51.   `datum_id` varchar(255) NOT NULL COMMENT 'datum_id',
    52.   `content` longtext NOT NULL COMMENT '内容',
    53.   `gmt_modified` datetime NOT NULL COMMENT '修改时间',
    54.   `app_name` varchar(128) DEFAULT NULL,
    55.   `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',
    56.   PRIMARY KEY (`id`),
    57.   UNIQUE KEY `uk_configinfoaggr_datagrouptenantdatum` (`data_id`,`group_id`,`tenant_id`,`datum_id`)
    58. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='增加租户字段';
    59.  
    60.  
    61. /******************************************/
    62. /*   数据库全名 = nacos_config   */
    63. /*   表名称 = config_info_beta   */
    64. /******************************************/
    65. CREATE TABLE `config_info_beta` (
    66.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
    67.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    68.   `group_id` varchar(128) NOT NULL COMMENT 'group_id',
    69.   `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',
    70.   `content` longtext NOT NULL COMMENT 'content',
    71.   `beta_ips` varchar(1024) DEFAULT NULL COMMENT 'betaIps',
    72.   `md5` varchar(32) DEFAULT NULL COMMENT 'md5',
    73.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    74.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    75.   `src_user` text COMMENT 'source user',
    76.   `src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip',
    77.   `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',
    78.   `encrypted_data_key` text NOT NULL COMMENT '秘钥',
    79.   PRIMARY KEY (`id`),
    80.   UNIQUE KEY `uk_configinfobeta_datagrouptenant` (`data_id`,`group_id`,`tenant_id`)
    81. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info_beta';
    82.  
    83. /******************************************/
    84. /*   数据库全名 = nacos_config   */
    85. /*   表名称 = config_info_tag   */
    86. /******************************************/
    87. CREATE TABLE `config_info_tag` (
    88.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
    89.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    90.   `group_id` varchar(128) NOT NULL COMMENT 'group_id',
    91.   `tenant_id` varchar(128) DEFAULT '' COMMENT 'tenant_id',
    92.   `tag_id` varchar(128) NOT NULL COMMENT 'tag_id',
    93.   `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',
    94.   `content` longtext NOT NULL COMMENT 'content',
    95.   `md5` varchar(32) DEFAULT NULL COMMENT 'md5',
    96.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    97.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    98.   `src_user` text COMMENT 'source user',
    99.   `src_ip` varchar(50) DEFAULT NULL COMMENT 'source ip',
    100.   PRIMARY KEY (`id`),
    101.   UNIQUE KEY `uk_configinfotag_datagrouptenanttag` (`data_id`,`group_id`,`tenant_id`,`tag_id`)
    102. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_info_tag';
    103.  
    104. /******************************************/
    105. /*   数据库全名 = nacos_config   */
    106. /*   表名称 = config_tags_relation   */
    107. /******************************************/
    108. CREATE TABLE `config_tags_relation` (
    109.   `id` bigint(20) NOT NULL COMMENT 'id',
    110.   `tag_name` varchar(128) NOT NULL COMMENT 'tag_name',
    111.   `tag_type` varchar(64) DEFAULT NULL COMMENT 'tag_type',
    112.   `data_id` varchar(255) NOT NULL COMMENT 'data_id',
    113.   `group_id` varchar(128) NOT NULL COMMENT 'group_id',
    114.   `tenant_id` varchar(128) DEFAULT '' COMMENT 'tenant_id',
    115.   `nid` bigint(20) NOT NULL AUTO_INCREMENT,
    116.   PRIMARY KEY (`nid`),
    117.   UNIQUE KEY `uk_configtagrelation_configidtag` (`id`,`tag_name`,`tag_type`),
    118.   KEY `idx_tenant_id` (`tenant_id`)
    119. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='config_tag_relation';
    120.  
    121. /******************************************/
    122. /*   数据库全名 = nacos_config   */
    123. /*   表名称 = group_capacity   */
    124. /******************************************/
    125. CREATE TABLE `group_capacity` (
    126.   `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID',
    127.   `group_id` varchar(128) NOT NULL DEFAULT '' COMMENT 'Group ID，空字符表示整个集群',
    128.   `quota` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '配额，0表示使用默认值',
    129.   `usage` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '使用量',
    130.   `max_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个配置大小上限，单位为字节，0表示使用默认值',
    131.   `max_aggr_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '聚合子配置最大个数，，0表示使用默认值',
    132.   `max_aggr_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个聚合数据的子配置大小上限，单位为字节，0表示使用默认值',
    133.   `max_history_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '最大变更历史数量',
    134.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    135.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    136.   PRIMARY KEY (`id`),
    137.   UNIQUE KEY `uk_group_id` (`group_id`)
    138. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='集群、各Group容量信息表';
    139.  
    140. /******************************************/
    141. /*   数据库全名 = nacos_config   */
    142. /*   表名称 = his_config_info   */
    143. /******************************************/
    144. CREATE TABLE `his_config_info` (
    145.   `id` bigint(64) unsigned NOT NULL,
    146.   `nid` bigint(20) unsigned NOT NULL AUTO_INCREMENT,
    147.   `data_id` varchar(255) NOT NULL,
    148.   `group_id` varchar(128) NOT NULL,
    149.   `app_name` varchar(128) DEFAULT NULL COMMENT 'app_name',
    150.   `content` longtext NOT NULL,
    151.   `md5` varchar(32) DEFAULT NULL,
    152.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
    153.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
    154.   `src_user` text,
    155.   `src_ip` varchar(50) DEFAULT NULL,
    156.   `op_type` char(10) DEFAULT NULL,
    157.   `tenant_id` varchar(128) DEFAULT '' COMMENT '租户字段',
    158.   `encrypted_data_key` text NOT NULL COMMENT '秘钥',
    159.   PRIMARY KEY (`nid`),
    160.   KEY `idx_gmt_create` (`gmt_create`),
    161.   KEY `idx_gmt_modified` (`gmt_modified`),
    162.   KEY `idx_did` (`data_id`)
    163. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='多租户改造';
    164.  
    165.  
    166. /******************************************/
    167. /*   数据库全名 = nacos_config   */
    168. /*   表名称 = tenant_capacity   */
    169. /******************************************/
    170. CREATE TABLE `tenant_capacity` (
    171.   `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID',
    172.   `tenant_id` varchar(128) NOT NULL DEFAULT '' COMMENT 'Tenant ID',
    173.   `quota` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '配额，0表示使用默认值',
    174.   `usage` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '使用量',
    175.   `max_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个配置大小上限，单位为字节，0表示使用默认值',
    176.   `max_aggr_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '聚合子配置最大个数',
    177.   `max_aggr_size` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '单个聚合数据的子配置大小上限，单位为字节，0表示使用默认值',
    178.   `max_history_count` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '最大变更历史数量',
    179.   `gmt_create` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
    180.   `gmt_modified` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间',
    181.   PRIMARY KEY (`id`),
    182.   UNIQUE KEY `uk_tenant_id` (`tenant_id`)
    183. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='租户容量信息表';
    184.  
    185.  
    186. CREATE TABLE `tenant_info` (
    187.   `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id',
    188.   `kp` varchar(128) NOT NULL COMMENT 'kp',
    189.   `tenant_id` varchar(128) default '' COMMENT 'tenant_id',
    190.   `tenant_name` varchar(128) default '' COMMENT 'tenant_name',
    191.   `tenant_desc` varchar(256) DEFAULT NULL COMMENT 'tenant_desc',
    192.   `create_source` varchar(32) DEFAULT NULL COMMENT 'create_source',
    193.   `gmt_create` bigint(20) NOT NULL COMMENT '创建时间',
    194.   `gmt_modified` bigint(20) NOT NULL COMMENT '修改时间',
    195.   PRIMARY KEY (`id`),
    196.   UNIQUE KEY `uk_tenant_info_kptenantid` (`kp`,`tenant_id`),
    197.   KEY `idx_tenant_id` (`tenant_id`)
    198. ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin COMMENT='tenant_info';
    199.  
    200. CREATE TABLE `users` (
    201. 	`username` varchar(50) NOT NULL PRIMARY KEY,
    202. 	`password` varchar(500) NOT NULL,
    203. 	`enabled` boolean NOT NULL
    204. );
    205.  
    206. CREATE TABLE `roles` (
    207. 	`username` varchar(50) NOT NULL,
    208. 	`role` varchar(50) NOT NULL,
    209. 	UNIQUE INDEX `idx_user_role` (`username` ASC, `role` ASC) USING BTREE
    210. );
    211.  
    212. CREATE TABLE `permissions` (
    213.     `role` varchar(50) NOT NULL,
    214.     `resource` varchar(255) NOT NULL,
    215.     `action` varchar(8) NOT NULL,
    216.     UNIQUE INDEX `uk_role_permission` (`role`,`resource`,`action`) USING BTREE
    217. );
    218.  
    219. INSERT INTO users (username, password, enabled) VALUES ('nacos', '$2a$10$EuWPZHzz32dJN7jexM34MOeYirDdFAZm2kuWj7VEOJhhZkDrxfvUu', TRUE);
    220.  
    221. INSERT INTO roles (username, role) VALUES ('nacos', 'ROLE_ADMIN');

    4、配置文件修改

    默认端口：8848.

    1. ### Default web context path:
    2. server.servlet.contextPath=/nacos
    3. ### Default web server port:
    4. server.port=7088
    1. spring.datasource.platform=mysql
    2.  
    3. ### Count of DB:
    4. db.num=1
    5.  
    6. ### Connect URL of DB:
    7. db.url.0=jdbc:mysql://127.0.0.1:3306/nacos_config?characterEncoding=utf8&connectTimeout=10000&socketTimeout=30000&autoReconnect=true&useUnicode=true&allowPublicKeyRetrieval=true&useSSL=false&serverTimezone=Asia/Shanghai
    8. db.user.0=数据库账号
    9. db.password.0=数据库密码
    10.  
    11. ### Connection pool configuration: hikariCP
    12. db.pool.config.connectionTimeout=30000
    13. db.pool.config.validationTimeout=10000
    14. db.pool.config.maximumPoolSize=20
    15. db.pool.config.minimumIdle=2

    5、单机启动命令

    ①、 startup.cmd -m standalone

    ②、直接启动命令修改.

    修改startup.cmd,修改为standalone，默认是以集群启动的.

     6、配置

    ①、默认账号/密码：nacos/nacos

     ②、新增配置

     ③、修改配置、灰度发布.

    支持TEXT、JSON、XML、YAML、HTML、Properties类型的配置文件，文件枚举信息如下:

    1. package com.alibaba.nacos.api.config;
    2.  
    3. import com.alibaba.nacos.api.utils.StringUtils;
    4.  
    5. import java.util.HashMap;
    6. import java.util.Map;
    7.  
    8. /**
    9.  * Config data type.
    10.  *
    11.  * @author liaochuntao
    12.  **/
    13. public enum ConfigType {
    14.     
    15.     /**
    16.      * config type is "properties".
    17.      */
    18.     PROPERTIES("properties"),
    19.     
    20.     /**
    21.      * config type is "xml".
    22.      */
    23.     XML("xml"),
    24.     
    25.     /**
    26.      * config type is "json".
    27.      */
    28.     JSON("json"),
    29.     
    30.     /**
    31.      * config type is "text".
    32.      */
    33.     TEXT("text"),
    34.     
    35.     /**
    36.      * config type is "html".
    37.      */
    38.     HTML("html"),
    39.     
    40.     /**
    41.      * config type is "yaml".
    42.      */
    43.     YAML("yaml"),
    44.     
    45.     /**
    46.      * not a real type.
    47.      */
    48.     UNSET("unset");
    49.     
    50.     private final String type;
    51.     
    52.     private static final Map LOCAL_MAP = new HashMap();
    53.     
    54.     static {
    55.         for (ConfigType configType : values()) {
    56.             LOCAL_MAP.put(configType.getType(), configType);
    57.         }
    58.     }
    59.     
    60.     ConfigType(String type) {
    61.         this.type = type;
    62.     }
    63.     
    64.     public String getType() {
    65.         return type;
    66.     }
    67.     
    68.     public static ConfigType getDefaultType() {
    69.         return TEXT;
    70.     }
    71.     
    72.     /**
    73.      * check input type is valid.
    74.      *
    75.      * @param type config type
    76.      * @return it the type valid
    77.      */
    78.     public static Boolean isValidType(String type) {
    79.         if (StringUtils.isBlank(type)) {
    80.             return false;
    81.         }
    82.         return null != LOCAL_MAP.get(type);
    83.     }
    84. }

    文件修改类型枚举.

    1. package com.alibaba.nacos.api.config;
    2.  
    3. /**
    4.  * Property Change Type.
    5.  *
    6.  * @author rushsky518
    7.  */
    8. public enum PropertyChangeType {
    9.     /**
    10.      * add.
    11.      */
    12.     ADDED,
    13.     /**
    14.      * modified.
    15.      */
    16.     MODIFIED,
    17.     /**
    18.      * deleted.
    19.      */
    20.     DELETED
    21. }

    在配置项中设置.

    1. package com.alibaba.nacos.api.config;
    2.  
    3. /**
    4.  * ConfigChangeItem.
    5.  *
    6.  * @author rushsky518
    7.  */
    8. public class ConfigChangeItem {
    9.     
    10.     private String key;
    11.     
    12.     private String oldValue;
    13.     
    14.     private String newValue;
    15.     
    16.     private PropertyChangeType type;
    17.     
    18.     public ConfigChangeItem(String key, String oldValue, String newValue) {
    19.         this.key = key;
    20.         this.oldValue = oldValue;
    21.         this.newValue = newValue;
    22.     }
    23.     
    24.     public String getKey() {
    25.         return key;
    26.     }
    27.     
    28.     public void setKey(String key) {
    29.         this.key = key;
    30.     }
    31.     
    32.     public String getOldValue() {
    33.         return oldValue;
    34.     }
    35.     
    36.     public void setOldValue(String oldValue) {
    37.         this.oldValue = oldValue;
    38.     }
    39.     
    40.     public String getNewValue() {
    41.         return newValue;
    42.     }
    43.     
    44.     public void setNewValue(String newValue) {
    45.         this.newValue = newValue;
    46.     }
    47.     
    48.     public PropertyChangeType getType() {
    49.         return type;
    50.     }
    51.     
    52.     public void setType(PropertyChangeType type) {
    53.         this.type = type;
    54.     }
    55.     
    56.     @Override
    57.     public String toString() {
    58.         return "ConfigChangeItem{" + "key='" + key + '\'' + ", oldValue='" + oldValue + '\'' + ", newValue='" + newValue
    59.                 + '\'' + ", type=" + type + '}';
    60.     }
    61. }

     ④、配置项查询，content为longtext类型存储.

    ⑤、配置项修改

     

    启动失败时候查看日志解决具体报错,使用logback日志组件.

     

    二、Windows下集群搭建

    1、目录规划以及端口安排，三个节点集群搭建.

    Nacos1:8848

    Nacos2:8850

    Nacos3:8852

    注意：单个Nacos节点分布式搭建集群需要四个端口.

    1. raft port: ${server.port} - 1000
    2. grpc port: ${server.port} + 1000
    3. grpc port for server: ${server.port} + 1001

    例如：假设对外端口为8848，即总共会有4个端口被占用，分别为7848、8848、9848、9849

    集群搭建要避免端口占用，否则集群启动节点失败.

    netstat -ano |findstr "8848"

    8848、7848、9848、9849

    netstat -ano |findstr "8850" 

    8850、7850、9850、9851

    netstat -ano |findstr "8852" 

    8852、7852、9852、9853

    2、集群配置文件

    8848节点，配置各个节点的集群ServerIP

    1. 192.168.1.6:8848
    2. 192.168.1.6:8850
    3. 192.168.1.6:8852

     3、启动集群节点

    8848节点

    8850节点

     8852节点

     4、集群访问页面

    http://192.168.1.6:8848/nacos/index.html#/clusterManagement?dataId=&group=&appName=&namespace=

     账号：nacos/nacos

    节点元数据.

     

     5、新增配置

    查看其他两个节点.

    说明：会在文件中做个缓存，本地文件中没有在GET服务端，都是这样设计的，Apollo的也是这样缓存的.

    三、高可用集群

    图片来自网络架构图

     说明：Nginx集群可以用云服务SLB来搭建负载均衡监听，MySQL保证高可用，常见基本如单Region单AZ的主备，以及跨AZ容灾的主备浮动VIP确保.

    ①、Nginx的反向代理配置如下:

    1. http {
    2. 	server {
    3.         listen       80;
    4.         server_name  127.0.0.1;
    5.  
    6.         location /nacos {
    7.             proxy_pass   http://nacoscluster/nacos;
    8.         }
    9. 	}
    10. 	upstream nacoscluster {
    11. 		server 192.168.1.6:8848;
    12. 		server 192.168.1.6:8850;
    13. 		server 192.168.1.6:8852;
    14. 	}
    15. }

    这里Nginx配置就略过了，网上资料比较多，配置反向代理即可.

    ②、有条件可以使用云服务+单独域名来负载均衡,搭建高可用的配置服务.

    四、Prometheus监控

    1、本质Nacos是使用SpringBoot开发,自带监控端点actuator,并且集成了prometheus监控.

    2、开启监控项

    management.endpoints.web.exposure.include=*

     3、配置Prometheus监控任务.

    1.   # Nacos集群  
    2.   - job_name: "NacosClusterMonitor"
    3.     metrics_path: '/nacos/actuator/prometheus'
    4.     static_configs:
    5.       - targets: ['192.168.1.6:8848','192.168.1.6:8850','192.168.1.6:8852']

    4、启动Promethesu监控

    http://192.168.1.6:9090/targets#pool-NacosClusterMonitor

    5、Grafana展示

    13221

      

    Nacos的监控实现:使用promethesu+Http方式

    1. package com.alibaba.nacos.client.monitor;
    2.  
    3. import io.prometheus.client.Gauge;
    4. import io.prometheus.client.Histogram;
    5.  
    6. /**
    7.  * Metrics Monitor.
    8.  *
    9.  * @author Nacos
    10.  */
    11. public class MetricsMonitor {
    12.     
    13.     private static final Gauge NACOS_MONITOR = Gauge.build().name("nacos_monitor").labelNames("module", "name")
    14.             .help("nacos_monitor").register();
    15.     
    16.     private static final Histogram NACOS_CLIENT_REQUEST_HISTOGRAM = Histogram.build()
    17.             .labelNames("module", "method", "url", "code").name("nacos_client_request").help("nacos_client_request")
    18.             .register();
    19.     
    20.     public static Gauge.Child getServiceInfoMapSizeMonitor() {
    21.         return NACOS_MONITOR.labels("naming", "serviceInfoMapSize");
    22.     }
    23.     
    24.     public static Gauge.Child getDom2BeatSizeMonitor() {
    25.         return NACOS_MONITOR.labels("naming", "dom2BeatSize");
    26.     }
    27.     
    28.     public static Gauge.Child getListenConfigCountMonitor() {
    29.         return NACOS_MONITOR.labels("naming", "listenConfigCount");
    30.     }
    31.     
    32.     public static Histogram.Timer getConfigRequestMonitor(String method, String url, String code) {
    33.         return NACOS_CLIENT_REQUEST_HISTOGRAM.labels("config", method, url, code).startTimer();
    34.     }
    35.     
    36.     public static Histogram.Child getNamingRequestMonitor(String method, String url, String code) {
    37.         return NACOS_CLIENT_REQUEST_HISTOGRAM.labels("naming", method, url, code);
    38.     }
    39. }
    1. /*
    2.  * Copyright 1999-2018 Alibaba Group Holding Ltd.
    3.  *
    4.  * Licensed under the Apache License, Version 2.0 (the "License");
    5.  * you may not use this file except in compliance with the License.
    6.  * You may obtain a copy of the License at
    7.  *
    8.  *      http://www.apache.org/licenses/LICENSE-2.0
    9.  *
    10.  * Unless required by applicable law or agreed to in writing, software
    11.  * distributed under the License is distributed on an "AS IS" BASIS,
    12.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    13.  * See the License for the specific language governing permissions and
    14.  * limitations under the License.
    15.  */
    16.  
    17. package com.alibaba.nacos.client.config.http;
    18.  
    19. import com.alibaba.nacos.api.exception.NacosException;
    20. import com.alibaba.nacos.client.monitor.MetricsMonitor;
    21. import com.alibaba.nacos.common.http.HttpRestResult;
    22. import io.prometheus.client.Histogram;
    23.  
    24. import java.util.Map;
    25.  
    26. /**
    27.  * MetricsHttpAgent.
    28.  *
    29.  * @author Nacos
    30.  */
    31. public class MetricsHttpAgent implements HttpAgent {
    32.     
    33.     private static final String GET = "GET";
    34.     
    35.     private static final String POST = "POST";
    36.     
    37.     private static final String DELETE = "DELETE";
    38.     
    39.     private static final String DEFAULT_CODE = "NA";
    40.     
    41.     private final HttpAgent httpAgent;
    42.     
    43.     public MetricsHttpAgent(HttpAgent httpAgent) {
    44.         this.httpAgent = httpAgent;
    45.     }
    46.  
    47.     @Override
    48.     public void start() throws NacosException {
    49.         httpAgent.start();
    50.     }
    51.     
    52.     @Override
    53.     public HttpRestResult httpGet(String path, Map headers, Map paramValues,
    54.             String encode, long readTimeoutMs) throws Exception {
    55.         Histogram.Timer timer = MetricsMonitor.getConfigRequestMonitor(GET, path, DEFAULT_CODE);
    56.         HttpRestResult result;
    57.         try {
    58.             result = httpAgent.httpGet(path, headers, paramValues, encode, readTimeoutMs);
    59.         } finally {
    60.             timer.observeDuration();
    61.         }
    62.         
    63.         return result;
    64.     }
    65.     
    66.     @Override
    67.     public HttpRestResult httpPost(String path, Map headers, Map paramValues,
    68.             String encode, long readTimeoutMs) throws Exception {
    69.         Histogram.Timer timer = MetricsMonitor.getConfigRequestMonitor(POST, path, DEFAULT_CODE);
    70.         HttpRestResult result;
    71.         try {
    72.             result = httpAgent.httpPost(path, headers, paramValues, encode, readTimeoutMs);
    73.         } finally {
    74.             timer.observeDuration();
    75.         }
    76.         
    77.         return result;
    78.     }
    79.     
    80.     @Override
    81.     public HttpRestResult httpDelete(String path, Map headers, Map paramValues,
    82.             String encode, long readTimeoutMs) throws Exception {
    83.         Histogram.Timer timer = MetricsMonitor.getConfigRequestMonitor(DELETE, path, DEFAULT_CODE);
    84.         HttpRestResult result;
    85.         try {
    86.             result = httpAgent.httpDelete(path, headers, paramValues, encode, readTimeoutMs);
    87.         } finally {
    88.             timer.observeDuration();
    89.         }
    90.         
    91.         return result;
    92.     }
    93.     
    94.     @Override
    95.     public String getName() {
    96.         return httpAgent.getName();
    97.     }
    98.     
    99.     @Override
    100.     public String getNamespace() {
    101.         return httpAgent.getNamespace();
    102.     }
    103.     
    104.     @Override
    105.     public String getTenant() {
    106.         return httpAgent.getTenant();
    107.     }
    108.     
    109.     @Override
    110.     public String getEncode() {
    111.         return httpAgent.getEncode();
    112.     }
    113.     
    114.     @Override
    115.     public void shutdown() throws NacosException {
    116.         httpAgent.shutdown();
    117.     }
    118. }
    119.

    仅仅搭建，后面分析分布式算法和一些源码等.

  • 相关阅读:
    保姆级Ubuntu从下载到正常使用，遇到各种问题解决方案。
    华为数通方向HCIP-DataCom H12-821题库(多选题：41-60)
    文章解读与仿真程序复现思路——电网技术EI\CSCD\北大核心《基于相似日聚类及模态分解的短期光伏发电功率组合预测研究》
    Google开源依赖注入框架-Guice指南
    基于神经网络的偏微分方程求解器再度取得突破,北大&字节的研究成果入选Nature子刊
    【SDXL_LORA模型训练详细教程（含云端教程）】
    Python时间模块（datetime）
    前端基础建设与架构14 解析 Webpack 源码，实现自己的构建工具
    shell_41.Linux获取所有的数据
    ASUS华硕天选4笔记本FA507NU7735H_4050原装出厂Win11系统
  • 原文地址：https://blog.csdn.net/HcJsJqJSSM/article/details/126913792