架构之旅-多层架构-数据

发表于 | 分类于

简述

本文中，将使用MyBatis + Druid来构建数据访问层访问MySQL，使用dubbo+zookeeper来充当service provider,并修改service来使用dubbo(service consumer)。

源代码

iarc-data

环境

IDE: IntelliJ IDEA
JDK: 1.8.0_u162
Framework: MyBatis, Druid, Dubbo
App Coordinator: Zookeeper
DB: MySQL
WebServer: Tomcat (本地端口8088)

开发

准备

  • zookeeper
    把Zookeeper安装目录中/conf/zoo_simple.cfg重命名为zoo.cfg。然后执行 Zookeeper安装目录/bin/zkServer.cmd
  • 在tomcat中安装dubbo admin来监控服务参考

工程结构

1
2
3
4
5
--root(maven pom父工程)
----iarc-entity (实体类 module)
----iarc-service-api (服务接口 module)
----iarc-service (服务站点-spring boot)
----iarc-data (数据服务 module)

SQL初始化脚本

1
2
3
4
5
6
7
8
9
10
11
CREATE SCHEMA ijava;
use ijava;
CREATE TABLE user
(
  id   INT AUTO_INCREMENT
    PRIMARY KEY,
  name VARCHAR(50) NOT NULL
)
  COMMENT 'user table'
  ENGINE = InnoDB;
INSERT INTO ijava.user (name) VALUES ('ivan'), ('du');

iarc-data

  • spring boot configuration

    1
    2
    3
    server.port=8002
    endpoints.jmx.unique-names=true
    spring.jmx.default-domain=iarc.data

  • dubbo configuration

    1
    2
    3
    4
    5
    6
    7
    8
    9
    spring.dubbo.application.name=iarc.data
    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
    spring.dubbo.registry.group=dubbo
    spring.dubbo.protocol.name=dubbo
    spring.dubbo.protocol.port=20882
    spring.dubbo.scan=cn.icmyfuture.iarc.data
    spring.dubbo.consumer.retries=0
    spring.dubbo.consumer.timeout=10000
    spring.dubbo.consumer.check=false

  • Custom Dubbo Auto Config class

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    28
    29
    30
    31
    32
    33
    34
    35
    36
    37
    38
    39
    40
    41
    42
    43
    44
    45
    46
    47
    48
    49
    50
    51
    52
    53
    54
    55
    56
    57
    58
    59
    60
    61
    62
    63
    64
    65
    66
    67
    68
    69
    70
    71
    72
    73
    74
    75
    76
    77
    78
    import com.alibaba.dubbo.config.*;
    import lombok.Getter;
    import lombok.Setter;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.boot.context.properties.EnableConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.Ordered;
    import org.springframework.core.annotation.Order;

    import javax.annotation.PreDestroy;

    @Configuration
    @EnableConfigurationProperties({CustomDubboAutoConfig.CustomDubboProperties.class})
    @Order(Ordered.LOWEST_PRECEDENCE)
    public class CustomDubboAutoConfig {
        private static final Logger logger = LoggerFactory.getLogger(CustomDubboAutoConfig.class);

        @ConfigurationProperties(prefix = "spring.dubbo")
        @Setter
        @Getter
        class CustomDubboProperties{
            private MonitorConfig monitor;
            private ConsumerConfig consumer;
            private ProviderConfig provider;
            private ModuleConfig module;
            private MethodConfig method;
        }


        @Autowired
        private CustomDubboProperties dubboProperties;

        @Bean
        public ConsumerConfig consumerConfig() {
            ConsumerConfig consumerConfig = this.dubboProperties.getConsumer();
            if (consumerConfig == null) {
                consumerConfig = new ConsumerConfig();
            }
            return consumerConfig;
        }

        @Bean
        public MonitorConfig monitorConfig(){
            MonitorConfig monitorConfig = this.dubboProperties.getMonitor();
            if (monitorConfig == null) {
                monitorConfig = new MonitorConfig();
            }
            return monitorConfig;
        }


        @Bean
        public ProviderConfig providerConfig() {
            ProviderConfig providerConfig = this.dubboProperties.getProvider();
            if (providerConfig == null) {
                providerConfig = new ProviderConfig();
            }
            return providerConfig;
        }

        @Bean
        public MethodConfig requestMethodConfig() {
            MethodConfig methodConfig = dubboProperties.getMethod();
            if (methodConfig == null) {
                methodConfig = new MethodConfig();
            }
            return methodConfig;
        }

        @PreDestroy
        public void shutdownDestroy() {
            ProtocolConfig.destroyAll();
        }
    }

  • Druid configuration

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    20
    21
    22
    23
    24
    25
    26
    27
    spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
    spring.datasource.druid.ijava.url=jdbc:mysql://localhost:3306/ijava?useUnicode=true&characterEncoding=utf-8&useSSL=false&allowMultiQueries=true&autoReconnect=true&failOverReadOnly=false&connectTimeout=10000&serverTimezone=Asia/Shanghai
    spring.datasource.druid.ijava.driverClassName=com.mysql.cj.jdbc.Driver
    spring.datasource.druid.ijava.username=***
    spring.datasource.druid.ijava.password=***
    spring.datasource.druid.ijava.initialSize=1
    spring.datasource.druid.ijava.minIdle=1
    spring.datasource.druid.ijava.maxActive=20
    spring.datasource.druid.ijava.maxWait=60000
    spring.datasource.druid.ijava.timeBetweenEvictionRunsMillis=60000
    spring.datasource.druid.ijava.minEvictableIdleTimeMillis=300000
    spring.datasource.druid.ijava.testWhileIdle=true
    spring.datasource.druid.ijava.testOnBorrow=false
    spring.datasource.druid.ijava.testOnReturn=false
    spring.datasource.druid.ijava.validationQuery=SELECT 1
    spring.datasource.druid.ijava.poolPreparedStatements=true
    spring.datasource.druid.ijava.maxPoolPreparedStatementPerConnectionSize=20
    spring.datasource.druid.ijava.filters=stat,slf4j
    spring.datasource.druid.ijava.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=2000
    #WebStatFilter，为了进行Druid DB监控
    spring.datasource.druid.WebStatFilter.enabled=true
    spring.datasource.druid.WebStatFilter.urlPattern=/druid/*
    spring.datasource.druid.WebStatFilter.exclusions=false
    #StatViewServlet，为了进行Druid DB监控
    spring.datasource.druid.StatViewServlet.enabled=true
    spring.datasource.druid.StatViewServlet.urlPattern=/druid/*
    spring.datasource.druid.StatViewServlet.resetEnable=false

iarc-service

  • port && jmx unique configuration

    1
    2
    3
    server.port=8002
    endpoints.jmx.unique-names=true
    spring.jmx.default-domain=iarc.data

  • dubbo configuration

    1
    2
    3
    4
    5
    6
    7
    8
    spring.dubbo.application.name=iarc.service
    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
    spring.dubbo.registry.group=dubbo
    spring.dubbo.protocol.port=20881
    spring.dubbo.scan=cn.icmyfuture.iarc.service
    spring.dubbo.consumer.retries=0
    spring.dubbo.consumer.timeout=10000
    spring.dubbo.consumer.check=false

  • dubbo service reference

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    @RestController
    @RequestMapping(value = "/user")
    public class UserController {
        @Reference
        private UserService userService;

        @CrossOrigin(origins = "*")
        @GetMapping("getUser/{id}")
        public User getUser(@PathVariable("id") int id) {
            return userService.getUser(id);
        }
    }

  • Custom Dubbo Auto Config class
    与iarc-data节中相同

调试

部署

maven 编译打包

1
mvn clean install -Dmaven.test.skip=true

部署data/service至centos

将打包好的iarc-service.war, iarc-data.war复制到 $CATALINA_HOME/webapps目录下，tomcat会自动解压war包，访问http://localhost:8080/iarc-service/user/getUser/1进行验证

参考