一.項目結構
項目結構:
|-- spring-boot-dubbo-demo (父級工程)
|-- spring-boot-dubbo-base (基礎工程)
|-- spring-boot-dubbo-consumer (消費者)
|-- spring-boot-dubbo-provider (生產(chǎn)者)
SpringBoot版本:2.2.0
Dubbo版本:2.7.0
Nacos版本:1.1.4
二.啟動Nacos注冊中心
Nacos官方文檔:nacos.io/zh-cn/docs/…
默認賬號密碼是nacos
image.png
<figcaption></figcaption>
image.png
<figcaption></figcaption>
三.搭建項目
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同一臺機器可能會有端口沖突現(xiàn)象
qos-enable: false
qos-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同一臺機器可能會有端口沖突現(xiàn)象
qos-enable: false
qos-accept-foreign-ip: false
# 配置注冊中心
registry:
address: nacos://127.0.0.1:8848
# 設置協(xié)議-協(xié)議由提供方指定消費方被動接受
protocol:
name: dubbo
port: 20880
spring:
main:
# 解決Bean重復定義問題
allow-bean-definition-overriding: true
四.Base工程編寫
編寫DTO
/**
* RPC接口DTO
* 注意這里要實現(xiàn)序列化接口
* @Author Sans
* @CreateTime 2019/11/6 23:04
*/
@Data
public class ProviderTestDTO implements Serializable {
// ID
private int id;
// 名字
private String name;
// 序號
private Integer number;
}
編寫Serivce
/**
* RPC接口
* @Author Sans
* @CreateTime 2019/11/6 23:03
*/
public interface IProviderService {
List<ProviderTestDTO> queryList();
}
編寫返回結果類
/**
* 返回結果類
* 這里采用構建者模式構建
* 優(yōu)點：1.私有化構造器訪問范圍小 2.參數(shù)可靈活設置便于管理
* @Author Sans
* @CreateTime 2019/11/7 18:59
*/
@Getter
public class ResultVO<T> implements Serializable {
/**
* 返回碼
*/
private int code;
/**
* 返回信息
*/
private String message;
/**
* 返回數(shù)據(jù)
*/
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);
}
}
實現(xiàn)IProviderService接口,注意這里的Serivce引用的是dubbo的包
/**
* 生產(chǎn)者Dubbo接口實現(xiàn)
* @Author Sans
* @CreateTime 2019/11/6 23:01
*/
@Service
public class ProviderServiceImpl implements IProviderService {
@Override
public List<ProviderTestDTO> queryList() {
// 初始化數(shù)據(jù)
ProviderTestDTO testDTO1 = new ProviderTestDTO();
testDTO1.setId(1);
testDTO1.setName("學生");
testDTO1.setNumber(100);
ProviderTestDTO testDTO2 = new ProviderTestDTO();
testDTO2.setId(2);
testDTO2.setName("教師");
testDTO2.setNumber(101);
// 組裝數(shù)據(jù)
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遠程調(diào)用注解
@Reference
private IProviderService providerService;
@RequestMapping(value = "/list",method = RequestMethod.GET)
public ResultVO getList(){
// 遠程調(diào)用
List<ProviderTestDTO> providerTestDTOList = providerService.queryList();
return new ResultVO.Builder<>().code(200).message("success").data(providerTestDTOList).build();
}
}
七.測試
啟動Provider工程和Consumer工程,這個時候Nacos會有對應的服務
image.png
<figcaption></figcaption>
使用Postman訪問Consumer測試接口
image.png
<figcaption></figcaption>
八.項目源碼
GitHub:github.com/xuyulong201…
謝謝大家閱讀,如果喜歡,請收藏點贊,多給些star,文章不足之處,也請給出寶貴意見.
