2. 程式人生 > >Spring Boot入門教程(四十九): Dubbo

Spring Boot入門教程(四十九): Dubbo

阿新 • • 發佈：2018-11-08

一：簡介

Apache Dubbo (incubating) |ˈdʌbəʊ| 是一款高效能、輕量級的開源Java RPC框架，它提供了三大核心能力：面向介面的遠端方法呼叫，智慧容錯和負載均衡，以及服務自動註冊和發現。
在這裡插入圖片描述

二：安裝dubbo管理控制檯(dubbo-admin)

下載dubbo-admin(https://github.com/apache/incubator-dubbo-ops/tree/master) 注意是dubbo-admin專案，不是其它專案。
在這裡插入圖片描述

# 打包
mvn clean install
# 啟動專案
cd target
java -jar dubbo-admin-0.0.1-SNAPSHOT.jar 
# 訪問
localhost:7001  使用者名稱：root 密碼：root

在這裡插入圖片描述

安裝監控中心(dubbo-monitor-simple)

# 打包dubbo-monitor-simple
cd dubbo-monitor-simple
mvn clean package

# 解壓.tar.gz 
cd target
tar -zxvf dubbo-monitor-simple-2.0.0-assembly.tar.gz 
mv dubbo-monitor-simple-2.0.0 ../..
# 啟動程式
cd ../../dubbo-monitor-simple-2.0.0/assembly.bin 
./start.sh 

# 訪問
http://localhost:8080/

在這裡插入圖片描述

三：XML方式

① dubbo-api

package com.example.api;

public interface DemoService {
    String sayHello(String name);
}

② dubbo-service-provider

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.example.provider</groupId>
    <artifactId>dubbo-service-provider</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencies>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.3</version>
        </dependency>

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.13</version>
        </dependency>

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

        <dependency>
            <groupId>com.example.api</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>

DemoServiceImpl

package com.example.provider;

public class DemoServiceImpl implements DemoService {
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

src/main/resources/provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://dubbo.apache.org/schema/dubbo
       http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <!-- 服務命名 -->
    <dubbo:application name="service-provider"/>

    <!-- 指定註冊中心 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>

    <!-- 指定服務提供者和服務消費者的通訊協議 -->
    <dubbo:protocol name="dubbo" port="20880"/>

	<!--監控中心(不是必須的)-->
    <dubbo:monitor protocol="registry"/>
    
    <!-- 暴露服務介面及介面關聯的實現 -->
    <dubbo:service interface="com.example.api.DemoService" ref="demoService" timeout="1000" retries="3">
        <dubbo:method name="sayHello" timeout="2000"/>
    </dubbo:service>
    <bean id="demoService" class="com.example.provider.DemoServiceImpl"/>
</beans>

ProviderMain

package com.example.provider;

public class ProviderMain {

    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("provider.xml");
        context.start();

        // 按任意鍵退出(阻塞程式停止結束)
        System.in.read();
    }
}

③ dubbo-client-consumer

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.example.consumer</groupId>
    <artifactId>dubbo-client-consumer</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencies>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.3</version>
        </dependency>

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.13</version>
        </dependency>

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

        <dependency>
            <groupId>com.example.api</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>

src/main/resources/consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://dubbo.apache.org/schema/dubbo
       http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <!-- 服務命名 -->
    <dubbo:application name="client-consumer" />

    <!-- 指定註冊中心 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>

	<!--監控中心(不是必須的)-->
    <dubbo:monitor protocol="registry"/>
    
    <!-- 引用介面 
    	timeout：服務呼叫超時時間，預設為1秒；
    	retries: 超時後重試次數(不包含第一次呼叫)；
    	version: 版本號，可以在服務提供上對同一個類暴露多次，每次都指定一個版本號，服務消費者可以指定來使用哪個版本的服務，*表示隨機呼叫任意一本版本 -->
    <dubbo:reference id="demoService" interface="com.example.api.DemoService" timeout="1000" retries="3"/>
</beans>

dubbo可以使用dubbo:reference針對介面做配置，也可以通過dubbo:method對介面的方法做配置，也可以使用dubbo:consumer用於全域性配置，越具體的配置優先順序越高
<dubbo:consumer timeout=“1000” retries=“3” check=“false”/>

package com.example.consumer;

public class ConsumerMain {

    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("consumer.xml");
        context.start();

        DemoService demoService = (DemoService)context.getBean("demoService");
        String hello = demoService.sayHello("world");
        System.out.println(hello);
		
		// 阻塞程式結束
        System.in.read();
    }
}

先啟動zookeeper，然後再執行ProviderMain最後再執行ConsumerMain
在這裡插入圖片描述

重新整理控制檯
在這裡插入圖片描述

服務治理下有很多選單，可以檢視具體內容
在這裡插入圖片描述

在這裡插入圖片描述

四：API方式

使用ServiceConfig和ReferenceConfig API取代xml配置方式

public class ProviderMain {

    public static void main(String[] args) throws IOException {
        ServiceConfig<DemoService> serviceConfig = new ServiceConfig<DemoService>();
        serviceConfig.setApplication(new ApplicationConfig("dubbo-service-provider"));
        serviceConfig.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
        serviceConfig.setInterface(DemoService.class);
        serviceConfig.setRef(new DemoServiceImpl());
        serviceConfig.export();

        // 按任意鍵退出(阻塞程式停止結束)
        System.in.read();
    }
}


public class ConsumerMain {

    public static void main(String[] args) {
        ReferenceConfig<DemoService> referenceConfig = new ReferenceConfig<DemoService>();
        referenceConfig.setApplication(new ApplicationConfig("dubbo-client-consumer"));
        referenceConfig.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
        referenceConfig.setInterface(DemoService.class);
        DemoService demoService = referenceConfig.get();
        String hello = demoService.sayHello("world");
        System.out.println(hello);
	
		// 阻塞程式結束
        System.in.read();
    }
}

五：Spring Boot

① 匯入dubbo-starter, 在application.properties配置屬性，使用@EnableDubbo開啟dubbo，使用@Service暴露服務，使用@Reference引用服務

注意：此種方式無法做到方法級別的配置

建立一個不依賴任何starter的Spring Boot工程springboot-dubbo-provider

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

<dependency>
    <groupId>com.alibaba.boot</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>0.2.0</version>
</dependency>

<dependency>
    <groupId>com.example.api</groupId>
    <artifactId>dubbo-api</artifactId>
    <version>1.0-SNAPSHOT</version>
</dependency>

@EnableDubbo 開啟Dubbo

@EnableDubbo
@SpringBootApplication
public class SpringbootDubboProviderApplication {

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

application.properties

dubbo.application.name=springboot-dubbo-provider
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
dubbo.monitor.protocol=registry

com.alibaba.dubbo.config.annotation.Service : 暴露介面

package com.example.dubbo.provider;
import com.alibaba.dubbo.config.annotation.Service;

@Service
@Component
public class DemoServiceImpl implements DemoService {
    @Override
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

建立一個依賴Web starter的Spring Boot工程：springboot-dubbo-consumer

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

<dependency>
     <groupId>com.alibaba.boot</groupId>
     <artifactId>dubbo-spring-boot-starter</artifactId>
     <version>0.2.0</version>
</dependency>

<dependency>
     <groupId>com.example.api</groupId>
     <artifactId>dubbo-api</artifactId>
     <version>1.0-SNAPSHOT</version>
</dependency>

application.properties

server.port=8081

dubbo.application.name=springboot-dubbo-consumer
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.monitor.protocol=registry

@EnableDubbo： 開啟Dubbo

@EnableDubbo
@SpringBootApplication
public class SpringbootDubboConsumerApplication {

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

@Reference：引用服務方提供的介面

@RestController
public class DemoController {

    @Reference
    private DemoService demoService;

    @GetMapping("/sayHello")
    public String sayHello(String name) {
        return demoService.sayHello(name);
    }
}

dubbo-api 一個普通的maven工程

package com.example.api;

public interface DemoService {
    String sayHello(String name);
}

在這裡插入圖片描述

在這裡插入圖片描述

② 使用xml配置

匯入dubbo-starter, 配置使用xml配置(provider.xml、consumer.xml)，application.properties就不需要任何dubbo配置，使用@ImportResource(location=“classpath:provider.xml”)來代替@EnableDubbo即可。

此種方式支援方法級別的配置。

③ 使用註解API

使用@Configuration來配置，使用@EnableDubbo開啟dubbo，使用@Service暴露介面，使用@Reference來引用介面。

每個標籤對應一個config類。如dubbo:application 對應ApplicationConfig

@Configuration
public class DubboConfiguration {

    @Bean
    public ApplicationConfig applicationConfig() {
        ApplicationConfig applicationConfig = new ApplicationConfig();
        applicationConfig.setName("springboot-dubbo-provider");

        return applicationConfig;
    }

    @Bean
    public RegistryConfig registryConfig() {
        RegistryConfig registryConfig = new RegistryConfig();
        registryConfig.setProtocol("zookeeper");
        registryConfig.setAddress("127.0.0.1");

        return registryConfig;
    }

    @Bean
    public ProtocolConfig protocolConfig() {
        ProtocolConfig protocolConfig = new ProtocolConfig();
        protocolConfig.setName("dubbo");
        protocolConfig.setPort(20882);

        return protocolConfig;
    }

    @Bean
    public ServiceConfig<DemoService> demoServiceServiceConfig(DemoService demoService) {
        ServiceConfig<DemoService> serviceConfig = new ServiceConfig<>();
        serviceConfig.setInterface(DemoService.class);
        serviceConfig.setRef(demoService);

        MethodConfig methodConfig = new MethodConfig();
        methodConfig.setName("sayHello");
        methodConfig.setTimeout(2000);
        serviceConfig.setMethods(Arrays.asList(methodConfig));

        return serviceConfig;
    }
}

註冊中心和監控不是必須的，當註冊中心宕機了，仍不影響服務的呼叫，可以通過@Reference中的url屬性直接指定服務提供者對應的ip和埠 @Reference(url = “127.0.0.1:20880”) , 這就是 Dubbo直連 方式。

負載均衡：Dubbo預設使用隨機的RandomLoadBanlance，可以在多個地方來配置複雜均衡策略，如在消費放配置 @Reference(loadbalance = “roundrobin”)

Dubbo可以與Hystrix整合,使用@EnableHystrix來開啟，使用@HystrixCommand來標註服務提供者方法和使用@HystrixCommand(fallbackMethod=“xxx”)來標註消費方方法

<dependency>
   <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
    <version>1.3.1.RELEASE</version>
</dependency>

相關推薦

Spring Boot入門教程(四十九): Dubbo

一：簡介 Apache Dubbo (incubating) |ˈdʌbəʊ| 是一款高效能、輕量級的開源Java RPC框架，它提供了三大核心能力：面向介面的遠端方法呼叫，智慧容錯和負載均衡，以及服務自動註冊和發現。 二：安裝dubbo管理控制檯(dubbo-admin)

Spring Boot入門教程(四十六): @Async

一：簡介 ThreadPoolTaskExecutor 用於定義執行緒池，是對java.util.concurrent.ThreadPoolExecutor類的包裝。可以通過@EnableAsync來開啟非同步支援，通過@Async來宣告一個非同步方法 二：示例 @Confi

Spring Boot入門教程(四十五): 事務@Transactional

一：簡介 在Spring中事務可以通過兩種方式來管理，一種是程式設計式事務另一種是宣告式事務 宣告式事務：@Transactional 在方法的開頭開始事務，在方法的結束提交事務 程式設計式事務：TransactionTemplate或者PlatformTransa

Spring Boot入門教程(四十八)：初始化操作 CommandLineRunner和ApplicationRunner

CommandLineRunner和ApplicationRunner在SpringApplication.run()之前，在所有的beans載入完成之後執行，用於執行一些初始化操作(如載入快取、讀取配置檔案、建立執行緒池等) CommandLineRunner和Applicatio

Spring Boot入門教程(四十):微信支付整合-刷卡支付

一：準備工作 使用微信支付需要先開通服務號，然後還要開通微信支付，最後還要配置一些開發引數，過程比較多。 二：支付方式 刷卡支付(MICROPAY) ：刷卡支付是使用者展示微信錢包內的“刷卡條碼/二維碼”給商戶系統掃描後直接完成支付的模式。主要應

Spring Boot入門教程(四十四): Sharding-JDBC+JPA|MyBatis+Druid分庫分表實現

一：資料庫分片方案 客戶端代理： 分片邏輯在應用端，封裝在jar包中，通過修改或者封裝JDBC層來實現。 噹噹網的 Sharding-JDBC 、阿里的TDDL是兩種比較常用的實現。 中介軟體代理： 在應用和資料中間加了一個代理層。分片邏輯統一維護在中介軟體

Spring Boot入門教程(五十): httpclient

在開發中經常會遇到呼叫第三方的介面，這裡介紹一下在spring boot中如何使用httpclient來發送get和post請求。 引入依賴 <dependency> <groupId>org.apache.httpco

Spring Boot入門教程(五十二): 在Docker上執行Spring Boot

一：基礎示例 1.1 安裝JDK和Maven 安裝openjdk: yum -y install java-1.8.0-openjdk* export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.191.b12-0.el7_

Spring Boot入門教程(五十一): JSON Web Token（JWT）

一：認證 在瞭解JWT之前先來回顧一下傳統session認證和基於token認證。 1.1 傳統session認證 http協議是一種無狀態協議，即瀏覽器傳送請求到伺服器，伺服器是不知道這個請求是哪個使用者發來的。為了讓伺服器知道請求是哪個使用者發來的，需要讓使用者提供

Spring Boot入門教程(三十一): 自定義Starter

在springboot中，使用的最多的就是starter。starter可以理解為一個可拔插式的外掛，例如，你想使用jdbc外掛，那麼可以使用spring-boot-starter-jdbc；如果想使用mongodb，可以使用spring-boot-starte

Spring Boot入門教程(四十三): API介面設計之token、timestamp、sign

一：token 簡介 Token：訪問令牌access token, 用於介面中, 用於標識介面呼叫者的身份、憑證，減少使用者名稱和密碼的傳輸次數。一般情況下客戶端(介面呼叫方)需要先向伺服器端申請一個介面呼叫的賬號，伺服器會給出一個appId和一個key,

Spring Boot入門教程(四):配置檔案

配置方式 每個starter都有自己預設的配置，如果需要改變預設值，可以在其他地方配置來覆蓋掉預設的值，覆蓋預設的配置有多種方式，每種方式的優先順序也不同，如果在多個地方配置則優先使用優先順序高的值，其中命令列引數優先順序最高, 其中大部分引數一般都配置在屬性

Spring Boot入門系列（十九）整合mybatis，使用註解實現動態Sql、引數傳遞等常用操作！

前面介紹了Spring Boot 整合mybatis 使用註解的方式實現資料庫操作，介紹瞭如何自動生成註解版的mapper 和pojo類。 接下來介紹使用mybatis 常用註解以及如何傳引數等資料庫操作中的常用操作。 其實，mybatis 註解方式 和 XML配置方式兩者的使用基本上相同，只有在構建 SQL

Spring Boot入門教程(十九): Thymeleaf

一：Thymeleaf Spring官方也推薦使用Thymeleaf，Thymeleaf最大的特點是能夠直接在瀏覽器中開啟並正確顯示模板頁面，而不需要啟動整個Web應用。 JSP技術Spring Boot官方是不推薦的，原因有三： tomcat只支援wa

spring boot入門（四） springboot事務管理。最完整、簡單易懂、詳細的spring boot教程。

本文緊接spring boot入門（三）。 事務管理是對於一系列資料庫操作進行管理，一個事務包含一個或多個SQL語句，是邏輯管理的工作單元（原子單元）。通俗的講，事務管理是指的“一次操作”要不就全做，要不就全不做。例如，在一個訂單系統中，包括生成訂單，扣除商品存庫等操作，如

Spring Boot2 系列教程(二十九)Spring Boot 整合 Redis

經過 Spring Boot 的整合封裝與自動化配置，在 Spring Boot 中整合Redis 已經變得非常容易了，開發者只需要引入 Spring Data Redis 依賴，然後簡單配下 redis 的基本資訊，系統就會提供一個 RedisTemplate 供開發者使用，但是今天鬆哥想和大夥聊的不是這種

Spring Boot入門系列（十四）使用JdbcTemplate操作資料庫，配置多資料來源！

前面介紹了Spring Boot 中的整合Mybatis並實現增刪改查、如何實現事物控制。不清楚的朋友可以看看之前的文章：https://www.cnblogs.com/zhangweizhong/category/1657780.html。 Spring Boot 除了Mybatis資料庫框架，還有Jdbc

Spring Boot 入門（四）微服務之 Config Server 統一配置中心

bootstra pan pat 默認 star default client efault localhost 一、目錄結構 二、pom文件 <!-- 配置服務依賴 --> <dependency> &l

Spring Cloud 入門教程(四)： 分布式環境下自動發現配置服務

.html article png discover ice conf label tail 註釋 前一章， 我們的Hello world應用服務，通過配置服務器Config Server獲取到了我們配置的hello信息“hello world”. 但自己的配置文件中必須配

Spring Boot系列教程四：配置文件詳解properties

date int ava ota axu return 端口 rand work 一.配置隨機數，使用隨機數 在application.properties文件添加配置信息 1 #32位隨機數 2 woniu.secret=${random.value} 3 #隨機整數