Springboot+Dubbo+Nacos 注解方式实现微服务调用

点击上方“Java知音”，选择“置顶公众号”

技术文章第一时间送达！

作者：Sans_

juejin.im/post/5dc3f5116fb9a04a7d7719f1

一.项目结构

|-- spring-boot-dubbo-demo (父级工程)|-- spring-boot-dubbo-base (基础工程)|-- spring-boot-dubbo-consumer (消费者)|-- spring-boot-dubbo-provider (生产者)

SpringBoot版本:2.2.0

Dubbo版本:2.7.0

Nacos版本:1.1.4

二.启动Nacos注册中心

Nacos官方文档:

https://nacos.io/zh-cn/docs/quick-start.html

默认账号密码是nacos

三.搭建项目

Consumer和Provider的Maven依赖如下：

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- Base依赖 --><dependency><groupId>com.sans</groupId><artifactId>spring-boot-dubbo-base</artifactId><version>0.0.1-SNAPSHOT</version></dependency><!-- Dubbo依赖 --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.0</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>2.7.0</version></dependency><!-- Nacos依赖 --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-registry-nacos</artifactId><version>2.7.1</version></dependency><dependency><groupId>com.alibaba.nacos</groupId><artifactId>nacos-client</artifactId><version>1.0.0</version></dependency>
</dependencies>

Consumer配置如下:

# 配置端口
server:port: 8862
dubbo:# 配置服务信息application:name: dubbo-consumer# 禁用QOS同一台机器可能会有端口冲突现象qos-enable: falseqos-accept-foreign-ip: false# 配置注册中心registry:address: nacos://127.0.0.1:8848# 设置超时时间consumer:timeout: 4000
spring:main:# 解决Bean重复定义问题allow-bean-definition-overriding: true

Provider配置如下:

# 配置端口
server:port: 8861
dubbo:# 配置服务信息application:name: dubbo-provider# 禁用QOS同一台机器可能会有端口冲突现象qos-enable: falseqos-accept-foreign-ip: false# 配置注册中心registry:address: nacos://127.0.0.1:8848# 设置协议-协议由提供方指定消费方被动接受protocol:name: dubboport: 20880
spring:main:# 解决Bean重复定义问题allow-bean-definition-overriding: true

四.Base工程编写

编写DTO

/*** RPC接口DTO* 注意这里要实现序列化接口* @Author Sans* @CreateTime 2019/11/6 23:04*/
@Data
public class ProviderTestDTO implements Serializable {// IDprivate int id;// 名字private String name;// 序号private Integer number;
}

编写Serivce

/*** RPC接口* @Author Sans* @CreateTime 2019/11/6 23:03*/
public interface IProviderService {List<ProviderTestDTO> queryList();
}

编写返回结果类

/*** 返回结果类* 这里采用构建者模式构建* 优点：1.私有化构造器访问范围小 2.参数可灵活设置便于管理* @Author Sans* @CreateTime 2019/11/7 18:59*/
@Getter
public class ResultVO<T> implements Serializable {/*** 返回码*/private int code;/*** 返回信息*/private String message;/*** 返回数据*/private T data;/** 私有化构造器  **/private ResultVO() {}private ResultVO(ResultVO<T> resultVO) {this.code = resultVO.code;this.message = resultVO.message;this.data = resultVO.data;}/*** Build*/public static class Builder<T>{private ResultVO<T> resultVO;public Builder() {resultVO = new ResultVO<>();}public Builder code(int code){resultVO.code = code;return this;}public Builder message(String message){resultVO.message = message;return this;}public Builder data(T data){resultVO.data = data;return this;}public ResultVO<T> build(){return new ResultVO<>(resultVO);}}
}

五.Provider工程编写

在启动类上面不要忘记加上@EnableDubbo注解

@EnableDubbo //开启Dubbo的注解支持
@SpringBootApplication
public class ProviderApplication {public static void main(String[] args) {SpringApplication.run(ProviderApplication.class, args);}
}

实现IProviderService接口,注意这里的Serivce引用的是dubbo的包

/*** 生产者Dubbo接口实现* @Author Sans* @CreateTime 2019/11/6 23:01*/
@Service
public class ProviderServiceImpl implements IProviderService {@Overridepublic List<ProviderTestDTO> queryList() {// 初始化数据ProviderTestDTO testDTO1 = new ProviderTestDTO();testDTO1.setId(1);testDTO1.setName("学生");testDTO1.setNumber(100);ProviderTestDTO testDTO2 = new ProviderTestDTO();testDTO2.setId(2);testDTO2.setName("教师");testDTO2.setNumber(101);// 组装数据List<ProviderTestDTO> list = new ArrayList<>();list.add(testDTO1);list.add(testDTO2);return list;}
}

六.Consumer工程编写

和Provider工程的启动类一样,加上@EnableDubbo注解

@EnableDubbo //开启dubbo的注解支持
@SpringBootApplication
public class ConsumerApplication {public static void main(String[] args) {SpringApplication.run(ConsumerApplication.class, args);}
}

编写测试接口

/*** 消费测试接口* @Author Sans* @CreateTime 2019/11/6 23:09*/
@RestController
@RequestMapping("/consumer")
public class ConsumerController {// Dubbo远程调用注解@Referenceprivate IProviderService providerService;@RequestMapping(value = "/list",method = RequestMethod.GET)public ResultVO getList(){// 远程调用List<ProviderTestDTO> providerTestDTOList = providerService.queryList();return new ResultVO.Builder<>().code(200).message("success").data(providerTestDTOList).build();}
}

七.测试

启动Provider工程和Consumer工程,这个时候Nacos会有对应的服务

使用Postman访问Consumer测试接口

八.项目源码

码云:

https://gitee.com/liselotte/spring-boot-dubbo-demo

GitHub:

https://github.com/xuyulong2017/my-java-demo

END

Java面试题专栏

【40期】说一下线程池内部工作原理

【39期】Mybatis面试18问，你想知道的都在这里了！

【38期】一份tcp、http面试指南，常考点都给你了

【37期】请你详细说说类加载流程，类加载机制及自定义类加载器

【36期】说说如何停止一个正在运行的线程？

【35期】谈谈你对Java线程之间通信方式的理解

【34期】谈谈为什么要拆分数据库？有哪些方法？

【33期】分别谈谈联合索引生效和失效的条件

【32期】你知道Redis的字符串是怎么实现的吗？

【31期】了解什么是 redis 的雪崩、穿透和击穿？redis 崩溃之后会怎么样？应对措施是什么

我知道你 “在看”