ToB企服应用市场:ToB评测及商务社交产业平台
标题:
SpringCloud学习笔记(一)微服务先容、服务拆分和RestTemplate长途调用、Eur
[打印本页]
作者:
老婆出轨
时间:
2024-7-18 02:36
标题:
SpringCloud学习笔记(一)微服务先容、服务拆分和RestTemplate长途调用、Eur
1 熟悉微服务
1.1 单体架构
单体架构即将业务的全部功能会合在一个项目中开发,打成一个包举行部署。
单体架构的优缺点如下:
优点:
架构简单
部署本钱低
缺点:
耦合度高(维护困难、升级困难)
1.2 分布式架构
分布式架构即根据业务功能对系统做拆分,每个业务功能模块作为独立项目开发,称为一个服务。
分布式架构的优缺点:
优点:
降低服务耦合
有利于服务升级和拓展
缺点:
服务调用关系错综复杂
要考虑的问题多:服务拆分的粒度如何界定?服务之间如何调用?服务的调用关系如何管理?
为此,我们需要制定一套行之有效的标准来规范分布式框架。
1.3 微服务
微服务的架构特征:
单一职责
:微服务拆分粒度更小,每一个服务都对应唯一的业务能力,做到单一职责
自治
:团队独立、技术独立、数据独立,独立部署和交付
面向服务
:服务提供统一标准的接口,与语言和技术无关
隔离性强
:服务调用做好隔离、容错、降级,制止出现级联问题
微服务的上述特性实在是在给分布式架构制定一个标准,进一步降低服务之间的耦合度,提供服务的独立性和灵活性,做到
高内聚、低耦合
。
因此,可以认为微服务是一种颠末良好架构设计的分布式架构方案 。
但方案该怎么落地?选用什么样的技术栈?全球的互联网公司都在积极尝试本身的微服务落地方案。
此中在Java范畴最引人注目的就是SpringCloud提供的方案了。
1.4 SpringCloud
SpringCloud是目前国内使用最广泛的微服务框架,其官网地址:https://spring.io/projects/spring-cloud。
SpringCloud集成了各种微服务功能组件,并基于SpringBoot实现了这些组件的自动装配,从而提供了良好的
开箱即用
体验。
此中常见的组件包罗:
别的,
SpringCloud底层是依赖于SpringBoot的,并且有版本的兼容关系
,如下:
该学习笔记使用的版本是 Hoxton.SR10,对应的SpringBoot版本是2.3.x版本。
1.5 总结
单体架构
:简单方便,高度耦合,扩展性差,适合小型项目。比方:门生管理系统
分布式架构
:松耦合,扩展性好,但架构复杂,难度大。适合大型互联网项目,比方:京东、淘宝
微服务
:一种良好的分布式架构方案
优点
:拆分粒度更小、服务更独立、耦合度更低
缺点
:架构非常复杂,运维、监控、部署难度提高
SpringCloud是微服务架构的一站式解决方案,集成了各种优秀微服务功能组件
2 服务拆分与长途调用
2.1 服务拆分原则
微服务举行服务时应遵照以下几个原则:
不同微服务,不要重复开发类似业务
微服务数据独立,不要访问别的微服务的数据库
微服务可以将本身的业务暴露为接口,供别的微服务调用
2.2 服务拆分示例
2.2.1 搭建项目
下面创建一个示例项目,项目结构如下:
sc-demo:父工程,管理依赖
order-service:订单微服务,负责订单相关业务(8080端口)
user-service:用户微服务,负责用户相关业务(8081端口)
项目代码下载:https://gitee.com/weidag/springcloud_learning.git
要求:
订单微服务和用户微服务都必须有各自的数据库,相互独立
订单服务和用户服务都对外暴露Restful的接口
订单服务如果需要查询用户信息,只能调用用户服务的Restful接口,不能查询用户数据库
2.2.2 创建数据库和表
创建用户微服务的数据库和表:
CREATE DATABASE sc_user_db;
USE sc_user_db;
CREATE TABLE `tb_user` (
`id` bigint NOT NULL AUTO_INCREMENT,
`username` varchar(100) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci DEFAULT NULL COMMENT '收件人',
`address` varchar(255) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci DEFAULT NULL COMMENT '地址',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE KEY `username` (`username`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=109 DEFAULT CHARSET=utf8mb3 ROW_FORMAT=COMPACT;
INSERT INTO `tb_user` VALUES (1, '孙悟空', '湖南省衡阳市');
INSERT INTO `tb_user` VALUES (2, '猪八戒', '陕西省西安市');
INSERT INTO `tb_user` VALUES (3, '沙悟净', '湖北省十堰市');
INSERT INTO `tb_user` VALUES (4, '唐三藏', '天津市');
INSERT INTO `tb_user` VALUES (5, '白龙马', '辽宁省沈阳市大东区');
INSERT INTO `tb_user` VALUES (6, '唐太宗', '山东省青岛市');
复制代码
创建订单微服务的数据库和表:
CREATE DATABASE sc_order_db;
USE sc_order_db;
CREATE TABLE `tb_order` (
`id` bigint NOT NULL AUTO_INCREMENT COMMENT '订单id',
`user_id` bigint NOT NULL COMMENT '用户id',
`name` varchar(100) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci DEFAULT NULL COMMENT '商品名称',
`price` bigint NOT NULL COMMENT '商品价格',
`num` int DEFAULT '0' COMMENT '商品数量',
PRIMARY KEY (`id`) USING BTREE,
UNIQUE KEY `username` (`name`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=109 DEFAULT CHARSET=utf8mb3 ROW_FORMAT=COMPACT;
INSERT INTO `tb_order` VALUES (101, 1, 'Apple 苹果 iPhone 12 ', 699900, 1);
INSERT INTO `tb_order` VALUES (102, 2, '雅迪 yadea 新国标电动车', 209900, 1);
INSERT INTO `tb_order` VALUES (103, 3, '骆驼(CAMEL)休闲运动鞋女', 43900, 1);
INSERT INTO `tb_order` VALUES (104, 4, '小米10 双模5G 骁龙865', 359900, 1);
INSERT INTO `tb_order` VALUES (105, 5, 'OPPO Reno3 Pro 双模5G 视频双防抖', 299900, 1);
INSERT INTO `tb_order` VALUES (106, 6, '美的(Midea) 新能效 冷静星II ', 544900, 1);
INSERT INTO `tb_order` VALUES (107, 2, '西昊/SIHOO 人体工学电脑椅子', 79900, 1);
INSERT INTO `tb_order` VALUES (108, 3, '梵班(FAMDBANN)休闲男鞋', 31900, 1);
复制代码
订单表tb_order持有用户表tb_user的user_id字段。
2.2.3 实现长途调用
在user-service中,实现了一个根据id查询用户信息的接口:
启动user-service服务,调用该接口可以查询出对应的用户信息:
同样,在order-service中,实现了一个根据id查询订单信息的接口:
启动order-service服务,调用该接口可以查询出对应的订单信息:
可以发现,返回的订单信息中user字段为空。
2.2.3.1 需求描述
现有如下需求:在order-service服务中,根据id查询订单信息的同时,根据订单中包含的userId字段查询出用户信息,一起返回。
为此,我们需要在order-service服务中 向user-service服务发起一个http的请求,调用http://localhost:8090/user/{userId}这个接口根据id查询用户信息。
而要实现服务之间的调用,可以通过RestTemplate工具来实现。RestTemplate是从Spring3.0开始支持的一个HTTP请求工具,它提供了常见的REST请求方案的模版,比方GET请求、POST请求、PUT请求、DELETE请求等。
2.2.3.2 注册RestTemplate
在order-service服务的OrderApplication启动类中,注册RestTemplate:
// com.star.order.OrderApplication
@MapperScan("com.star.order.mapper")
@SpringBootApplication
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class, args);
}
@Bean
public RestTemplate restTemplate() {
return new RestTemplate();
}
}
复制代码
2.2.3.3 实现长途调用
修改OrderService类的queryOrderById()方法,使用RestTemplate实现长途调用:
// com.star.order.service.OrderService
@Service
public class OrderService {
@Autowired
private OrderMapper orderMapper;
@Autowired
private RestTemplate restTemplate;
public Order queryOrderById(Long orderId) {
// 1.查询订单
Order order = orderMapper.findById(orderId);
// 2.远程查询用户信息
String url = "http://127.0.0.1:8090/user/" + order.getUserId();
User user = restTemplate.getForObject(url, User.class);
order.setUser(user);
// 3.返回
return order;
}
}
复制代码
再次调用/order/{orderId}接口,查询对应的订单信息:
可以发现,返回的订单信息中user字段也一并被查询了出来,RestTemplate实现长途调用成功。
2.2.4 提供者与斲丧者
在本次服务调用关系中,有两个不同的脚色:
服务提供者
:一次业务中,被别的微服务调用的服务,即user-service服务。(提供接口给别的微服务)
服务斲丧者
:一次业务中,调用别的微服务的服务,即order-service服务。
但是,
服务提供者与服务斲丧者的脚色并不是绝对的,而是相对于业务而言
,比方order-service服务既可以是服务斲丧者,也可以是服务提供者给user-service服务调用。
3 Eureka注册中央
假如user-service服务部署了多个实例,如图:
那么这就产生了几个问题:
order-service服务在发起长途调用的时候,该如何得知user-service实例的ip地址和端口?
有多个user-service实例地址,order-service调用时该如何选择?
order-service如何得知某个user-service实例是否依然康健,是不是已经宕机?
3.1 Eureka的结构和作用
这些问题都需要使用SpringCloud中的
注册中央
来解决,也就是
Eureka
,其结构如下:
问题1:order-service服务在发起长途调用的时候,该如何得知user-service实例的ip地址和端口?
1)user-service服务实例启动后,将本身的信息注册到eureka-server(Eureka服务端),即服务注册;
2)eureka-server保存服务名称到服务实例地址列表的映射关系;
3)order-service根据服务名称,拉取实例地址列表,即服务发现或服务拉取。
问题2:有多个user-service实例地址,order-service调用时该如何选择?
1)order-service从实例列表中使用
负载均衡
算法选中一个实例地址;
2)向该实例地址发起长途调用。
问题3:order-service如何得知某个user-service实例是否依然康健,是不是已经宕机?
1)user-service会每隔一段时间(默认30秒)向eureka-server发起请求,报告本身状态,称为心跳;
2)当凌驾一定时间没有发送心跳时,eureka-server会认为微服务实例故障,将该实例从服务列表中剔除;
3)order-service拉取服务时,就能将故障实例排除了。
3.2 搭建eureka-server服务
3.2.1 创建eureka-server模块
注册中央eureka-server服务,必须是一个独立的微服务,因此在父工程sc_demo下创建一个子模块:
3.2.2 引入eureka-server依赖
// sc_demo\eureka-server\pom.xml
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
复制代码
3.2.3 编写启动类
和普通的SpringBoot启动类不同的是,该启动类需要添加@EnableEurekaServer注解,以开启eureka的注册中央功能:
// com.star.eureka.EurekaApplication
@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
public static void main(String[] args) {
SpringApplication.run(EurekaApplication.class, args);
}
}
复制代码
3.2.4 编写配置文件
在sc_demo\eureka-server\src\main\resources目录下创建一个application.yml文件,内容如下:
server:
port: 10086
spring:
application:
name: eureka-server
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:10086/eureka
复制代码
3.2.5 启动服务
启动微服务,然后在欣赏器访问:http://127.0.0.1:10086,出现以下界面就说明注册中央eureka-server服务创建成功了。
3.3 注册user-service服务
接下来将user-service服务注册到eureka-server服务中。
3.3.1 引入eureka-client依赖
在user-service服务中,引入eureka-client依赖:
// sc_demo\user-service\pom.xml
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
复制代码
3.3.2 修改配置文件
在user-service服务中,修改application.yml文件,添加服务名称、eureka-server地址:
// sc_demo\user-service\src\main\resources\application.yml
spring:
application:
name: user-service
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:10086/eureka
复制代码
3.3.3 启动服务
启动user-service服务,检察eureka-server管理页面,可以发现user-service服务已经注册到了eureka-server服务中:
3.3.4 启动多个user-service实例
在IDEA上再启动一个user-service实例,配置其端口为8082。启动后检察eureka-server管理页面,可以发现此时有2个user-service服务(端口分别是8081和8082)注册到了eureka-server服务中:
3.4 服务发现
接下来,修改order-service的逻辑:向eureka-server拉取user-service的信息,实现服务发现。
3.4.1 引入eureka-client依赖
在order-service服务中,引入eureka-client依赖:
// sc_demo\order-service\pom.xml
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
复制代码
3.4.2 修改配置文件
在order-service服务中,修改application.yml文件,添加服务名称、eureka-server地址:
// sc_demo\order-service\src\main\resources\application.yml
spring:
application:
name: order-service
eureka:
client:
service-url:
defaultZone: http://127.0.0.1:10086/eureka
复制代码
3.4.3 服务拉取和负载均衡
在order-service的OrderApplication启动类中,给RestTemplate这个Bean添加一个@LoadBalanced注解,以启用负载均衡:
// com.star.order.OrderApplication
@Bean
@LoadBalanced
public RestTemplate restTemplate() {
return new RestTemplate();
}
复制代码
修改order-service的OrderService类中的queryOrderById()方法,修改访问的url路径,
用服务名代替ip、端口
:
// order-service#com.star.order.service.OrderService#queryOrderById()
// 2.远程查询用户信息
// String url = "http://127.0.0.1:8081/user/" + order.getUserId();
// 使用服务名代替ip和端口
String url = "http://user-service/user/" + order.getUserId();
复制代码
如许配置之后,会根据user-service这个服务名称,从erueka-server中获取实例列表,而后完成负载均衡。
3.4.4 功能测试
重启order-service服务,会发现该服务也注册到了erueka-server中:
调用/order/102接口,查询用户信息的请求分发到了8081端口的user-service:
调用/order/101接口,查询用户信息的请求分发到了8082端口的user-service:
…
本节完,更多内容请查阅分类专栏:SpringCloud学习笔记
本文涉及代码下载地址:https://gitee.com/weidag/springcloud_learning.git
感兴趣的读者还可以查阅我的别的几个专栏:
SpringBoot源码解读与原理分析(已完结)
MyBatis3源码深度解析(已完结)
Redis从入门到精通(已完结)
MyBatisPlus详解(已完结)
再探Java为面试赋能(持续更新中…)
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/)
Powered by Discuz! X3.4