SpringBoot整合Dubbo的第一种方式——application.properties + @DubboService + @DubboReference
Posted 张起灵-小哥
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了SpringBoot整合Dubbo的第一种方式——application.properties + @DubboService + @DubboReference相关的知识,希望对你有一定的参考价值。
1.文档参照
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配置类)