【Spring Cloud】003-Rest学习环境搭建

蔚落 2023-10-05 10:28 34阅读 0赞

# **目录** #

一、服务提供者

1、创建一个普通的Maven项目作为父项目，删除src文件夹，并导入坐标

2、创建一个新模块springcloud-api

3、创建一个数据库

创建：

表结构：

数据：

实体类：

3、再创建一个新模块springcloud-provider-dept-8001

导入依赖到pom.xml：

配置文件application.yaml：

配置文件mybatis-confid.xml：

创建Dao接口：

创建Dao接口的映射配置DeptDao.xml：

DeptService接口：

DeptService接口实现类：

DeptController类：

编写启动类：

测试结果：

二、服务消费者

1、创建一个新模块springcloud-consumer-dept-80

导入依赖坐标到pom.xml：

配置文件application.yaml：

ConfigBean：

ConsumerDeptController：

编写启动类：

测试结果：

注意：

--------------------

# 一、服务提供者 #

## 1、创建一个普通的Maven项目作为父项目，删除src文件夹，并导入坐标 ##

<?xml version="1.0" encoding="UTF-8"?>
    <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>org.example</groupId>
        <artifactId>springcloud</artifactId>
        <version>1.0-SNAPSHOT</version>
        
        <packaging>pom</packaging>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <maven.compiler.source>1.8</maven.compiler.source>
            <maven.compiler.target>1.8</maven.compiler.target>
            <junit.version>4.13</junit.version>
            <lombok.version>41.18.12</lombok.version>
        </properties>
    
        <dependencyManagement>
            <dependencies>
                
                
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Hoxton.SR8</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                
                <dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-dependencies</artifactId>
                    <version>2.3.4.RELEASE</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                
                <dependency>
                    <groupId>mysql</groupId>
                    <artifactId>mysql-connector-java</artifactId>
                    <version>8.0.21</version>
                </dependency>
                <dependency>
                    <groupId>com.alibaba</groupId>
                    <artifactId>druid</artifactId>
                    <version>1.1.23</version>
                </dependency>
                
                <dependency>
                    <groupId>org.mybatis.spring.boot</groupId>
                    <artifactId>mybatis-spring-boot-starter</artifactId>
                    <version>2.1.3</version>
                </dependency>
                
                <dependency>
                    <groupId>junit</groupId>
                    <artifactId>junit</artifactId>
                    <version>${junit.version}</version>
                    <scope>test</scope>
                </dependency>
                
                <dependency>
                    <groupId>org.projectlombok</groupId>
                    <artifactId>lombok</artifactId>
                    <version>${lombok.version}</version>
                </dependency>
                
                <dependency>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                    <version>1.2.17</version>
                </dependency>
                
                <dependency>
                    <groupId>ch.qos.logback</groupId>
                    <artifactId>logback-core</artifactId>
                    <version>1.2.3</version>
                </dependency>
            </dependencies>
        </dependencyManagement>
    </project>

## 2、创建一个新模块springcloud-api ##

（普通Maven项目模块）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz_size_16_color_FFFFFF_t_70][]

## 3、创建一个数据库 ##

（Navicat）

### 创建： ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz_size_16_color_FFFFFF_t_70 1][]

### 表结构： ###

![20200923172233595.png][]

### 数据： ###

insert into dept (dname, db_source) VALUES ('开发部',DATABASE());
    insert into dept (dname, db_source) VALUES ('人事部',DATABASE());
    insert into dept (dname, db_source) VALUES ('财务部',DATABASE());
    insert into dept (dname, db_source) VALUES ('市场部',DATABASE());
    insert into dept (dname, db_source) VALUES ('运维部',DATABASE());

### 实体类： ###

package com.zibo.springcloud.pojo;
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    import lombok.experimental.Accessors;
    
    import java.io.Serializable;
    
    @Data
    @NoArgsConstructor
    @Accessors(chain = true) //支持链式写法
    public class Dept implements Serializable { //Dept实体类对应dept表 类表关系映射
        private Long deptno;//编号、主键
        private String dname;
    
        //这条数据存在于哪个数据库，微服务，一个服务对应一个数据库
        private String db_source;
    
        public Dept(String dname) {
            this.dname = dname;
        }
    
        /*
         Dept dept = new Dept();
         普通写法：
         dept.setDeptNo(11);
         dept.setDeptName("訾博");
         链式写法：
         dept.setDeptNo(11).setDeptName("訾博");
         */
    }

## 3、再创建一个新模块springcloud-provider-dept-8001 ##

### 导入依赖到pom.xml： ###

### 配置文件application.yaml： ###

server:
      port: 8001
    
    # mybatis配置
    mybatis:
      type-aliases-package: com.zibo.springcloud.pojo
      config-location: classpath:mybatis/mybatis-config.xml
      mapper-locations: classpath:mybatis/mapper/*.xml
    
    # spring配置
    spring:
      application:
        name: springcloud-provider-dept
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource #数据源
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/zb1?serverTimezone=UTC
        username: root
        password: zibo15239417242

### 配置文件mybatis-confid.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>

### 创建Dao接口： ###

package com.zibo.springcloud.dao;
    
    import com.zibo.springcloud.pojo.Dept;
    import org.apache.ibatis.annotations.Mapper;
    import org.springframework.stereotype.Repository;
    
    import java.util.List;
    
    @Mapper
    @Repository
    public interface DeptDao {
    
        public boolean addDept(Dept dept);
    
        public Dept queryById(int deptno);
    
        public List<Dept> queryAll();
    
    }

### 创建Dao接口的映射配置DeptDao.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="com.zibo.springcloud.dao.DeptDao">
        <insert id="addDept" parameterType="Dept">
            insert into dept (dname, db_source) VALUES (#{dname},DATABASE())
        </insert>
    
        <select id="queryById" parameterType="long" resultType="Dept">
            select * from dept where deptno = #{deptno};
        </select>
    
        <select id="queryAll" resultType="Dept">
            select * from dept;
        </select>
    </mapper>

### DeptService接口： ###

package com.zibo.springcloud.service;
    
    import com.zibo.springcloud.pojo.Dept;
    
    import java.util.List;
    
    public interface DeptService {
        public boolean addDept(Dept dept);
    
        public Dept queryById(int deptno);
    
        public List<Dept> queryAll();
    }

### DeptService接口实现类： ###

package com.zibo.springcloud.service;
    
    import com.zibo.springcloud.dao.DeptDao;
    import com.zibo.springcloud.pojo.Dept;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import java.util.List;
    
    @Service
    public class DeptServiceImpl implements DeptService {
    
        @Autowired
        private DeptDao deptDao;
    
        @Override
        public boolean addDept(Dept dept) {
            return deptDao.addDept(dept);
        }
    
        @Override
        public Dept queryById(int deptno) {
            return deptDao.queryById(deptno);
        }
    
        @Override
        public List<Dept> queryAll() {
            return deptDao.queryAll();
        }
    }

### DeptController类： ###

package com.zibo.springcloud.controller;
    
    import com.zibo.springcloud.pojo.Dept;
    import com.zibo.springcloud.service.DeptService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.PostMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.List;
    
    //提供Restful服务！
    @RestController
    public class DeptController {
    
        @Autowired
        private DeptService deptService;
    
        @PostMapping("/dept/add")
        public boolean addDept(Dept dept){
            return deptService.addDept(dept);
        }
    
        @GetMapping("/dept/get/{id}")
        public Dept get(@PathVariable("id") long id){
            return deptService.queryById(id);
        }
    
        @GetMapping("/dept/get")
        public List<Dept> addDept(){
            return deptService.queryAll();
        }
    
    }

### 编写启动类： ###

package com.zibo.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    //启动类
    @SpringBootApplication
    public class DeptProvider_8001 {
        public static void main(String[] args) {
            SpringApplication.run(DeptProvider_8001.class,args);
        }
    }

### 测试结果： ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz_size_16_color_FFFFFF_t_70 2][]

# 二、服务消费者 #

## 1、创建一个新模块springcloud-consumer-dept-80 ##

### 导入依赖坐标到pom.xml： ###

### 配置文件application.yaml： ###

server:
      port: 80

### ConfigBean： ###

package com.zibo.springcloud.config;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    @Configuration
    public class ConfigBean {
    
        @Bean
        public RestTemplate getRestTemplate(){
            return new RestTemplate();
        }
    
    }

### ConsumerDeptController： ###

package com.zibo.springcloud.controller;
    
    import com.zibo.springcloud.pojo.Dept;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import java.util.List;
    
    @RestController
    public class ConsumerDeptController {
    
        //理解：消费者，不应该有service层
        //RestTemplate 供我们直接调用就可以了！注册到Spring中
        //参数：(url,实体：Map,class<T> responseType,)
        @Autowired
        private RestTemplate restTemplate;//提供多种便捷访问远程http服务的方法，简单的Restful服务模板
    
        private static final String REST_URL_PRE = "http://localhost:8001";
    
        //http://localhost:8001/dept/get/1
        @RequestMapping("/consumer/dept/get/{id}")
        public Dept getById(@PathVariable("id") long  id){
            return restTemplate.getForObject(REST_URL_PRE + "/dept/get/" + id,Dept.class);
        }
    
        @RequestMapping("/consumer/dept/add")
        public boolean add(Dept dept){
            return restTemplate.postForObject(REST_URL_PRE + "/dept/add",dept,Boolean.class);
        }
    
        @RequestMapping("/consumer/dept/get")
        public List<Dept> get(){
            return restTemplate.getForObject(REST_URL_PRE + "/dept/get",List.class);
        }
    
    }

### 编写启动类： ###

package com.zibo.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    @SpringBootApplication
    public class DeptConsumer_80 {
        public static void main(String[] args) {
            SpringApplication.run(DeptConsumer_80.class,args);
        }
    }

### 测试结果： ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz_size_16_color_FFFFFF_t_70 3][]

### 注意： ###

必须县启动服务提供者，才能使用服务消费者！

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200923171212862.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200923171458681.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz,size_16,color_FFFFFF,t_70
[20200923172233595.png]: https://img-blog.csdnimg.cn/20200923172233595.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200923222314479.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20200923232654652.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzI5Njg5MzQz,size_16,color_FFFFFF,t_70