本项目的笔记和资料的Download，请点击这一句话自行获取。
day01-springboot（理论篇） ；day01-springboot（实践篇）
day02-springcloud（理论篇一：HttpClient的简单使用) ；day02-springcloud(理论篇二：知道什么是SpringCloud) ；day02-springcloud(理论篇三：搭建Eureka注册中心)
14 微服务电商【黑马乐优商城】：day02-springcloud
0.学习目标
- 了解系统架构的演变
- 了解RPC与Http的区别
- 掌握HttpClient的简单使用
- 知道什么是SpringCloud
- 独立搭建Eureka注册中心
- 独立配置Robbin负载均衡
4.初识SpringCloud
微服务是一种架构方式，最终肯定需要技术架构去实施。
微服务的实现方式很多，但是最火的莫过于Spring Cloud了。为什么？
- 后台硬：作为Spring家族的一员，有整个Spring全家桶靠山，背景十分强大。
- 技术强：Spring作为Java领域的前辈，可以说是功力深厚。有强力的技术团队支撑，一般人还真比不了。
- 群众基础好：可以说大多数程序员的成长都伴随着Spring框架，试问：现在有几家公司开发不用Spring？SpringCloud与Spring的各个框架无缝整合，对大家来说一切都是熟悉的感觉。
- 使用方便：相信大家都体会到了SpringBoot给我们开发带来的便利，而SpringCloud完全支持SpringBoot的开发，用很少的配置就能完成微服务框架的搭建。
4.1.简介
SpringCloud是Spring旗下的项目之一，官网地址：http://projects.spring.io/spring-cloud/
Spring最擅长的就是集成，把世界上最好的框架拿过来，集成到自己的项目中。
SpringCloud也是一样，它将现在非常流行的一些技术整合到一起，实现了诸如：配置管理，服务发现，智能路由，负载均衡，熔断器，控制总线，集群状态等等功能。其主要涉及的组件包括：
netflix
- Eureka：注册中心
- Zuul：服务网关
- Ribbon：负载均衡
- Feign：服务调用
- Hystix：熔断器
以上只是其中一部分，架构图：
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