本项目的笔记和资料的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的为首字母的一些单词组成
我们在项目中,会是以Finchley的版本。
其中包含的组件,也都有各自的版本。
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问题
OkHttp官方教程解析-彻底入门OkHttp使用
end