总概
A、技术栈
- 开发语言：Java 1.8
- 数据库：MySQL、Redis、MongoDB、Elasticsearch
- 微服务框架：Spring Cloud Alibaba
- 微服务网关：Spring Cloud Gateway
- 服务注册和配置中心：Nacos
- 分布式事务：Seata
- 链路追踪框架：Sleuth
- 服务降级与熔断：Sentinel
- ORM框架：MyBatis-Plus
- 分布式任务调度平台：XXL-JOB
- 消息中间件：RocketMQ
- 分布式锁：Redisson
- 权限：OAuth2
- DevOps：Jenkins、Docker、K8S
B、本节实现目标
- 新建mall-feign服务。
- 新建mall-order服务。
- 实现下单接口
一、Spring Cloud OpenFeign简介
Spring Cloud OpenFeign是一种声明式、模板化的HTTP客户端。在Spring Cloud中使用OpenFeign，可以做到使用HTTP请求访问远程服务，就像调用本地方法一样的，开发者完全感知不到这是在调用远程方法，更感知不到在访问HTTP请求。
二、新建mall-feign服务
2.1 新建module
新建module
新建mall-feign
2.2 新建.gitignore
.idea
.mvn
target
mvnw
*.iml
2.3 配置pom.xml
参考mall-member服务配置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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<artifactId>mall-pom</artifactId>
<groupId>com.ac</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<groupId>com.ac</groupId>
<artifactId>mall-feign</artifactId>
<version>${mall.version}</version>
<name>mall-feign</name>
<description>OpenFeign服务</description>
<dependencies>
<dependency>
<groupId>com.ac</groupId>
<artifactId>mall-common</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>8</source>
<target>8</target>
</configuration>
</plugin>
</plugins>
</build>
</project>
2.4 加OpenFeign依赖
在mall-pom的pom.xml里加入mavn依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
<version>${alibaba.cloud.version}</version>
</dependency>
2.5 提供用户查询的Feign接口
package com.ac.feign.member.api;
import com.ac.feign.member.dto.MemberDTO;
import io.swagger.annotations.ApiOperation;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
@FeignClient("mall-member")
public interface MemberFeignApi {
@ApiOperation(value = "获取用户")
@GetMapping("member/{id}")
MemberDTO findMember(@PathVariable("id") Long id);
}
2.5.1 说明NO.1
@FeignClient("mall-member")中的"mall-member"是member服务注册在Nacos上的服务名称，
mall-member
2.5.2 说明NO.2
@PathVariable("id") Long id ，@PathVariable括号里的“id”不能少，否则其他依赖mall-feign服务的代码启动会报错，MemberFeignApi注入失败。
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'com.ac.feign.member.api.MemberFeignApi': FactoryBean threw exception on object creation; nested exception is java.lang.IllegalStateException: PathVariable annotation was empty on param 0.
2.6 mall-feign项目结构截图
mall-feign项目结构截图
2.7 关于OpenFeign位置说明
OpenFeign位置一般有两种，
- 第一种：在各个服务中写需要用的OpenFeign接口。
- 第二种：将项目中所有的OpenFeign接口抽取出来，放到一个公共的feign服务中，如上面创建的mall-feign服务，然后其他各个服务都依赖这个mall-feign。
很明显，我采用的是第二种，理由是，一个OpenFeign接口可能很多服务都需要用，比如，大部分服务都会通过OpenFeign来取用户数据，如果采用方案一，各个服务都要写一遍MemberFeignApi，如果采用第二种方案，则mall-feign里的MemberFeignApi能被各服务共用。
三、新建mall-order服务
参考mall-feign新建mall-order服务，具体操作步骤省略。
3.1 依赖mall-feign服务
mall-order需要依赖mall-feign服务，因此在pom.xml里配置依赖项
<dependency>
<groupId>com.ac</groupId>
<artifactId>mall-feign</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
pom.xml依赖项
3.2 @EnableFeignClients注解
在mall-order的Application类上，加上注解@EnableFeignClients注解，@EnableFeignClients申明该项目是Feign客户端，扫描对应的feign client。
@MapperScan("com.ac.order.mapper")
@ComponentScan("com.ac.*")
@EnableFeignClients(basePackages = {"com.ac.feign.*"})
@SpringBootApplication
public class OrderApplication {
public static void main(String[] args) {
SpringApplication.run(OrderApplication.class, args);
}
}
3.2.1 说明NO.1
@EnableFeignClients(basePackages = {"com.ac.feign.*"}) ，中配置了basePackages，让IOC容器去扫描mall-feign服务里的接口。
如果不配置，mall-order服务启动时会报错
A component required a bean of type 'com.ac.feign.member.api.MemberFeignApi' that could not be found.
3.3 调用MemberFeignApi测试
@Api(tags = "订单")
@RestController
@RequestMapping("order")
public class OrderController {
@Resource
private MemberFeignApi memberFeignApi;
@ApiOperation(value = "通过OpenFeign取用户数据")
@GetMapping("feign/member/{id}")
public MemberDTO test(@PathVariable Long id) {
return memberFeignApi.findMember(id);
}
}
测试结果
项目结构截图
四、下单接口
下单接口需要通过memberId调用mall-member服务的用户信息，通过productId调用mall-product服务的产品信息，代码如下：
@Slf4j
@Service
public class OrderServiceImpl implements OrderService {
@Resource
private OrderDao orderDaoImpl;
@Resource
private MemberFeignApi memberFeignApi;
@Resource
private OrderItemService orderItemServiceImpl;
@Transactional(rollbackFor = Exception.class)
@Override
public Long createOrder(OrderAddVO addVO) {
Order order = new Order();
order.setOrderNo(RandomUtil.randomNumbers(8));
order.setOrderState(OrderStateEnum.UN_PAY);
order.setOrderTime(LocalDateTime.now());
//通过feign取用户信息
MemberDTO member = memberFeignApi.findMember(addVO.getMemberId());
order.setMemberId(addVO.getMemberId());
order.setMemberName(member.getMemberName());
order.setMobile(member.getMobile());
orderDaoImpl.save(order);
BigDecimal discountAmount = new BigDecimal(0.00);
BigDecimal productAmount = new BigDecimal(0.00);
//存订单项信息
for (OrderItemAddVO orderItemAdd : addVO.getOrderItemList()) {
OrderItem orderItem = orderItemServiceImpl.addOrderItem(order.getId(), orderItemAdd);
productAmount = productAmount.add(orderItem.getBuyPrice().multiply(new BigDecimal(orderItem.getBuyNum())));
}
//更新订单金额信息
order.setDiscountAmount(discountAmount);
order.setProductAmount(productAmount);
BigDecimal payAmount = productAmount.subtract(discountAmount);
order.setPayAmount(payAmount);
orderDaoImpl.updateById(order);
return order.getId();
}
}
@Slf4j
@Service
public class OrderItemServiceImpl implements OrderItemService {
@Resource
private OrderItemDao orderItemDaoImpl;
@Resource
private ProductFeignApi productFeignApi;
@Override
public OrderItem addOrderItem(Long orderId, OrderItemAddVO orderItemAdd) {
//通过feign取产品信息
ProductDTO product = productFeignApi.findProduct(orderItemAdd.getProductId());
OrderItem entity = new OrderItem();
entity.setOrderId(orderId);
entity.setProductId(product.getId());
entity.setProductName(product.getProductName());
entity.setImageUrl(product.getImageUrl());
entity.setBuyNum(orderItemAdd.getBuyNum());
if (product.getDiscountPrice() != null && product.getDiscountPrice().doubleValue() > 0) {
entity.setBuyPrice(product.getDiscountPrice());
} else {
entity.setBuyPrice(product.getSellPrice());
}
orderItemDaoImpl.save(entity);
return entity;
}
}
