14 微服务电商【黑马乐优商城】：day02-springcloud(理论篇二：知道什么是SpringCloud)
本项目的笔记和资料的Download，请点击这一句话自行获取。html
day01-springboot（理论篇） ；day01-springboot（实践篇）java
day02-springcloud（理论篇一：HttpClient的简单使用) ；day02-springcloud(理论篇二：知道什么是SpringCloud) ；day02-springcloud(理论篇三：搭建Eureka注册中心)mysql
14 微服务电商【黑马乐优商城】：day02-springcloud
0.学习目标
- 了解系统架构的演变
- 了解RPC与Http的区别
- 掌握HttpClient的简单使用
- 知道什么是SpringCloud
- 独立搭建Eureka注册中心
- 独立配置Robbin负载均衡
4.初识SpringCloud
微服务是一种架构方式，最终确定须要技术架构去实施。程序员
微服务的实现方式不少，可是最火的莫过于Spring Cloud了。为何？web
- 后台硬：做为Spring家族的一员，有整个Spring全家桶靠山，背景十分强大。
- 技术强：Spring做为Java领域的前辈，能够说是功力深厚。有强力的技术团队支撑，通常人还真比不了。
- 群众基础好：能够说大多数程序员的成长都伴随着Spring框架，试问：如今有几家公司开发不用Spring？SpringCloud与Spring的各个框架无缝整合，对你们来讲一切都是熟悉的感受。
- 使用方便：相信你们都体会到了SpringBoot给咱们开发带来的便利，而SpringCloud彻底支持SpringBoot的开发，用不多的配置就能完成微服务框架的搭建。
4.1.简介
SpringCloud是Spring旗下的项目之一，官网地址：http://projects.spring.io/spring-cloud/spring
Spring最擅长的就是集成，把世界上最好的框架拿过来，集成到本身的项目中。sql
SpringCloud也是同样，它将如今很是流行的一些技术整合到一块儿，实现了诸如：配置管理，服务发现，智能路由，负载均衡，熔断器，控制总线，集群状态等等功能。其主要涉及的组件包括：数据库
netflixapache
- Eureka：注册中心
- Zuul：服务网关
- Ribbon：负载均衡
- Feign：服务调用
- Hystix：熔断器
以上只是其中一部分，架构图：tomcat
4.2.版本
SpringCloud的版本命名比较特殊，由于它不是一个组件，而是许多组件的集合，它的命名是以A到Z的为首字母的一些单词组成
其中包含的组件，也都有各自的版本。
Greenwich builds and works with Spring Boot 2.1.x, and is not expected to work with Spring Boot 1.5.x.
接下来，咱们就一一学习SpringCloud中的重要组件。
5.微服务场景模拟
首先，咱们须要模拟一个服务调用的场景。方便后面学习微服务架构
5.1.服务提供者
咱们新建一个项目，对外提供查询用户的服务。
5.1.1.Spring脚手架建立工程
借助于Spring提供的快速搭建工具：
填写项目信息：
添加web依赖：
添加mybatis依赖：
Spring Boot 的版本能够在自动搭建生成后，手动在pom.xml里修改未显示的低版本！
填写项目位置：
生成的项目结构：
依赖也已经所有自动引入：
固然，由于要使用通用mapper，因此咱们须要手动加一条依赖：
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.9.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.leyou.demo</groupId> <artifactId>user-service-demo</artifactId> <version>0.0.1-SNAPSHOT</version> <name>user-service-demo</name> <description>Demo project for Spring Boot</description> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!--springboot测试的起步依赖--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <!--SpringBoot热部署开发模式启动器--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <scope>runtime</scope> <optional>true</optional> </dependency> <!--DAO层相关数据库驱动的启动器--> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> <!-- 启用了通用Mapper，下面的mybatis和jdbc就能够自动继承依赖，所以注释掉--> <!--<dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>2.1.0</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jdbc</artifactId> </dependency>--> <!-- 通用mapper的启动器 --> <dependency> <groupId>tk.mybatis</groupId> <artifactId>mapper-spring-boot-starter</artifactId> <version>2.1.5</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>3.4.6</version> </dependency> <!-- Druid链接池启动器 --> <!--<dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.1.10</version> </dependency>--> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
使用spring initializr很是快捷啊！
5.1.2.编写代码
添加一个对外查询（微服务架构的）接口：
Controller层
@RestController //等同于@Controller+@ResponseBody @RequestMapping("user") public class UserController { @Autowired private IUserService userService; @GetMapping("/{id}") // public User queryById(@PathVariable(name = "id") Long id){ User user= this.userService.queryById(id); return user; } }
Service层的接口的实现类
@Service @Transactional //启用事务的注解 public class UserServiceImpl implements IUserService { @Autowired private UserMapper userMapper; @Override public User queryById(Long id) { return this.userMapper.selectByPrimaryKey(id); } }
DAO层提供给 通用Mapper查询的Interface
//@Mapper //@Repository //此处的注解做用有待测试，添加以后IDEA对Service层不报错 public interface UserMapper extends tk.mybatis.mapper.common.Mapper<User> { }
数据库对应的实体类： 若是是非持久化的属性字段要用注解@Transient声明
@Table(name = "tb_user") public class User implements Serializable { // private static final long serialVersionUID = 1L; @Id @KeySql(useGeneratedKeys = true) //主键，必须用基本类型的包装类 //此处用long基本类型会返回null private Long id; // 用户名 private String userName; // 密码 private String password; // 姓名 private String name; // 年龄 private Integer age; // 性别，1男性，2女性 private Integer sex; // 出生日期 private Date birthday; // 备注 private String note; // 建立时间 private Date created; // 更新时间 private Date updated; //=====下面省略get/set方法和toString()方法=====//
属性配置文件,这里咱们采用了yaml语法，而不是properties：
application-demo.yml
spring: datasource: #四项链接配置 driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://localhost:3306/leyou?useUniode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai username: root password: root #链接池类型 type: com.zaxxer.hikari.HikariDataSource #链接池个性化配置 hikari: maximum-pool-size: 20 minimum-idle: 10 mybatis: #配置entity实体类的映射扫描包 type-aliases-package: com.leyou.demo.userservice.pojo configuration: #配置下划线转驼峰规则 map-underscore-to-camel-case: true #tomcat服务器端口 server: port: 8081 # servlet: #对应的是视图层方法上@RequestMapping注解的("/*.do") # path: "*.do" #log4j日志输出控制 #logging: # level: # cn.bjut.interceptor: debug
application.yml
spring:
profiles:
active: demo
5.1.3.启动并测试：
启动项目，访问接口：http://localhost:8081/user/7
5.2.服务调用者
5.2.1.建立工程
与上面相似，这里再也不赘述，须要注意的是，咱们调用user-service的功能，所以不须要mybatis相关依赖了。
pom.xml
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.9.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.leyou.demo</groupId> <artifactId>user-consumer-demo</artifactId> <version>0.0.1-SNAPSHOT</version> <name>user-consumer-demo</name> <description>Demo project for Spring Boot</description> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <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> <!-- 添加OkHttp支持 --> <dependency> <groupId>com.squareup.okhttp3</groupId> <artifactId>okhttp</artifactId> <version>4.2.1</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
5.2.2.编写代码
首先在启动类中注册RestTemplate：
@SpringBootApplication public class UserConsumerDemoApplication { public static void main(String[] args) { SpringApplication.run(UserConsumerDemoApplication.class, args); } @Bean public RestTemplate restTemplate() { //注册谁，就用@Bean注解返回，谁的一个匿名对象 // 此次咱们使用了OkHttp客户端,只须要注入工厂便可 return new RestTemplate(new OkHttp3ClientHttpRequestFactory()); } }
而后编写UserDao，注意，这里不是调用mapper查数据库，而是经过RestTemplate远程查询user-service-demo中的接口：
@Repository public class UserDao { @Autowired private RestTemplate restTemplate; public User queryUserById(Long id){ String url = "http://localhost:8081/user/" + id; //RestTemplate的.getForObject方法封装了JSON转实体类的过程 return this.restTemplate.getForObject(url, User.class); } }
而后编写user-service，循环查询UserDAO信息：
@Service public class UserService { @Autowired private UserDao userDao; public List<User> querUserByIds(List<Long> ids){ //初始化一个集合对象放查询结果 List<User> users = new ArrayList<>(); for (Long id : ids) { User user = this.userDao.queryUserById(id); users.add(user); } return users; } }
编写controller：
@RestController @RequestMapping("consume") public class ConsumerController { @Autowired private UserService userService; @GetMapping public List<User> consume(@RequestParam("ids") List<Long> ids) { return this.userService.querUserByIds(ids); } }
5.2.3.启动测试：
由于咱们没有配置端口，那么默认就是8080，咱们访问：http://localhost:8080/consume?ids=6,7,8
一个简单的远程服务调用案例就实现了。
5.3.有没有问题？
简单回顾一下，刚才咱们写了什么：
- use-service-demo：一个提供根据id查询用户的微服务
- consumer-demo：一个服务调用者，经过RestTemplate远程调用user-service-demo
流程以下：
存在什么问题？
- 在consumer中，咱们把url地址硬编码到了代码中，不方便后期维护
- consumer须要记忆user-service的地址，若是出现变动，可能得不到通知，地址将失效
- consumer不清楚user-service的状态，服务宕机也不知道
- user-service只有1台服务，不具有高可用性
- 即使user-service造成集群，consumer还需本身实现负载均衡
其实上面说的问题，归纳一下就是分布式服务必然要面临的问题：
- 服务管理
- 如何自动注册和发现
- 如何实现状态监管
- 如何实现动态路由
- 服务如何实现负载均衡
- 服务如何解决容灾问题
- 服务如何实现统一配置
以上的问题，咱们都将在SpringCloud中获得答案。
================================================
参考资料：
springboot 使用通用mapper时pojo 定义为基本类型 从数据库查不到数据 返回null
解决mybatis的mapper.xml查询不出数据，结果一直为null问题
end