Spring Cloud微服务架构从入门到会用(三)—服务间调用Feign

Stella981
• 阅读 484

微服务最重要的一个功能是服务间调用,各个服务互相依赖。比如电商系统有订单服务,有库存服务。在我们购买一件商品的时候,需要生成订单和减库存。这里我们就要用到服务间调用Feign。

Feign是一个http请求调用的轻量级框架,可以以Java接口注解的方式调用Http请求,而不用像Java中通过封装HTTP请求报文的方式直接调用。

接下来我们新建两个module,一个app-order,一个app-storage;app-order作为调用方,app-storage作为被调用方。使用mybatis-plus作为数据处理框架。使用lombok简化代码(idea需要按照lombok插件,否则会报错)

1. 创建app-storage

1.1 修改app-storage下的pom.xml文件
<properties>   <java.version>1.8</java.version>   <spring-cloud.version>Hoxton.SR1</spring-cloud.version></properties><dependencies>   <dependency>       <groupId>org.springframework.boot</groupId>       <artifactId>spring-boot-starter-web</artifactId>   </dependency>    <!-- eureka-client -->   <dependency>       <groupId>org.springframework.cloud</groupId>       <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>   </dependency>   <!-- feign -->   <dependency>       <groupId>org.springframework.cloud</groupId>       <artifactId>spring-cloud-starter-openfeign</artifactId>   </dependency>   <!--    mybatis-plus    -->   <dependency>       <groupId>com.baomidou</groupId>       <artifactId>mybatis-plus-boot-starter</artifactId>       <version>3.3.1.tmp</version>   </dependency>   <dependency>       <groupId>mysql</groupId>       <artifactId>mysql-connector-java</artifactId>       <scope>runtime</scope>   </dependency>   <dependency>       <groupId>org.projectlombok</groupId>       <artifactId>lombok</artifactId>       <optional>true</optional>   </dependency>   <dependency>       <groupId>org.springframework.boot</groupId>       <artifactId>spring-boot-starter-test</artifactId>       <scope>test</scope>       <exclusions>           <exclusion>               <groupId>org.junit.vintage</groupId>               <artifactId>junit-vintage-engine</artifactId>           </exclusion>       </exclusions>   </dependency></dependencies><dependencyManagement>   <dependencies>       <dependency>           <groupId>org.springframework.cloud</groupId>           <artifactId>spring-cloud-dependencies</artifactId>           <version>${spring-cloud.version}</version>           <type>pom</type>           <scope>import</scope>       </dependency>   </dependencies></dependencyManagement>
1.2 修改配置
# 设置端口号server.port=9920# 设置服务名称spring.application.name=app-storage# 设置eurekaeureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/eureka.instance.instance-id=${spring.application.name}:${server.port}# 数据源配置spring.datasource.url=jdbc:mysql://localhost:3306/storage?allowMultiQueries=true&serverTimezone=GMT%2B8&useSSL=false&allowPublicKeyRetrieval=truespring.datasource.driver-class-name=com.mysql.cj.jdbc.Driverspring.datasource.username=rootspring.datasource.password=root
1.3 创建表,预制数据
CREATE TABLE `tb_storage` (  `id` int(11) NOT NULL AUTO_INCREMENT,  `commodity_code` varchar(255) DEFAULT NULL,  `count` int(11) DEFAULT 0,  PRIMARY KEY (`id`),  UNIQUE KEY (`commodity_code`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;

预制数据

INSERT INTO `storage`(`id`, `commodity_code`, `count`) VALUES (1, 'product-1', 9999999);
1.4 修改启动类
@SpringBootApplication@EnableEurekaClient  // 开启eureka客户端模式@MapperScan("com.ipp.springcloud.appstorage.mapper") // mybatis扫描public class AppOrderApplication {    public static void main(String[] args) {        SpringApplication.run(AppOrderApplication.class, args);    }}
1.5 创建storage表对应的entity,mapper,service,controller

可以用mybatis-plus代码生成插件去生成以上代码,篇幅问题不在此处做详细展示,详细内容请查看git仓库。

1.6 创建一个供app-order调用的减库存接口

controller

/**     * 减库存     * @param commodityCode 商品代码     * @param count 数量     * @return     */    @RequestMapping(path = "/deduct")    public Boolean deduct(String commodityCode, Integer count) {        storageService.deduct(commodityCode, count);        return true;    }

service

@Override    public void deduct(String commodityCode, int count) {        QueryWrapper<Storage> wrapper = new QueryWrapper<>();        wrapper.setEntity(new Storage().setCommodityCode(commodityCode));        Storage storage = baseMapper.selectOne(wrapper);        storage.setCount(storage.getCount() - count);        baseMapper.updateById(storage);    }

2. 创建app-order

2.1 修改app-order下的pom.xml文件

内容与app-storage一致

2.2 修改配置
# 设置端口号server.port=9910# 设置服务名称spring.application.name=app-order# 设置eurekaeureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/eureka.instance.instance-id=${spring.application.name}:${server.port}# 数据源配置spring.datasource.url=jdbc:mysql://localhost:3306/order?allowMultiQueries=true&serverTimezone=GMT%2B8&useSSL=false&allowPublicKeyRetrieval=truespring.datasource.driver-class-name=com.mysql.cj.jdbc.Driverspring.datasource.username=rootspring.datasource.password=root
2.3 创建表
CREATE TABLE `tb_order` (  `id` int(11) NOT NULL AUTO_INCREMENT,  `user_id` varchar(255) DEFAULT NULL,  `commodity_code` varchar(255) DEFAULT NULL,  `count` int(11) DEFAULT 0,  `money` int(11) DEFAULT 0,  PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;
2.4 修改启动类
@SpringBootApplication@EnableEurekaClient  // 开启eureka客户端模式@EnableFeignClients //开启feign请求@MapperScan("com.ipp.springcloud.apporder.mapper") // mybatis扫描public class AppOrderApplication {    public static void main(String[] args) {        SpringApplication.run(AppOrderApplication.class, args);    }}
2.5 创建表order表对应的entity,mapper,service,controller

可以用mybatis-plus代码生成插件去生成以上代码,篇幅问题不在此处做详细展示,详细内容请查看git仓库。

2.6 创建feign调用接口
@FeignClient(name = "APP-STORAGE")public interface StorageFeignService {    /**     * 减库存     * @param commodityCode     * @param count     * @return     */    @GetMapping("storage/deduct")    Boolean deduct(@RequestParam("commodityCode") String commodityCode, @RequestParam("count") Integer count);}

这里的@FeignClient 中的name写的是app-storage服务的服务名称(也就是注册到eureka中的服务名称)

下面声明的deduct方法对应app-storage服务中的deduct接口

2.7 创建下订单的接口

controller

 @RequestMapping("/placeOrder/commit")    public Boolean placeOrderCommit() {        orderServiceImpl.placeOrder("1", "product-1", 1);        return true;    }

service

@Autowiredprivate StorageFeignService storageFeignService;@Overridepublic void placeOrder(String userId, String commodityCode, Integer count) {     BigDecimal orderMoney = new BigDecimal(count).multiply(new BigDecimal(5));     Order order = new Order()             .setUserId(userId)             .setCommodityCode(commodityCode)             .setCount(count)             .setMoney(orderMoney);     baseMapper.insert(order);     storageFeignService.deduct(commodityCode, count);}

3. 启动服务验证

依次启动server-eureka,app-storage,app-order

4. 验证接口

在浏览器中访问 http://127.0.0.1:9910/order/placeOrder/commit , 分别查看order表和storage表。是否生成了订单和减了库存

本文分享自微信公众号 - 自增程序员(javaipp)。
如有侵权,请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”,欢迎正在阅读的你也加入,一起分享。

点赞
收藏
评论区
推荐文章
Wesley13 Wesley13
2年前
spring feign http客户端连接池配置以及spring zuul http客户端连接池配置解析
背景Feign和网关Zuul的RPC调用,实际上都是HTTP请求。HTTP请求,如果不配置好HTTP连接池参数的话,会影响性能,或者造成堆积阻塞,对于其中一个微服务的调用影响到其他微服务的调用。源代码类比解析本文基于SpringCloudDalston.SR4,但是基本思路上,这块比较稳定,不稳定的是Feign本身Htt
Wesley13 Wesley13
2年前
Java 调用RESTful接口的几种方式
前端一般通过Ajax来调用,后端调用的方式还是挺多的,比如HttpURLConnection,HttpClient,Spring的RestTemplate服务端代码如下:服务端接口请求的URL:http://localhost:8080/rest/user/getUser/xiaoming/18(https://www.oschina.net/a
Stella981 Stella981
2年前
Netty 实现简单的RPC远程调用
RPC又称远程过程调用,我们所知的远程调用分为两种,现在在服务间通信的方式也太多已这两种为主1.是基于HTTP的restful形式的广义远程调用,以springboot的feign和restTemplate为代表,由于采用的协议是HTTP的7层调用协议,并且协议的参数和响应序列化基本以JSON格式和XML格式为主。2.是基于TCP的狭义的RPC远程调
Stella981 Stella981
2年前
Linkis架构解析系列(一)——Linkis RPC架构解析
“为了提升Linkis的高并发能力,Linkis基于微服务架构,在Feign的基础之上,实现了一套自己的底层RPC通信方案,用以提升微服务间的通信性能和并发能力。”基于Feign的微服务之间HTTP接口调用,只能满足简单的A微服务实例根据简单的规则随机访问B微服务之中的某个服务实例,而这个B微服务实例如果想异步回传信
Easter79 Easter79
2年前
SpringCloud的限流、降级和熔断——Hystrix
!(https://oscimg.oschina.net/oscnet/updb144b1538f24c2488b01c4e66a45d48038.JPEG)一、前言分布式系统环境中,服务间类似依赖非常常见,一个业余调用通常依赖多个基础服务。如下图,对于同步调用,当库存服务不可用时,商品服务请求线程被阻塞,当有大批量请求调用库存服务时,
Stella981 Stella981
2年前
Spring Cloud Sleuth 分布式服务追踪
随着业务的发展,系统规模也会变得越来越大,各微服务间的调用关系也变得越来越错综复杂。通常一个由客户端发起的请求在后端系统中会经过多个不同的微服务调用来协同产生最后的请求结果,在复杂的微服务架构系统中,几乎每一个前端请求都会形成一条复杂的分布式服务调用链路,在每条链路中任何一个依赖服务出现延迟过高或错误的时候都有可能引起请求最后的失败。这时
Stella981 Stella981
2年前
Spring Cloud构建微服务架构
在微服务架构中,我们将系统拆分成了一个个的服务单元,各单元应用间通过服务注册与订阅的方式互相依赖。由于每个单元都在不同的进程中运行,依赖通过远程调用的方式执行,这样就有可能因为网络原因或是依赖服务自身问题出现调用故障或延迟,而这些问题会直接导致调用方的对外服务也出现延迟,若此时调用方的请求不断增加,最后就会出现因等待出现故障的依赖方响应而形成任务积压,线程资
Stella981 Stella981
2年前
Spring Boot + Spring Cloud 构建微服务系统(七):API服务网关(Zuul)
技术背景前面我们通过Ribbon或Feign实现了微服务之间的调用和负载均衡,那我们的各种微服务又要如何提供给外部应用调用呢。当然,因为是RESTAPI接口,外部客户端直接调用各个微服务是没有问题的,但出于种种原因,这并不是一个好的选择。让客户端直接与各个微服务通讯,会有以下几个问题:客户端会多次请求不同的微服务,增加了客
Stella981 Stella981
2年前
Hystrix原理与实战(文章略长)
背景分布式系统环境下,服务间类似依赖非常常见,一个业务调用通常依赖多个基础服务。如下图,对于同步调用,当库存服务不可用时,商品服务请求线程被阻塞,当有大批量请求调用库存服务时,最终可能导致整个商品服务资源耗尽,无法继续对外提供服务。并且这种不可用可能沿请求调用链向上传递,这种现象被称为雪崩效应。!(https://stati
分布式系统中的分布式链路追踪与分布式调用链路
在分布式系统中,由于服务间的调用关系复杂,需要实现分布式链路追踪来跟踪请求在各个服务中的调用路径和时间消耗。这对问题排查和性能监控都很重要。常用的分布式链路追踪实现有基于日志的和基于分布式追踪系统的两种方式: