在微服务构架中,不可避免的要遇到服务间的调用,目前的方式是通过RPC或者是rest的http接口调用; spring-cloud中很多都使用的feign来做服务调用,
在spring-cloud-alibaba的套装中我们使用dubbo来替换掉feign这个组件(使用feign也可以)。下面是集成步骤:
引入maven相关依赖:
<properties>
<java.version>1.8</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<spring-boot.version>2.3.7.RELEASE</spring-boot.version>
<spring-cloud-alibaba.version>2.2.2.RELEASE</spring-cloud-alibaba.version>
<spring-cloud.version>Hoxton.SR9</spring-cloud.version>
</properties>
<!--引入依赖管理-->
<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>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>${spring-boot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
<version>${spring-cloud-alibaba.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
引入dubbo的依赖
<!-- dubbo依赖 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-dubbo</artifactId>
</dependency>
<!-- nacos 服务注册客户端依赖 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
由于我们的其他服务是直接通过接口进行调用的,因此需要将接口提取到单独的jar包中,因此项目基本组成如下:
公共接口包:api-model
服务消费者:customer-service
服务提供者:provider-service
修改配置文件(服务消费者和服务提供者配置都一样)
dubbo:
protocol:
name: dubbo
# 这个dubbo的协议端口在一台服务器上的时候,每个项目的必须配置成不一样的(否则将启动失败),或者配置为-1,使用随机端口
port: 20880
registry:
# 由于使用的是spring-cloud,因此这里使用spring-cloud的
address: spring-cloud://192.168.56.1.102
scan:
# 配置需要扫描的注解包
base-packages: top.vchar
使用方式
我们无需像feign那样再去编写一个类,对应需要提供对外服务的接口直接在接口的实现上将@Service
注解改为org.apache.dubbo.config.annotation.DubboService
注解即可。
服务调用方直接在要使用的服务接口上加上 @DubboReference
注解即可。
接口(因为服务调用方也需要使用,因此我们需要将接口单独提取到一个jar包,然后消费者和提供者引入即可)
public interface GoodsService {
/**
* 通过ID查询商品详情
* @param id 商品ID
* @return 返回结果
*/
GoodsDetailDTO findGoodsById(Long id);
}
服务提供者(就是普通的接口方法实现)
@DubboService
public class GoodsServiceImpl implements GoodsService {
@Override
public GoodsDetailDTO findGoodsById(Long id) {
System.out.println("查询数据");
GoodsDetailDTO goods = new GoodsDetailDTO();
goods.setGoodsNo(String.valueOf(id));
goods.setGoodsName("手机");
goods.setInventory(2);
goods.setPrice(new BigDecimal("3000"));
return goods;
}
}
服务调用
// 要调用的远程服务
@DubboReference
private GoodsService goodsService;
@Override
public String booking(Long id, int num) {
GoodsDetailDTO goods = this.goodsService.findGoodsById(id);
System.out.println(JSONObject.toJSONString(goods));
return goods.getGoodsName();
}
当然你也可以使用之前的xml配置文件来实现,使用单独的配置文件来实现的话能够更好的和代码解耦,比如以后想切换为HSF做为RPC服务调用的话直接修改配置文件即可,代码无需改动。