Spring Cloud云架构-Restful 基础架构

淩亂°似流年 2022-03-15 03:36 234阅读 0赞

对于 Rest 基础架构实现处理是 SpringCloud 核心所在，其基本操作形式在 SpringBoot 之中已经有了明确的讲解，那么本次为 了清晰可见，创建一套新的微服务架构：部门微服务（Dept）。愿意了解源码的朋友直接求求交流分享技术一七九一七四三三八零

如果要想进行 SpringCloud 开发，那么一定要对 SpringBoot 有一定的了解，同时本次也将融合 MyBatis 开发技术实现整体的微 服务的创建处理。

1、搭建项目环境

对于现在的项目创建一个：microcloud 的整体父 pom 项目，那么随后为了方便管理，将创建其三个子模块：

· microcloud-api 模块，作为公共的信息导入配置模块；

· microcloud-provider-dept-8001：作为服务提供者，该提供者负责使用 Mybatis 与数据库交互；

· microcloud-consumer-80：作为微服务调用的客户端使用。

1.1 创建一个新的 maven 项目：microcloud；

1.2 【microcloud】修改 pom.xml 文件，主要追加 springcloud 与 springboot 两个开发包的依赖关系；

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <groupId>cn.study</groupId>
        <artifactId>microcloud</artifactId>
        <version>0.0.1</version>
        <packaging>pom</packaging>
        <name>microcloud</name>
        <url>http://maven.apache.org</url>
        <properties>
            <jdk.version>1.8</jdk.version>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        </properties>
        <dependencyManagement>
            <dependencies>
                <dependency>    
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Dalston.SR1</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                <dependency>    
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-dependencies</artifactId>
                    <version>1.5.4.RELEASE</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
        <build>
            <finalName>microcloud</finalName>
            <plugins>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <configuration>
                        <source>${jdk.version}</source>
                        <target>${jdk.version}</target>
                        <encode>${project.build.sourceEncoding}</encode>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    </project>

2、 【microcloud-api】建立一个 api 的公共模块，该模块的主要功能是提供有公共处理类，本次预计建立一个 Dept 数据表，里面 的字段：deptno（Long）、dname（String）、loc（保存的数据库的名字）；

package cn.study.vo;
     
    import java.io.Serializable;
     
    @SuppressWarnings("serial")
    public class Dept implements Serializable {
        private Long deptno ;
        private String dname ;
        private String loc ;
        public Long getDeptno() {
            return deptno;
        }
        public void setDeptno(Long deptno) {
            this.deptno = deptno;
        }
        public String getDname() {
            return dname;
        }
        public void setDname(String dname) {
            this.dname = dname;
        }
        public String getLoc() {
            return loc;
        }
        public void setLoc(String loc) {
            this.loc = loc;
        }
        @Override
        public String toString() {
            return "Dept [deptno=" + deptno + ", dname=" + dname + ", loc=" + loc
                    + "]";
        }
    }

3、 创建一个 Rest 提供者的【microcloud-provider-dept-8001】项目模块，在这个模块里面主要定义要使用的数据库脚本：

DROP DATABASE IF EXISTS "study8001" ;
    CREATE DATABASE study8001 CHARACTER SET UTF8 ;
    USE study8001 ;
    CREATE TABLE dept (
        deptno        BIGINT        AUTO_INCREMENT ,
        dname        VARCHAR(50) ,
        loc            VARCHAR(50) ,
        CONSTRAINT pk_deptno PRIMARY KEY(deptno)
    ) ;
    INSERT INTO dept(dname,loc) VALUES ('开发部',database()) ;
    INSERT INTO dept(dname,loc) VALUES ('财务部',database()) ;
    INSERT INTO dept(dname,loc) VALUES ('市场部',database()) ;
    INSERT INTO dept(dname,loc) VALUES ('后勤部',database()) ;
    INSERT INTO dept(dname,loc) VALUES ('公关部',database()) ;

由于在整个微服务里面需要进行负载均衡的操作，所以本次在使用的时候加入了数据库的名称信息。

3、创建 Dept 微服务

所谓的微服务的核心本质就是 JSON 的传输，那么既然现在要求使用 MyBatis 进行数据库操作，所以应该在项目里面配置 Druid 数据库连接池，而后对外进行项目的发布。

1、 【microcloud-provider-dept-8001】修改 pom.xml 配置文件，追加相关的依赖程序支持包：

<dependencies>
           <dependency>
               <groupId>cn.study</groupId>
               <artifactId>microcloud-api</artifactId>
           </dependency>
           <dependency>
               <groupId>junit</groupId>
               <artifactId>junit</artifactId>
               <scope>test</scope>
           </dependency>
           <dependency>
               <groupId>mysql</groupId>
               <artifactId>mysql-connector-java</artifactId>
           </dependency>
           <dependency> 
               <groupId>com.alibaba</groupId>
               <artifactId>druid</artifactId>
           </dependency>
           <dependency>
               <groupId>ch.qos.logback</groupId>
               <artifactId>logback-core</artifactId>
           </dependency>
           <dependency>
               <groupId>org.mybatis.spring.boot</groupId>
               <artifactId>mybatis-spring-boot-starter</artifactId>
           </dependency>
           <dependency>
               <groupId>org.springframework.boot</groupId>
               <artifactId>spring-boot-starter-jetty</artifactId>
           </dependency>
           <dependency>
               <groupId>org.springframework.boot</groupId>
               <artifactId>spring-boot-starter-web</artifactId>
           </dependency>
           <dependency>
               <groupId>org.springframework.boot</groupId>
               <artifactId>spring-boot-starter-test</artifactId>
               <scope>test</scope>
           </dependency>
           <dependency>
               <groupId>org.springframework</groupId>
               <artifactId>springloaded</artifactId>
           </dependency>
           <dependency>
               <groupId>org.springframework.boot</groupId>
               <artifactId>spring-boot-devtools</artifactId>
           </dependency>
       </dependencies>

2、 【microcloud-provider-dept-8001】创建一个 IDeptDAO 数据操作接口，这个接口里面将提供有三个数据操作方法：

package cn.study.microcloud.dao;
     
    import java.util.List;
     
    import org.apache.ibatis.annotations.Mapper;
     
    import cn.study.vo.Dept;
    @Mapper
    public interface IDeptDAO {
        public boolean doCreate(Dept vo) ;
        public Dept findById(Long id) ;
        public List<Dept> findAll() ;
    }

3、 【microcloud-provider-dept-8001】修改 application.yml 配置文件，追加 mybatis 和服务的相关配置信息：

server:
      port: 8001
    mybatis:
      config-location: classpath:mybatis/mybatis.cfg.xml    # mybatis配置文件所在路径
      type-aliases-package: cn.study.vo            # 定义所有操作类的别名所在包
      mapper-locations:                                     # 所有的mapper映射文件
      - classpath:mybatis/mapper/**/*.xml
    spring:
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource    # 配置当前要使用的数据源的操作类型
        driver-class-name: org.gjt.mm.mysql.Driver      # 配置MySQL的驱动程序类
        url: jdbc:mysql://localhost:3306/study8001           # 数据库连接地址
        username: root                                  # 数据库用户名
        password: mysqladmin                            # 数据库连接密码
        dbcp2:                                          # 进行数据库连接池的配置
          min-idle: 5                                   # 数据库连接池的最小维持连接数    
          initial-size: 5                               # 初始化提供的连接数
          max-total: 5                                  # 最大的连接数
          max-wait-millis: 200                          # 等待连接获取的最大超时时间

4、 【microcloud-provider-dept-8001】定义 src/main/resources/mybatis/mybatis.cfg.xml 配置文件：

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE configuration   
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"   
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
    <configuration> 
        <settings>    
            <setting name="cacheEnabled" value="true"/>
        </settings>
    </configuration>

5、 【microcloud-provider-dept-8001】修改 src/main/resources/mybatis/mapper/cn/mldn/Dept.xml 配置文件：

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" 
    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    <mapper namespace="cn.study.microcloud.dao.IDeptDAO">
        <select id="findById" resultType="Dept" parameterType="long">
            SELECT deptno,dname,loc FROM dept WHERE deptno=#{deptno} ;
        </select>
        <select id="findAll" resultType="Dept">
            SELECT deptno,dname,loc FROM dept ;
        </select>
        <insert id="doCreate" parameterType="Dept">
            INSERT INTO dept(dname,loc) VALUES (#{dname},database()) ;
        </insert>
    </mapper>

6、 【microcloud-provider-dept-8001】建立 IDeptService 接口，做业务实现：

package cn.study.microcloud.service;
     
    import java.util.List;
     
    import cn.study.vo.Dept;
     
    public interface IDeptService {
        public Dept get(long id) ;
        public boolean add(Dept dept) ;
        public List<Dept> list() ;
    }
    package cn.study.microcloud.service.impl;
     
    import java.util.List;
     
    import javax.annotation.Resource;
     
    import org.springframework.stereotype.Service;
     
    import cn.study.microcloud.dao.IDeptDAO;
    import cn.study.microcloud.service.IDeptService;
    import cn.study.vo.Dept;
    @Service
    public class DeptServiceImpl implements IDeptService {
        @Resource
        private IDeptDAO deptDAO ;
        @Override
        public Dept get(long id) {
            return this.deptDAO.findById(id);
        }
     
        @Override
        public boolean add(Dept dept) {
            return this.deptDAO.doCreate(dept);
        }
     
        @Override
        public List<Dept> list() {
            return this.deptDAO.findAll();
        }
     
    }

7、 【microcloud-provider-dept-8001】定义程序的运行主类

package cn.study.microcloud;
     
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    @SpringBootApplication
    public class Dept_8001_StartSpringCloudApplication {
        public static void main(String[] args) {
            SpringApplication.run(Dept_8001_StartSpringCloudApplication.class, args);
        }
    }

8、 【microcloud-provider-dept-8001】进行业务接口测试编写：

package cn.study.test;
     
    import static org.junit.Assert.fail;
     
    import javax.annotation.Resource;
     
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    import org.springframework.test.context.web.WebAppConfiguration;
     
    import cn.study.microcloud.Dept_8001_StartSpringCloudApplication;
    import cn.study.microcloud.service.IDeptService;
    import cn.study.vo.Dept;
    @SpringBootTest(classes = Dept_8001_StartSpringCloudApplication.class)
    @RunWith(SpringJUnit4ClassRunner.class)
    @WebAppConfiguration
    public class IDeptServiceTest {
        @Resource
        private IDeptService deptService ;
        @Test
        public void testGet() {
            System.out.println(this.deptService.get(1));
        }
     
        @Test
        public void testAdd() {
            Dept dept = new Dept() ;
            dept.setDname("测试部-" + System.currentTimeMillis());
            System.out.println(this.deptService.add(dept)); 
        }
     
        @Test
        public void testList() {
            System.out.println(this.deptService.list());
        }
     
    }

9、 【microcloud-provider-dept-8001】建立Restful的DeptRest 服务类：

package cn.study.microcloud.rest;
     
    import javax.annotation.Resource;
     
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
     
    import cn.study.microcloud.service.IDeptService;
    import cn.study.vo.Dept;
     
    @RestController
    public class DeptRest {
        @Resource
        private IDeptService deptService ;
        @RequestMapping(value="/dept/get/{id}",method=RequestMethod.GET)
        public Object get(@PathVariable("id") long id) {
            return this.deptService.get(id) ;
        }
        @RequestMapping(value="/dept/add",method=RequestMethod.GET)
        public Object add(@RequestBody Dept dept) {
            return this.deptService.add(dept) ;
        }
        @RequestMapping(value="/dept/list",method=RequestMethod.GET)
        public Object list() {
            return this.deptService.list() ;
        }
    }

10、 修改 hosts 配置文件，追加一个映射路径（路径：C:\\Windows\\System32\\drivers\\etc\\hosts）。

127.0.0.1 dept-8001.com

11、 观察 Rest 服务能否正常提供：

· 调用 get 操作：[dept-8001.com:8001/dept/get/1；][dept-8001.com_8001_dept_get_1]

· 调用 list 操作：[dept-8001.com:8001/dept/list；][dept-8001.com_8001_dept_list]

2.3、客户端调用微服务

1、 创建一个 Maven 的新的模块：microcloud-consumer-80；

2、 【microcloud-consumer-80】修改 application.yml 配置文件：

server:
      port: 80

3、 【microcloud-consumer-80】创建一个 Rest 的配置程序类，主要进行 RestTemplate 类对象创建，这里很重要，编写这个类然后在控制器里面使用@Resource注解注入以后控制器就可以调用其他微服务了

package cn.study.microcloud.config;
     
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
     
    @Configuration
    public class RestConfig {
        @Bean
        public RestTemplate getRestTemplate() {
            return new RestTemplate() ;
        }
    }

4、 【microcloud-consumer-80】创建一个控制器，为了简化处理，本次不再进行页面定义了，所有服务结果都使用 Rest 返回；

package cn.study.microcloud.controller;
     
    import java.util.List;
     
    import javax.annotation.Resource;
     
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
     
    import cn.study.vo.Dept;
     
    @RestController
    public class ConsumerDeptController {
        public static final String DEPT_GET_URL = "http://dept-8001.com:8001/dept/get/";
        public static final String DEPT_LIST_URL = "http://dept-8001.com:8001/dept/list/";
        public static final String DEPT_ADD_URL = "http://dept-8001.com:8001/dept/add";
        //使用@Resource注解注入RestTemplate以后控制器就可以调用其他微服务了
        @Resource
        private RestTemplate restTemplate;
        @RequestMapping(value = "/consumer/dept/get")
        public Object getDept(long id) {
            Dept dept = this.restTemplate.getForObject(DEPT_GET_URL + id,
                    Dept.class);
            return dept;
        }
        @SuppressWarnings("unchecked")
        @RequestMapping(value = "/consumer/dept/list")
        public Object listDept() {
            List<Dept> allDepts = this.restTemplate.getForObject(DEPT_LIST_URL,
                    List.class); 
            return allDepts;
        }
        @RequestMapping(value = "/consumer/dept/add")
        public Object addDept(Dept dept) {
            Boolean flag = this.restTemplate.postForObject(DEPT_ADD_URL, dept,
                    Boolean.class);
            return flag;
        }
    }

5、 【microcloud-consumer-80】编写启动程序类

package cn.study.microcloud;
     
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    @SpringBootApplication
    public class Consumer_80_StartSpringCloudApplication {
        public static void main(String[] args) {
            SpringApplication.run(Consumer_80_StartSpringCloudApplication.class,
                    args);
        }
    }

6、 修改 hosts 配置文件，追加访问控制路径：

127.0.0.1 client.com

7、 进行代码测试调用：

调用数据返回：[http://client.com/consumer/dept/get?id=1；][http_client.com_consumer_dept_get_id_1]

测试列表数据：[http://client.com/consumer/dept/list；][http_client.com_consumer_dept_list]

测试数据增加：[http://client.com/consumer/dept/add?dname=WEB][http_client.com_consumer_dept_add_dname_WEB] 测试

[dept-8001.com_8001_dept_get_1]: http://dept-8001.com:8001/dept/get/1%EF%BC%9B
[dept-8001.com_8001_dept_list]: http://dept-8001.com:8001/dept/list%EF%BC%9B
[http_client.com_consumer_dept_get_id_1]: http://client.com/consumer/dept/get?id=1%EF%BC%9B
[http_client.com_consumer_dept_list]: http://client.com/consumer/dept/list%EF%BC%9B
[http_client.com_consumer_dept_add_dname_WEB]: http://client.com/consumer/dept/add?dname=WEB