SpringCloud学习二：实现Springboot

文章目录

• 一、架构
• 二、实战学习
• • 2.1 第一步：SpringCloud版本选择
  • 2.2 第二步：创建父工程
  • 2.3 第三步：创建子工程：pojo管理：springcloud-api
  • • 2.3.1 导入依赖
    • 2.3.2 创建数据库
    • 2.3.3 创建实体类
  • 2.4 第四步：创建子工程服务提供者：springcloud-provider-dept-8001
  • • 2.4.1 创建maven项目端口号加上最好
    • 2.4.2 导入依赖
    • 2.4.3 配置
    • • 2.4.3.1 pom配置
      • 2.4.3.2 mybatis-config.xml配置
      • 2.4.3.3 配置主类
    • 2.4.4 编写 dao service controller
    • • dao
      • service
      • DeptController
  • 2.5 第五步：创建子工程服务消费者：springcloud-consumer-dept-80
  • • 2.5.1 创建maven项目端口号加上50最好
    • 2.5.2 导入依赖
    • 2.5.3 配置
    • • pom
      • yml
      • 配置类ConfigBean(RestTemplate )
      • 配置主启动类DeptConsumer_80
    • 2.5.4 编写 controller
    • • DeptConsumerController

一、架构

二、实战学习 2.1 第一步：SpringCloud版本选择

2.2 第二步：创建父工程

直接创建一个名为SpringCloud的Maven空项目即可

然后后面全部的项目都是父工程的一个子模块，并且都是maven的空项目

建立一个数据库：db01

pom.xml

第一步：修改打包方式为 pom

第二步：导入springcloud依赖

第三步：导入springboot依赖

第四步：导入数据库的依赖

第五步：导入数据源的依赖 用阿里巴巴的druid连接池比较好

第六步：加入springboot的启动器依赖

第七步：加入log4j的日志依赖

第八步：加入lombok 的依赖

   
    

    4.0.0

    com.wu
    SpringCloud
    1.0-SNAPSHOT

    
    pom

    
    
        UTF-8
        1.8
        1.8
        4.12
        1.18.16
        1.2.17
        1.2.3
        8.0.21
        1.1.23
        2.1.4
        2.3.8.RELEASE
        Hoxton.SR9
    

    
    
        
            
            
                org.springframework.cloud
                spring-cloud-dependencies
                ${spring-cloud-dependencies.version}
                pom
                import
            
            
            
                org.springframework.boot
                spring-boot-dependencies
                ${spring-boot-dependencies.version}
                pom
                import
            
            
            
                mysql
                mysql-connector-java
                ${mysql-connector-java.version}
            
            
            
                com.alibaba
                druid
                ${druid.version}
            
            
            
                org.mybatis.spring.boot
                mybatis-spring-boot-starter
                ${mybatis-spring-boot-starter.version}
            
            
            
            
                junit
                junit
                ${junit.version}
            
            
            
                org.projectlombok
                lombok
                ${lombok.version}
            
            
            
                log4j
                log4j
                ${log4j.version}
            
            
                ch.qos.logback
                logback-core
                ${logback-core.version}
            
        
    
    
        
    

2.3 第三步：创建子工程：pojo管理：springcloud-api

创建一个maven的Api工程就好了

2.3.1 导入依赖

因为有父工程，所以这里的导入依赖了版本号，但是依旧要导入

    
        org.projectlombok
        lombok
    

2.3.2 创建数据库

2.3.3 创建实体类

1. 必须要实现序列化===》网络通信
2. @Accessors(chain = true) //链式写法 就是可以连续set
   

@Data
@NoArgsConstructor
@Accessors(chain = true)  //链式写法
//所有的实体类务必实现序列化,通讯需求
public class Dept implements Serializable {//Dept,实体类 orm 类表关系映射
    private static final long serialVersionUID = 708560364349809174L;
    private Long deptno; //主键
    private String dname;

    //看下这个数据存在哪个数据库的字段~ 微服务 ，一个服务对应一个数据库
    //同一个信息可能存在不同的数据库
    private String db_source;

    public Dept(String dname) {
        this.dname = dname;
    }

}

2.4 第四步：创建子工程服务提供者：springcloud-provider-dept-8001 2.4.1 创建maven项目端口号加上最好

2.4.2 导入依赖

1. 我们需要拿到实体类，所以要配置api module(导入就可以用他的实体类了)
2. 添加相关依赖

    
    
        com.wu
        springcloud-api
        1.0-SNAPSHOT
    
    
    
        junit
        junit
    
    
        mysql
        mysql-connector-java
    
    
        com.alibaba
        druid
    
    
    
        ch.qos.logback
        logback-core
    
    
        org.mybatis.spring.boot
        mybatis-spring-boot-starter
    
    
    
        org.springframework.boot
        spring-boot-test
    
    
    
        org.springframework.boot
        spring-boot-starter-web
    
    
    
        org.springframework.boot
        spring-boot-starter-jetty
    
    
    
        org.springframework.boot
        spring-boot-devtools
    

2.4.3 配置 2.4.3.1 pom配置

server:
  port: 8001

#mybatis配置
mybatis:
  type-aliases-package: com.wu.springcloud.pojo
  config-location: classpath:mybatis/mybatis-config.xml
  mapper-locations: classpath:mybatis/mapper/*.xml

#spring的配置
spring:
  application:
    name: springcloud-provider-dept  # 3个服务名称一致是前提
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource  #数据源
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/db01?useUnicode=true&characterEncoding=UTF-8&useSSL=true&serverTimezone=UTC
    username: root
    password: root

2.4.3.2 mybatis-config.xml配置

2.4.3.3 配置主类

//启动类
@SpringBootApplication
public class DeptProvider_8001 {
    public static void main(String[] args) {
        SpringApplication.run(DeptProvider_8001.class, args);
    }
}

2.4.4 编写 dao service controller dao

@Mapper
@Repository
public interface DeptMapper {
    //添加部门
    boolean addDept(Dept dept);

    //根据ID查询部门
    Dept queryById(@Param("deptno") long id);

    //查询全部部门
    List queryall();
}

    
        insert into dept(dname,db_source)
        values (#{dname},DATAbase());
    

    
        select * from dept where deptno = #{deptno};
    

    
        select * from dept;
    

service

public interface DeptService {
    boolean addDept(Dept dept);

    Dept queryById(long id);

    List queryall();

}

@Service
public class DeptServiceImpl implements DeptService {

    @Autowired
    private DeptMapper deptMapper;

    @Override
    public boolean addDept(Dept dept) {
        return deptMapper.addDept(dept);
    }

    @Override
    public Dept queryById(long id) {
        return deptMapper.queryById(id);
    }

    @Override
    public List queryall() {
        return deptMapper.queryall();
    }
}

DeptController

//提供Restfull服务!!
@RestController
public class DeptController {

    @Autowired
    private DeptServiceImpl deptService;

    @PostMapping("/dept/add")
    public boolean addDept(Dept dept) {
        return deptService.addDept(dept);
    }


    @GetMapping("/dept/get/{id}")
    public Dept getDept(@PathVariable("id") Long id) {
        Dept dept = deptService.queryById(id);
        if (dept == null) {
            throw new RuntimeException("Fail");
        }
        return dept;
    }

    @GetMapping("/dept/list")
    public List queryAll() {
        return deptService.queryall();
    }

}

2.5 第五步：创建子工程服务消费者：springcloud-consumer-dept-80 2.5.1 创建maven项目端口号加上50最好

2.5.2 导入依赖

    
        com.wu
        springcloud-api
        1.0-SNAPSHOT
    
    
        org.springframework.boot
        spring-boot-starter-web
    
    
    
        org.springframework.boot
        spring-boot-devtools
    

2.5.3 配置 pom

    
        com.wu
        springcloud-api
        1.0-SNAPSHOT
    
    
        org.springframework.boot
        spring-boot-starter-web
    
    
    
        org.springframework.boot
        spring-boot-devtools
    

yml

server：
	port:80

配置类ConfigBean(RestTemplate )

• 这里要用到 RestTemplate ,但是它的类中没有Bean，所以我们要把它注册到Bean中

@Configuration
public class ConfigBean {  //@Configuration ... 相当于spring中的配置文件 applicationContext.xml文件
    @Bean
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
}

配置主启动类DeptConsumer_80

@SpringBootApplication
public class DeptConsumer_80 {
    public static void main(String[] args) {
        SpringApplication.run(DeptConsumer_80.class, args);
    }
}

2.5.4 编写 controller DeptConsumerController

1. 不应该有服务层
2. RestTemplate 有很多方法给我们直接调用 ! 它的类中没有Bean所以要我们自己把它注册到Bean中

RestTemplate 使用方式

1. 配置config类
2. @Autowired private RestTemplate restTemplate; //提供多种便捷访问远程http服务的方法，简单的restful服务模板
3. private static final String REST_URL_PREFIX = “http://localhost:8001”;
4. 请求：restTemplate.getForObject(REST_URL_PREFIX + “/dept/get/” + id, Dept.class

@Controller
public class DeptConsumerController {

    //消费者 : 不因该有service层
    //RestTemplate  有很多方法给我们直接调用  !  它的类中没有Bean所以要我们自己把它注册到Bean中
    //(url, 实体：Map, Class responseType)
    @Autowired
    private RestTemplate restTemplate;  //提供多种便捷访问远程http服务的方法，简单的restful服务模板

    private static final String REST_URL_PREFIX = "http://localhost:8001";

    @RequestMapping("/consumer/dept/get/{id}")
    @ResponseBody
    public Dept getDept(@PathVariable("id") Long id) {
        //service不在本项目中，所以要去远程项目获取
        //远程只能用  get 方式请求，那么这里也只能通过 get 方式获取
        return restTemplate.getForObject(REST_URL_PREFIX + "/dept/get/" + id, Dept.class);
    }

    @RequestMapping("/consumer/dept/add")
    @ResponseBody
    public boolean add(Dept dept) {
        //远程只能用  post 方式请求，那么这里也只能通过 post 方式获取
        return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);
    }

    @RequestMapping("/consumer/dept/list")
    @ResponseBody
    public List queryAll() {
        return restTemplate.getForObject(REST_URL_PREFIX + "/dept/list", List.class);
    }

}

• 最后启动服务提供者 springcloud-provider-dept-8001

• 然后启动服务消费者 springcloud-consumer-dept-80

• 通过服务消费者的url请求去获取服务提供者对应的请求，照样可以拿到