spring-cloud-alibaba之dubbo

Java

发布日期: 2021-03-05

在微服务构架中，不可避免的要遇到服务间的调用，目前的方式是通过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服务调用的话直接修改配置文件即可，代码无需改动。

一些奇奇怪怪的问题

在Windows上项目是正常，但是到Mac上报 Connection refused 错误

具体错误详情如下：

2022-04-25 19:50:40.083  INFO 5504 --- [           main] org.apache.dubbo.config.ServiceConfig    :  [DUBBO] No valid ip found from environment, try to find valid host from DNS., dubbo version: 2.7.8, current host: 192.168.0.22
2022-04-25 19:50:40.089  WARN 5504 --- [           main] org.apache.dubbo.config.ServiceConfig    :  [DUBBO] Connection refused (Connection refused), dubbo version: 2.7.8, current host: 192.168.0.22

java.net.ConnectException: Connection refused (Connection refused)
	at java.base/java.net.PlainSocketImpl.socketConnect(Native Method) ~[na:na]
	at java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412) ~[na:na]
	at java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255) ~[na:na]
	at java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237) ~[na:na]
	at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[na:na]
	at java.base/java.net.Socket.connect(Socket.java:609) ~[na:na]
	at org.apache.dubbo.config.ServiceConfig.findConfigedHosts(ServiceConfig.java:588) ~[dubbo-2.7.8.jar:2.7.8]
	at org.apache.dubbo.config.ServiceConfig.doExportUrlsFor1Protocol(ServiceConfig.java:443) ~[dubbo-2.7.8.jar:2.7.8]
	......

这个由于Mac多网卡导致的，我们需要手动指定具体的IP；有如下2种方式（这里的IP可以直接用上面控制台打印的IP）：