微服务拆分
微服务拆分接下来，我们就一起将黑马商城这个单体项目拆分为微服务项目，并解决此中出现的各种问题。
熟悉黑马商城
首先，我们需要熟悉黑马商城项目的基本布局：
https://i-blog.csdnimg.cn/direct/4327e4d62c4e4a028b3b09f9b747afb2.png
大家可以直接启动该项目，测试效果。不过，需要修改数据库毗连参数，在application-local.yaml中：
hm:
db:
host: 192.168.202.128 # 修改为你自己的虚拟机IP地址
pw: 1234 # 修改为docker中的MySQL密码
同时设置启动项激活的是local环境：
https://i-blog.csdnimg.cn/direct/2092296eaf0a41d2ad456780991c6925.png
登录
首先来看一下登录业务流程：
https://i-blog.csdnimg.cn/direct/12348f2eae644717ba84cd9f6bb7fd99.png
登录入口在com.hmall.controller.UserController中的login方法：
https://i-blog.csdnimg.cn/direct/127266803fe94a339989a45dbc333a94.png
搜索商品
在首页搜索框输入关键字，点击搜索即可进入搜索列表页面：
https://i-blog.csdnimg.cn/direct/02acbce81d324ddba4f5b98aa0c2275d.png
该页面会调用接口：/search/list，对应的服务端入口在com.hmall.controller.SearchController中的search方法：
https://i-blog.csdnimg.cn/direct/99dc0db03cc2455bb733350807df5aa8.png
这里如今是使用数据库实现了简单的分页查询。
购物车
在搜索到的商品列表中，点击按钮参加购物车，即可将商品参加购物车：
https://i-blog.csdnimg.cn/direct/15e1890995e143ada7c45a928065f421.png
参加乐成后即可进入购物车列表页，查察本身购物车商品列表：
https://i-blog.csdnimg.cn/direct/e56eaa1725574713acdaa560f0490d97.png
同时这里还可以对购物车实现修改、删除等操纵。
干系功能全部在com.hmall.controller.CartController中：
https://i-blog.csdnimg.cn/direct/46c9754c5ab04b80ae82f9d57d4eab5c.png
此中，查询购物车列表时，由于要判定商品最新的价格和状态，所以还需要查询商品信息，业务流程如下：
https://i-blog.csdnimg.cn/direct/411abafb1a6548e9b88c635519f1d7a1.png
下单
在购物车页面点击结算按钮，会进入订单结算页面：
https://i-blog.csdnimg.cn/direct/81b8ee7d22ca4fafb1383a6370f60645.png
点击提交订单，会提交哀求到服务端，服务端做3件事变：
[*]创建一个新的订单
[*]扣减商品库存
[*]清算购物车中商品
业务入口在com.hmall.controller.OrderController中的createOrder方法：
https://i-blog.csdnimg.cn/direct/258f4abe9ac648dca1f88542d7c04ff5.png
付出
下单完成后会跳转到付出页面，如今只支持余额付出：
https://i-blog.csdnimg.cn/direct/da63548eff5f4b6daa4e5639cd5aee68.png
在选择余额付出这种方式后，会发起哀求到服务端，服务端会立刻创建一个付出流水单，并返回付出流水单号到前端。
当用户输入用户暗码，然后点击确认付出时，页面会发送哀求到服务端，而服务端会做几件事变：
[*]校验用户暗码
[*]扣减余额
[*]修改付出流水状态
[*]修改交易订单状态
哀求入口在com.hmall.controller.PayController中：
https://i-blog.csdnimg.cn/direct/ed6e0c2980654984873dab027978e79c.png
服务拆分原则
服务拆分一定要考虑几个问题：
[*]什么时间拆？
[*]如何拆？
什么时间拆
一样平常情况下，对于一个初创的项目，首先要做的是验证项目的可行性。因此这一阶段的首要任务是敏捷开辟，快速产出生产可用的产物，投入市场做验证。为了达成这一目的，该阶段项目架构通常会比力简单，许多情况下会直接采用单体架构，如许开辟成本比力低，可以快速产出结果，一旦发现项目不符合市场，损失较小。如果这一阶段采用复杂的微服务架构，投入大量的人力和时间成本用于架构计划，终极发现产物不符合市场需求，等于全部做了无勤奋。
所以，对于大多数小型项目来说，一样平常是先采用单体架构，随着用户规模扩大、业务复杂后再逐渐拆分为微服务架构**。如许初期成本会比力低，可以快速试错。但是，这么做的问题就在于后期做服务拆分时，可能会碰到许多代码耦合带来的问题，拆分比力困难（**前易后难）。
而对于一些大型项目，在立项之初目的就很明白，为了长远考虑，在架构计划时就直接选择微服务架构。固然前期投入较多，但后期就少了拆分服务的烦恼（前难后易）。
怎么拆
之前我们说过，微服务拆分时粒度要小，这实在是拆分的目标。具体可以从两个角度来分析：
[*]高内聚：每个微服务的职责要只管单一，包含的业务相互关联度高、完整度高。
[*]低耦合：每个微服务的功能要相对独立，只管减少对其它微服务的依赖，大概依赖接口的稳定性要强。
高内聚首先是单一职责，但不能说一个微服务就一个接口，而是要包管微服务内部业务的完整性为前提。目标是当我们要修改某个业务时，最好就只修改当前微服务，如许变更的成本更低。一旦微服务做到了高内聚，那么服务之间的耦合度自然就降低了。
当然，微服务之间不可避免的会有或多或少的业务交互，比如下单时需要查询商品数据。这个时间我们不能在订单服务直接查询商品数据库，否则就导致了数据耦合。而应该由商品服务对应暴露接口，并且一定要包管微服务对外接口的稳定性（即：只管包管接口外观稳定）。固然出现了服务间调用，但此时无论你如何在商品服务做内部修改，都不会影响到订单微服务，服务间的耦合度就降低了。
明白了拆分目标，接下来就是拆分方式了。我们在做服务拆分时一样平常有两种方式：
[*]纵向拆分
[*]横向拆分
所谓纵向拆分，就是按照项目的功能模块来拆分。比方黑马商城中，就有用户管理功能、订单管理功能、购物车功能、商品管理功能、付出功能等。那么按照功能模块将他们拆分为一个个服务，就属于纵向拆分。这种拆分模式可以尽可能提高服务的内聚性。
而横向拆分，是看各个功能模块之间有没有公共的业务部分，如果有将其抽取出来作为通用服务。比方用户登录是需要发送消息通知，纪录风控数据，下单时也要发送短信，纪录风控数据。因此消息发送、风控数据纪录就是通用的业务功能，因此可以将他们分别抽取为公共服务：消息中央服务、风控管理服务。如许可以提高业务的复用性，避免重复开辟。同时通用业务一样平常接口稳定性较强，也不会使服务之间太过耦合。
当然，由于黑马商城并不是一个完整的项目，此中的短信发送、风控管理并没有实现，这里就不再考虑了。而其它的业务按照纵向拆分，可以分为以下几个微服务：
[*]用户服务
[*]商品服务
[*]订单服务
[*]购物车服务
[*]付出服务
拆分购物车、商品服务
接下来，我们先把商品管理功能、购物车功能抽取为两个独立服务。
一样平常微服务项目有两种差别的工程布局：
[*]完全解耦：每一个微服务都创建为一个独立的工程，乃至可以使用差别的开辟语言来开辟，项目完全解耦。
[*]长处：服务之间耦合度低
[*]缺点：每个项目都有本身的独立堆栈，管理起来比力麻烦
[*]Maven聚合：整个项目为一个Project，然后每个微服务是此中的一个Module
[*]长处：项目代码会合，管理和运维方便
[*]缺点：服务之间耦合，编译时间较长
注意：
这里采用Maven聚合工程，大家以后到了企业，可以根据需求自由选择工程布局。在hmall父工程之中，我已经提前界说了SpringBoot、SpringCloud的依赖版本，所以为了方便期间，我们直接在这个项目中创建微服务module.
商品服务
在hmall中创建module，选择maven模块，并设定JDK版本为11。商品模块，我们起名为item-service：
https://i-blog.csdnimg.cn/direct/23e66f23f94c41ffb2aa8719721a22d0.png
引入依赖：
<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>hmall</artifactId>
<groupId>com.heima</groupId>
<version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>item-service</artifactId>
<properties>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
</properties>
<dependencies>
<!--common-->
<dependency>
<groupId>com.heima</groupId>
<artifactId>hm-common</artifactId>
<version>1.0.0</version>
</dependency>
<!--web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--数据库-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!--mybatis-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
</dependency>
<!--单元测试-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
</dependencies>
<build>
<finalName>${project.artifactId}</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
编写启动类：
https://i-blog.csdnimg.cn/direct/c2c9fbd57d0742d486eaac64fc0f89ef.png
代码如下：
package com.hmall.item;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@MapperScan("com.hmall.item.mapper")
@SpringBootApplication
public class ItemApplication {
public static void main(String[] args) {
SpringApplication.run(ItemApplication.class, args);
}
}
接下来是设置文件，可以从hm-service中拷贝：
https://i-blog.csdnimg.cn/direct/2f0c8123dbbd4c9ba89820fad1065f0e.png
此中，application.yaml内容如下：
server:
#port: 8080
port: 8081
spring:
application:
name: item-service
# name: hm-service
profiles:
active: dev
datasource:
url: jdbc:mysql://${hm.db.host}:3306/hmall?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: ${hm.db.pw}
mybatis-plus:
configuration:
default-enum-type-handler: com.baomidou.mybatisplus.core.handlers.MybatisEnumTypeHandler
global-config:
db-config:
update-strategy: not_null
id-type: auto
logging:
level:
com.hmall: debug
pattern:
dateformat: HH:mm:ss:SSS
file:
path: "logs/${spring.application.name}"
knife4j:
enable: true
openapi:
title: 商品服务接口
# title: 黑马商城接口文档
description: "信息"
#description: "黑马商城接口文档"
email: zs0536@stu.edu.cn
concat: Charlie
url: https://www.itcast.cn
version: v1.0.0
group:
default:
group-name: default
api-rule: package
api-rule-resources:
- com.hmall.item.controller
# - com.hmall.controller
剩下的application-dev.yaml和application-local.yaml直接从hm-service拷贝即可。
然后拷贝hm-service中与商品管理有关的代码到item-service，如图：
https://i-blog.csdnimg.cn/direct/c6f9df9da7324a7496314572b09d33a0.png
这里有一个地方的代码需要改动，就是ItemServiceImpl中的deductStock方法：
改动前
https://i-blog.csdnimg.cn/direct/e1ef298abb0e4220a8258f3004ad819d.png
改动后
https://i-blog.csdnimg.cn/direct/a5e49388042f43f3a13e6d8a9be1970b.png
这也是因为ItemMapper的所在包发生了变化，因此这里代码必须修改包路径。
最后，还要导入数据库表。默认的数据库毗连的是假造机，在你docker数据库执行网盘中提供的SQL文件：
通过网盘分享的文件：微服务独立数据库
链接: https://pan.baidu.com/s/1ep9hMO6m8st8nEHedW-R6w?pwd=j6am 提取码: j6am
–来自百度网盘超等会员v5的分享
https://i-blog.csdnimg.cn/direct/6395fb2ee980487fb4acbc3a01530e26.png
终极，会在数据库创建一个名为hm-item的database，将来的每一个微服务都会有本身的一个database：
https://i-blog.csdnimg.cn/direct/d15e17f0d5df4559b1e5619a46185154.png
注意：在企业开辟的生产环境中，每一个微服务都应该有本身的独立数据库服务，而不仅仅是database，讲堂我们用database来取代。
接下来，就可以启动测试了，在启动前我们要设置一下启动项，让默认激活的设置为local而不是dev,在打开的编辑框填写active profiles:
https://i-blog.csdnimg.cn/direct/20eb40fa51cf4f04b9f8331062aac161.png
接着，启动item-service，访问商品微服务的swagger接口文档：http://localhost:8081/doc.html
然后测试此中的根据id批量查询商品这个接口，测试参数：100002672302,100002624500,100002533430，结果如下：
https://i-blog.csdnimg.cn/direct/1b352c39a576401bb03d6427f0723ba5.png
阐明商品微服务抽取乐成了。
购物车服务
与商品服务类似，在hmall下创建一个新的module，起名为cart-service:
https://i-blog.csdnimg.cn/direct/5bfe02e21a584fcb9ae9d96629653863.png
然后是依赖：
<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>hmall</artifactId>
<groupId>com.heima</groupId>
<version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>cart-service</artifactId>
<properties>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
</properties>
<dependencies>
<!--common-->
<dependency>
<groupId>com.heima</groupId>
<artifactId>hm-common</artifactId>
<version>1.0.0</version>
</dependency>
<!--web-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!--数据库-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!--mybatis-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
</dependency>
<!--单元测试-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
</dependencies>
<build>
<finalName>${project.artifactId}</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
然后是启动类：
package com.hmall.cart;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@MapperScan("com.hmall.cart.mapper")
@SpringBootApplication
public class CartApplication {
public static void main(String[] args) {
SpringApplication.run(CartApplication.class, args);
}
}
然后是设置文件，同样可以拷贝自item-service，不过此中的application.yaml需要修改：
server:
port: 8082
spring:
application:
name: cart-service
profiles:
active: dev
datasource:
url: jdbc:mysql://${hm.db.host}:3306/hm-cart?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&serverTimezone=Asia/Shanghai
driver-class-name: com.mysql.cj.jdbc.Driver
username: root
password: ${hm.db.pw}
mybatis-plus:
configuration:
default-enum-type-handler: com.baomidou.mybatisplus.core.handlers.MybatisEnumTypeHandler
global-config:
db-config:
update-strategy: not_null
id-type: auto
logging:
level:
com.hmall: debug
pattern:
dateformat: HH:mm:ss:SSS
file:
path: "logs/${spring.application.name}"
knife4j:
enable: true
openapi:
title: 购物车服务接口
description: "信息"
email: zs0536@stu.edu.cn
concat: Charlie
url: https://www.itcast.cn
version: v1.0.0
group:
default:
group-name: default
api-rule: package
api-rule-resources:
- com.hmall.cart.controller
最后，把hm-service中的与购物车有关功能拷贝过来，终极的项目布局如下：
https://i-blog.csdnimg.cn/direct/a429d343cfdd4169809280ffd5702ac8.png
特殊注意的是com.hmall.cart.service.impl.CartServiceImpl，此中有两个地方需要处理：
[*]需要获取登录用户信息，但登录校验功能如今没有复制过来，先写死固定用户id
[*]查询购物车时需要查询商品信息，而商品信息不在当前服务，需要先将这部分代码解释
https://i-blog.csdnimg.cn/direct/8a0590ba9b794104bface991875e2038.png
我们对这部分代码做如下修改：
package com.hmall.cart.service.impl;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hmall.cart.domain.dto.CartFormDTO;
import com.hmall.cart.domain.po.Cart;
import com.hmall.cart.domain.vo.CartVO;
import com.hmall.cart.mapper.CartMapper;
import com.hmall.cart.service.ICartService;
import com.hmall.common.exception.BizIllegalException;
import com.hmall.common.utils.BeanUtils;
import com.hmall.common.utils.CollUtils;
import com.hmall.common.utils.UserContext;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import java.util.Collection;
import java.util.List;
/**
* <p>
* 订单详情表 服务实现类
* </p>
*
* @author 虎哥
* @since 2023-05-05
*/
@Service
@RequiredArgsConstructor
public class CartServiceImpl extends ServiceImpl<CartMapper, Cart> implements ICartService {
// private final IItemService itemService;
@Override
public void addItem2Cart(CartFormDTO cartFormDTO) {
// 1.获取登录用户
Long userId = UserContext.getUser();
// 2.判断是否已经存在
if (checkItemExists(cartFormDTO.getItemId(), userId)) {
// 2.1.存在，则更新数量
baseMapper.updateNum(cartFormDTO.getItemId(), userId);
return;
}
// 2.2.不存在，判断是否超过购物车数量
checkCartsFull(userId);
// 3.新增购物车条目
// 3.1.转换PO
Cart cart = BeanUtils.copyBean(cartFormDTO, Cart.class);
// 3.2.保存当前用户
cart.setUserId(userId);
// 3.3.保存到数据库
save(cart);
}
@Override
public List<CartVO> queryMyCarts() {
// 1.查询我的购物车列表
List<Cart> carts = lambdaQuery().eq(Cart::getUserId, 1L /*TODO UserContext.getUser()*/).list();
if (CollUtils.isEmpty(carts)) {
return CollUtils.emptyList();
}
// 2.转换VO
List<CartVO> vos = BeanUtils.copyList(carts, CartVO.class);
// 3.处理VO中的商品信息
handleCartItems(vos);
// 4.返回
return vos;
}
private void handleCartItems(List<CartVO> vos) {
// 1.获取商品id TODO 处理商品信息
/*Set<Long> itemIds = vos.stream().map(CartVO::getItemId).collect(Collectors.toSet());
// 2.查询商品
List<ItemDTO> items = itemService.queryItemByIds(itemIds);
if (CollUtils.isEmpty(items)) {
throw new BadRequestException("购物车中商品不存在！");
}
// 3.转为 id 到 item的map
Map<Long, ItemDTO> itemMap = items.stream().collect(Collectors.toMap(ItemDTO::getId, Function.identity()));
// 4.写入vo
for (CartVO v : vos) {
ItemDTO item = itemMap.get(v.getItemId());
if (item == null) {
continue;
}
v.setNewPrice(item.getPrice());
v.setStatus(item.getStatus());
v.setStock(item.getStock());
}*/
}
@Override
public void removeByItemIds(Collection<Long> itemIds) {
// 1.构建删除条件，userId和itemId
QueryWrapper<Cart> queryWrapper = new QueryWrapper<Cart>();
queryWrapper.lambda()
.eq(Cart::getUserId, UserContext.getUser())
.in(Cart::getItemId, itemIds);
// 2.删除
remove(queryWrapper);
}
private void checkCartsFull(Long userId) {
int count = lambdaQuery().eq(Cart::getUserId, userId).count();
if (count >= 10) {
throw new BizIllegalException(StrUtil.format("用户购物车课程不能超过{}", 10));
}
}
private boolean checkItemExists(Long itemId, Long userId) {
int count = lambdaQuery()
.eq(Cart::getUserId, userId)
.eq(Cart::getItemId, itemId)
.count();
return count > 0;
}
}
最后，还是要导入数据库表，在资料对应的SQL文件：
https://i-blog.csdnimg.cn/direct/1b37b64e4c9f40edb8e78c652e789784.png
在数据库中会出现名为hm-cart的database，以及此中的cart表，代表购物车：
https://i-blog.csdnimg.cn/direct/e971ef9e9b4849119fe39ae4b7c1a772.png
接下来，就可以测试了。不过在启动前，同样要设置启动项的active profile为local：
https://i-blog.csdnimg.cn/direct/55d4a600301142d78b4cc05a8506ed80.png
然后启动CartApplication，访问swagger文档页面：http://localhost:8082/doc.html
我们测试此中的查询我的购物车列表接口，无需填写参数，直接访问：
https://i-blog.csdnimg.cn/direct/62a03b4308e6430b9b7c0ed47fdd393a.png
我们注意到，此中与商品有关的几个字段值都为空！这就是因为刚才我们解释掉了查询购物车时，查询商品信息的干系代码。
那么，我们该如何在cart-service服务中实现对item-service服务的查询呢？
服务调用
在拆分的时间，我们发现一个问题：就是购物车业务中需要查询商品信息，但商品信息查询的逻辑全部迁移到了item-service服务，导致我们无法查询。
终极结果就是查询到的购物车数据不完整，因此要想解决这个问题，我们就必须改造此中的代码，把原来本地方法调用，改造成跨微服务的远程调用（RPC，即Remote Produce Call）。
因此，如今查询购物车列表的流程变成了如许：
https://i-blog.csdnimg.cn/direct/769e6634cd494a0390dc45135aaeeeb9.png
代码中需要变化的就是这一步：
https://i-blog.csdnimg.cn/direct/6cf36cee1b2f43bdaa4165a74e9f2114.png
那么问题来了：我们该如何跨服务调用，准确的说，如何在cart-service中获取item-service服务中的提供的商品数据呢？
大家思索一下，我们以前有没有实现过类似的远程查询的功能呢？
答案是肯定的，我们前端向服务端查询数据，实在就是从浏览器远程查询服务端数据。比如我们刚才通过Swagger测试商品查询接口，就是向http://localhost:8081/items这个接口发起的哀求：
https://i-blog.csdnimg.cn/direct/00561b25594a4e418cc97b04058a0f2d.png
而这种查询就是通过http哀求的方式来完成的，不仅仅可以实现远程查询，还可以实现新增、删除等各种远程哀求。
如果我们在cart-service中能模拟浏览器，发送http哀求到item-service，是不是就实现了跨微服务的远程调用了呢？
那么：我们该如何用Java代码发送Http的哀求呢？
RestTemplate
Spring给我们提供了一个RestTemplate的API，可以方便的实现Http哀求的发送。
org.springframework.web.client public class RestTemplate
extends InterceptingHttpAccessor
implements RestOperations
----------------------------------------------------------------------------------------------------------------
同步客户端执行HTTP哀求，在底层HTTP客户端库(如JDK HttpURLConnection、Apache HttpComponents等)上公开一个简单的模板方法API。RestTemplate通过HTTP方法为常见场景提供了模板，此外还提供了支持不太常见情况的通用互换和执行方法。 RestTemplate通常用作共享组件。然而，它的设置不支持并发修改，因此它的设置通常是在启动时准备的。如果需要，您可以在启动时创建多个差别设置的RestTemplate实例。如果这些实例需要共享HTTP客户端资源，它们可以使用相同的底层ClientHttpRequestFactory。 注意:从5.0开始，这个类处于维护模式，只有对更改和错误的小哀求才会被继承。请考虑使用org.springframework.web.react .client. webclient，它有更当代的API，支持同步、异步和流场景。
----------------------------------------------------------------------------------------------------------------
自: 3.0 拜见: HttpMessageConverter, RequestCallback, ResponseExtractor, ResponseErrorHandler
此中提供了大量的方法，方便我们发送Http哀求，比方：
https://i-blog.csdnimg.cn/direct/2d17d8c0905f4c3d9614eea2f2c8a643.png
可以看到常见的Get、Post、Put、Delete哀求都支持，如果哀求参数比力复杂，还可以使用exchange方法来构造哀求。
我们在cart-service服务中界说一个设置类：
https://i-blog.csdnimg.cn/direct/8e8bf9c338c146758dd368d3c8b7e7cd.png
先将RestTemplate注册为一个Bean：
package com.hmall.cart.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
@Configuration
public class RemoteCallConfig {
@Bean
public RestTemplate restTemplate() {
return new RestTemplate();
}
}
远程调用
接下来，我们修改cart-service中的com.hmall.cart.service.impl.CartServiceImpl的handleCartItems方法，发送http哀求到item-service：
https://i-blog.csdnimg.cn/direct/726d787f7fee4c83898e935186171de2.png
可以看到，使用RestTemplate发送http哀求与前端ajax发送哀求非常相似，都包含四部分信息：
[*]① 哀求方式
[*]② 哀求路径
[*]③ 哀求参数
[*]④ 返回值类型
handleCartItems方法的完整代码如下：
private void handleCartItems(List<CartVO> vos) {
// TODO 1.获取商品id
Set<Long> itemIds = vos.stream().map(CartVO::getItemId).collect(Collectors.toSet());
// 2.查询商品
// List<ItemDTO> items = itemService.queryItemByIds(itemIds);
// 2.1.利用RestTemplate发起http请求，得到http的响应
ResponseEntity<List<ItemDTO>> response = restTemplate.exchange(
"http://localhost:8081/items?ids={ids}",
HttpMethod.GET,
null,
new ParameterizedTypeReference<List<ItemDTO>>() {
},
Map.of("ids", CollUtil.join(itemIds, ","))
);
// 2.2.解析响应，检查HTTP响应的状态码是否在200-299范围内，表示请求成功。
if(!response.getStatusCode().is2xxSuccessful()){
// 查询失败，直接结束
return;
}
// 获取响应体中的商品信息
List<ItemDTO> items = response.getBody();
if (CollUtils.isEmpty(items)) {
return;
}
// 3.转为 id 到 item的map
Map<Long, ItemDTO> itemMap = items.stream().collect(Collectors.toMap(ItemDTO::getId, Function.identity()));
// 4.写入vo
for (CartVO v : vos) {
ItemDTO item = itemMap.get(v.getItemId());
if (item == null) {
continue;
}
v.setNewPrice(item.getPrice());
v.setStatus(item.getStatus());
v.setStock(item.getStock());
}
}
好了，如今重启cart-service，再次测试查询我的购物车列表接口：
https://i-blog.csdnimg.cn/direct/e41547f9c3ba48ed9bd3e33c549e16ab.png
可以发现，全部商品干系数据都已经查询到了。
在这个过程中，item-service提供了查询接口，cart-service使用Http哀求调用该接口。因此item-service可以称为服务的提供者，而cart-service则称为服务的斲丧者或服务调用者。
总结
什么时间需要拆分微服务？
[*]如果是创业型公司，最好先用单体架构快速迭代开辟，验证市场运作模子，快速试错。当业务跑通以后，随着业务规模扩大、人员规模增加，再考虑拆分微服务。
[*]如果是大型企业，有充足的资源，可以在项目开始之初就搭建微服务架构。
如何拆分？
[*]首先要做到高内聚、低耦合
[*]从拆分方式来说，有横向拆分和纵向拆分两种。纵向就是按照业务功能模块，横向则是拆分通用性业务，提高复用性
服务拆分之后，不可避免的会出现跨微服务的业务，此时微服务之间就需要举行远程调用。微服务之间的远程调用被称为RPC，即远程过程调用。RPC的实现方式有许多，比如：
[*]基于Http协议
[*]基于Dubbo协议
我们讲堂中使用的是Http方式，这种方式不关心服务提供者的具体技术实现，只要对外暴露Http接口即可，更符合微服务的需要。
Java发送http哀求可以使用Spring提供的RestTemplate，使用的基本步骤如下：
[*]注册RestTemplate到Spring容器
[*]调用RestTemplate的API发送哀求，常见方法有：
[*]getForObject：发送Get哀求并返回指定类型对象
[*]PostForObject：发送Post哀求并返回指定类型对象
[*]put：发送PUT哀求
[*]delete：发送Delete哀求
[*]exchange：发送任意类型哀求，返回ResponseEntity
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]