5 springboot 集成dubbo

本文轉載自查看原文 2018-12-22 15:45 924 SpringBoot

Apache Dubbo 是一款高性能Java RPC框架

由阿里巴巴開源並進入Apache孵化器，官網 http://dubbo.apache.org

提供服務化基礎功能：接口遠程調用，智能負載均衡，服務發現與注冊和運維治理界面等功能

集成SpringBoot中文說明地址 https://github.com/apache/incubator-dubbo-spring-boot-project/blob/master/README_CN.md

我們重新看下項目中的結構，做出如下修改

...somefun

......somefun-web （springboot項目 dubbo客戶端）

......somefun-service-system

.........somefun-system-api （對外提供模塊，提供接口和DTO）

.........somefun-system-service （springboot項目 dubbo服務提供端）

1我們將web模塊開發成dubbo服務消費端部分

2將web模塊中的pom去掉 somefun-system-service 依賴（somefun-system-api 依賴不去掉，通過此模塊實現遠程調用而不侵入代碼）

3將somefun-system-service模塊修改為springboot項目獨立運行

服務提供方的代碼

somefun-system-service模塊

pom文件

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <project xmlns="http://maven.apache.org/POM/4.0.0"
 3          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 5     <parent>
 6         <groupId>org.springframework.boot</groupId>
 7         <artifactId>spring-boot-starter-parent</artifactId>
 8         <version>2.1.1.RELEASE</version>
 9         <relativePath/>
10     </parent>
11 
12     <modelVersion>4.0.0</modelVersion>
13 
14     <artifactId>somefun-system-service</artifactId>
15     <dependencies>
16         <dependency>
17             <groupId>com.zhj</groupId>
18             <artifactId>somefun-system-api</artifactId>
19             <version>1.0-SNAPSHOT</version>
20         </dependency>
21 
22         <dependency>
23             <groupId>com.alibaba.boot</groupId>
24             <artifactId>dubbo-spring-boot-starter</artifactId>
25             <version>0.2.0</version> <!-- 最新的0.2.1-SNAPSHOT 可以去上邊的GitHub地址中下載編譯 -->
26         </dependency>
27 
28         <!-- Dubbo -->
29         <dependency>
30             <groupId>com.alibaba</groupId>
31             <artifactId>dubbo</artifactId>
32             <version>2.6.5</version>
33         </dependency>
34         <!-- Spring Context Extras -->
35         <dependency>
36             <groupId>com.alibaba.spring</groupId>
37             <artifactId>spring-context-support</artifactId>
38             <version>1.0.2</version>
39         </dependency>
40 
41     </dependencies>
42 
43 
44 </project>

創建啟動類SomefunSystemApplication

 1 @SpringBootApplication (scanBasePackages={"com.zhj.somefun"})
 2 public class SomefunSystemApplication {
 3 
 4    public static void main(String[] args) {
 5 
 6       new SpringApplicationBuilder(SomefunSystemApplication.class)
 7             .web(WebApplicationType.NONE)  //非web方式運行
 8             .run(args);
 9    }
10 
11 }

TestServiceImpl類：

注意下這時候的Service注解的包要引用 duboo中的service注解

 1 package com.zhj.somefun.system.service.impl;
 2 
 3 import com.zhj.somefun.system.api.dto.TestDto;
 4 import com.zhj.somefun.system.api.service.TestService;
 5 
 6 import com.alibaba.dubbo.config.annotation.Service;
 7 
 8 import java.util.ArrayList;
 9 import java.util.Date;
10 import java.util.List;
11 
12 @Service
13 public class TestServiceImpl implements TestService {
14 
15     @Override
16     public List<TestDto> getTestList() {
17         List<TestDto> list = new ArrayList<>();
18         TestDto dto = new TestDto();
19         dto.setAge(18);
20         dto.setId(1);
21         dto.setName("姓名1");
22         dto.setCreatedate(new Date());
23         list.add(dto);
24         return list;
25     }
26 }

TestDto類：

要實現Serializable接口

1 public class TestDto implements Serializable{
2     private Integer id;
3     private String name;
4 
5     public Integer getId() {
6         return id;
7     }
8     …… ……
9 }

application.yml文件

 1 server:
 2     port: 6666
 3 spring:
 4     application:
 5         name: dubbo-provider-demo
 6 
 7 dubbo:
 8     application:
 9         id: dubbo-provider-demo
10         name: dubbo-provider-demo
11     monitor:
12         protocol: registry
13     protocol:
14         id: dubbo
15         name: dubbo
16         port: 12345
17     registry:
18         address: zookeeper://127.0.0.1:2181
19         id: my-registry
20     scan:
21         #掃描server包地址
22         basePackages: com.zhj.somefun.system.service

服務消費方

我們將web模塊改造成dubbo調用方

pom 引入dubbo

 1 <dependency>
 2    <groupId>com.alibaba.boot</groupId>
 3    <artifactId>dubbo-spring-boot-starter</artifactId>
 4    <version>0.2.0</version>
 5 </dependency>
 6 
 7 <!-- Dubbo -->
 8 <dependency>
 9    <groupId>com.alibaba</groupId>
10    <artifactId>dubbo</artifactId>
11    <version>2.6.5</version>
12 </dependency>
13 <!-- Spring Context Extras -->
14 <dependency>
15    <groupId>com.alibaba.spring</groupId>
16    <artifactId>spring-context-support</artifactId>
17    <version>1.0.2</version>
18 </dependency>

Testcontroller控制器類

注解修改為Reference注解類

 1 @RestController
 2 public class Testcontroller {
 3 
 4     @Reference
 5     private TestService testService;
 6 
 7     @GetMapping("/getlist")
 8     public List<TestDto> getlist(){
 9         return testService.getTestList();
10     }
11 
12 }

application.yml 文件

 1 dubbo:
 2     application:
 3         id: dubbo-consumer-demo
 4         name: dubbo-consumer-demo
 5     monitor:
 6         protocol: registry
 7     protocol:
 8         id: dubbo
 9         name: dubbo
10         port: 12345
11     registry:
12         address: zookeeper://127.0.0.1:2181
13 server:
14     port: 8080
15 spring:
16   profiles:
17     active: dev
18   application:
19     name: dubbo-consumer-demo

因為我們注冊中心使用的是zookeeper，我們可以在網上下載最新的zookeeper文件，運行起來即可。

運行服務器提供方的項目somefun-system-service

運行消費方的項目somefun-web

訪問 http://localhost:8080/getlist ，

我們會發現已經可以返回 JSON數據

[{"id":1,"name":"姓名1","age":18,"createdate":"2018-12-22T06:58:43.535+0000"}]

這說明dubbo已經可以正常運行了

我們在運行項目中的時候編譯器可能會打印錯誤日志

com.alibaba.dubbo.rpc.RpcException: No provider available from registry 127.0.0.1:2181 for service com.alibaba.dubbo.monitor.MonitorService on consumer 192.168.1.73 use dubbo version 2.6.5, please check status of providers(disabled, not registered or in blacklist).

這個因為 dubbo的監控中心沒有接入，對於這篇代碼來說暫時沒有影響

這里只是介紹了最簡單的springboot 接入dubbo，更新豐富的功能和詳解的介紹在dubbo官網

http://dubbo.apache.org/zh-cn/

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 SpringBoot之Dubbo和Zookeeper集成 dubbo與springboot的集成 dubbo實戰之二：與SpringBoot集成 SpringBoot2集成Dubbo SpringBoot系列之集成Dubbo示例教程 springboot集成dubbo服務報錯No provider available for the service SpringBoot | 第二十九章：Dubbo的集成和使用 Spring boot 集成dubbo swagger部署和dubbo集成（一）dubbo swagger接入 springboot整合dubbo