SpringBoot整合Dubbo的第一种方式——application.properties + @DubboService + @DubboReference

Posted 张起灵-小哥

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了SpringBoot整合Dubbo的第一种方式——application.properties + @DubboService + @DubboReference相关的知识,希望对你有一定的参考价值。

1.文档参照

dubbo配置官方文档


2.三个工程

2.1 公共接口工程

这个工程中存放的是一些公共的Java Bean、相关接口信息。

其中UserService接口是针对服务提供者的,OrderService接口是针对服务消费者的。

<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <version>1.18.10</version>
</dependency>
package com.szh.gmall.bean;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;

import java.io.Serializable;

/**
 *
 */
@Data
@AllArgsConstructor
@NoArgsConstructor
public class UserAddress implements Serializable 
    private Integer id;
    private String userAddress; //用户地址
    private String userId;      //用户id
    private String consignee;   //收货人
    private String phoneNum;    //电话号码
    private String isDefault;   //是否为默认地址 Y-是 N-否

package com.szh.gmall.service;

import com.szh.gmall.bean.UserAddress;

import java.util.List;

/**
 *
 */
public interface UserService 

    /**
     * 根据用户id返回所有的收货地址
     */
    List<UserAddress> getUserAddressList(String userId);

package com.szh.gmall.service;

import com.szh.gmall.bean.UserAddress;

import java.util.List;

/**
 *
 */
public interface OrderService 

    /**
     * 初始化订单
     */
    void initOrder(String userId);

    List<UserAddress> initOrder2(String userId);

2.2 服务提供者工程

springboot这里我使用的是 2.3.12.RELEASE。dubbo是2.7.8

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>$dubbo.version</version>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>$dubbo.version</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.8.0</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.8.0</version>
        </dependency>

        <dependency>
            <groupId>com.szh</groupId>
            <artifactId>common-gmall-interface</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

那么在这个服务提供者中,我们肯定要对上面公共接口中的UserService进行具体的实现。  下面有两个实现类是为了后面测试Dubbo的多版本功能(也即version属性信息)。 @DubboService注解用来暴露服务。

package com.szh.service.impl;

import com.szh.gmall.bean.UserAddress;
import com.szh.gmall.service.UserService;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;

import java.util.Arrays;
import java.util.List;
import java.util.concurrent.TimeUnit;

/**
 * 1.将服务提供者注册到注册中心
 *      1) 引入dubbo依赖、zookeeper客户端依赖
 *      2) 配置服务提供者
 * 2.让服务消费者从注册中心订阅服务提供者的相关服务
 */
@Service
@DubboService(interfaceClass = UserService.class, version = "1.0.0")
public class UserServiceImpl implements UserService 

    //The default value of $dubbo.application.name is $spring.application.name
    @Value("$dubbo.application.name")
    private String applicationName;

    @Override
    public List<UserAddress> getUserAddressList(String userId) 
        UserAddress userAddress1 = new UserAddress(1, "浙江省杭州市", "1", "张三", "123456", "Y");
        UserAddress userAddress2 = new UserAddress(2, "湖北省武汉市", "1", "李四", "999999", "N");
        try 
            TimeUnit.MILLISECONDS.sleep(2000); //测试timeout
//            TimeUnit.MILLISECONDS.sleep(4000); //测试重试次数
         catch (InterruptedException e) 
            e.printStackTrace();
        
        System.out.println(applicationName + " old....");
        return Arrays.asList(userAddress1, userAddress2);
    

package com.szh.service.impl;

import com.szh.gmall.bean.UserAddress;
import com.szh.gmall.service.UserService;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.util.Arrays;
import java.util.List;
import java.util.concurrent.TimeUnit;

/**
 * 1.将服务提供者注册到注册中心
 *      1) 引入dubbo依赖、zookeeper客户端依赖
 *      2) 配置服务提供者
 * 2.让服务消费者从注册中心订阅服务提供者的相关服务
 */
@Service
@DubboService(interfaceClass = UserService.class, version = "2.0.0")
public class UserServiceImpl2 implements UserService 

    //The default value of $dubbo.application.name is $spring.application.name
    @Value("$dubbo.application.name")
    private String applicationName;

    @Override
    public List<UserAddress> getUserAddressList(String userId) 
        UserAddress userAddress1 = new UserAddress(1, "浙江省杭州市", "1", "张三", "123456", "Y");
        UserAddress userAddress2 = new UserAddress(2, "湖北省武汉市", "1", "李四", "999999", "N");
        try 
            TimeUnit.MILLISECONDS.sleep(2000); //测试timeout
//            TimeUnit.MILLISECONDS.sleep(4000); //测试重试次数
         catch (InterruptedException e) 
            e.printStackTrace();
        
        System.out.println(applicationName + " new....");
        return Arrays.asList(userAddress1, userAddress2);
    

properties配置文件如下,这种方式主要也就是 properties + 注解。 

spring.application.name=boot-user-service-provider
dubbo.application.name=boot-user-service-provider

dubbo.scan.base-packages=com.szh.service.impl

dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper

dubbo.protocol.name=dubbo
dubbo.protocol.port=20880

dubbo.monitor.protocol=registry

主启动类上添加 @EnableDubbo注解开启Dubbo的注解配置功能。  

package com.szh;

import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.apache.dubbo.config.spring.context.annotation.EnableDubboConfig;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo
public class BootUserServiceProviderApplication 

    public static void main(String[] args) 
        SpringApplication.run(BootUserServiceProviderApplication.class, args);
    


2.3 服务消费者工程

这里是一个springboot web工程,版本仍然和上面的服务提供者相同。dubbo是2.7.8

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>$dubbo.version</version>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
            <version>$dubbo.version</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>2.8.0</version>
        </dependency>

        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>2.8.0</version>
        </dependency>

        <dependency>
            <groupId>com.szh</groupId>
            <artifactId>common-gmall-interface</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

这里我们要通过浏览器访问具体的接口,所以需要一个controller。

package com.szh.controller;

import com.szh.gmall.bean.UserAddress;
import com.szh.gmall.service.OrderService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 *
 */
@RestController
public class OrderController 

    @Autowired
    private OrderService orderService;

    @GetMapping(value = "/initOrder/userId")
    public List<UserAddress> initOrder(@PathVariable("userId") String userId) 
        return orderService.initOrder2(userId);
    

然后需要对公共接口工程中的OrderService进行实现,因为这是服务消费者。(要表示如何消费,即实现接口就可以了)

@DubboReference注解用来引用服务。

package com.szh.service.impl;

import com.szh.gmall.bean.UserAddress;
import com.szh.gmall.service.OrderService;
import com.szh.gmall.service.UserService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.apache.dubbo.config.annotation.Method;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 *
 */
@Service
public class OrderServiceImpl implements OrderService 

    @DubboReference(interfaceClass = UserService.class, //服务接口名
                    version = "2.0.0", //服务版本,与服务提供者的版本一致
                    check = false,  //启动时检查提供者是否存在,true报错,false忽略
                    timeout = 3000, //服务方法调用超时时间(毫秒)
                    methods = @Method(name = "getUserAddressList"), //精确到服务接口的某个方法
                    retries = 3) //远程服务调用重试次数,不包括第一次调用,不需要重试请设为0
    private UserService userService;

    @Override
    public List<UserAddress> initOrder2(String userId) 
        System.out.println("用户id:" + userId);
        List<UserAddress> addressList = userService.getUserAddressList(userId);
        return addressList;
    

    @Override
    public void initOrder(String userId) 

    

server.port=8081

spring.application.name=boot-order-service-consumer
dubbo.application.name=boot-order-service-consumer

dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.monitor.protocol=registry

主启动类上添加 @EnableDubbo注解开启Dubbo的注解配置功能。 

package com.szh;

import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo
public class BootOrderServiceConsumerApplication 

    public static void main(String[] args) 
        SpringApplication.run(BootOrderServiceConsumerApplication.class, args);
    



3.启动测试

启动服务提供者和消费者之前,要先将zookeeper开启,然后再将dubbo管控台打开。

我这里为了方便,就直接在windows下启动zookeeper了,下载请移步官网:https://zookeeper.apache.org/,下载解压之后,找到conf目录下的zoo.cfg文件,做如下修改:

# example sakes.
dataDir=E:\\\\zookeeper\\\\zookeeper-3.4.11\\\\data
# the port at which the clients will connect
clientPort=2181

然后转到bin目录下,cmd启动 zkServer.cmd 即可。

zookeeper相关配置等链接参考:https://dubbo.apache.org/zh/docs/references/registry/zookeeper/

这里需要先启动服务提供者,再启动服务消费者。 

由于我们在服务消费者的 @DubboReference 注解中配置了 check=false,所以这里即使启动顺序不对,或者找不到服务提供者,也不会报错,而是直接忽略。

下面是dubbo的管控台,这个不安装也无所谓,我这里就不给出下载安装的步骤了。。。(可以参考尚硅谷-雷神老师的Dubbo课程)

下面通过服务消费者中的接口,可以直接调用到服务提供者的接口,同时获取到相关数据内容。 

下面的截图是对应了服务提供者中的 TimeUnit.MILLISECONDS.sleep(2000); //测试timeout 代码。和服务消费者中的 @DubboReference 注解中的timeout属性。

如果服务提供者睡眠时间超过了 服务消费者 中定义的超时时间,那么就会出现下图的异常。

反之,则可以正常远程调用服务提供者的接口,也就是下下张图。

下面的截图演示的是重试次数,远程服务调用重试次数,不包括第一次调用,不需要重试请设为0。

对应的是 服务提供者 的  TimeUnit.MILLISECONDS.sleep(4000); //测试重试次数。和服务消费者中的 @DubboReference 注解中的 retries 属性。

这里需要保证 服务提供者的响应时间大于服务消费者的等待超时时间,一旦满足,服务消费者此时调不到服务提供者,那么在服务提供者方就会进行重试。

最后这个测试的Dubbo的多版本问题。也就是用到了服务提供者中的两个具体实现类,这二者通过 @DubboService 注解中的 version 加以区分,一个版本为1.0.0、另一个版本为2.0.0。  而在服务消费者中通过  @DubboReference 注解中的version属性来指定具体要消费服务提供者的哪个实现类。


4.Dubbo配置原则

JVM 启动 -D 参数优先,这样可以使用户在部署和启动时进行参数重写,比如在启动时需改变协议的端口。

XML 次之,如果在 XML 中有配置,则 dubbo.properties 中的相应配置项无效。

Properties 最后,相当于缺省值,只有 XML 没有配置时,dubbo.properties 的相应配置项才会生效,通常用于共享公共配置,比如应用名。

以上是关于SpringBoot整合Dubbo的第一种方式——application.properties + @DubboService + @DubboReference的主要内容,如果未能解决你的问题,请参考以下文章

SpringBoot整合Dubbo的第三种方式——XML配置 + @ImportResource

SpringBoot整合Dubbo的第三种方式——XML配置 + @ImportResource

SpringBoot整合Dubbo的第三种方式——XML配置 + @ImportResource

SpringBoot整合Dubbo的第二种方式——API(自定义Configuration配置类)

SpringBoot整合Dubbo的第二种方式——API(自定义Configuration配置类)

5分钟实现SpringBoot整合Dubbo构建分布式服务