springboot整合apache dubbo

文章目錄

• ZooKeeper安裝啟動
• dubbo-admin安裝啟動
• dubbo服務提供者
• dubbo服務消費者
• 總結

Apache Dubbo 是一款高性能、輕量級的開源Java RPC框架，它提供了三大核心能力：面向接口的遠程方法調用，智能容錯和負載均衡，以及服務自動注冊和發現。

ZooKeeper安裝啟動

下載地址：http://zookeeper.apache.org/releases.html

下載完畢后解壓縮，在zookeeper的conf目錄下 把 zoo_sample.cfg復制一份重命名為 zoo.cfg ，然后只想 bin 目錄下的 zkServer.cmd

tickTime=2000 
initLimit=10 
syncLimit=5 
#這個參數可以改為自己的想要的位置
dataDir=../data 
#zookeeper的啟動端口
clientPort=2181 

dubbo-admin安裝啟動

源碼地址：https://github.com/apache/dubbo-admin

通過git clone 來回來源碼自己編譯，mvn clean package ， 
編譯之前需要改一下配置 dubbo-admin\dubbo-admin-server\src\main\resources\application.properties

#如果要換啟動端口可以在這設置
server.port=8081
# centers in dubbo2.7
admin.registry.address=zookeeper://127.0.0.1:2181
admin.config-center=zookeeper://127.0.0.1:2181
admin.metadata-report.address=zookeeper://127.0.0.1:2181

#group
admin.registry.group=dubbo
admin.config-center.group=dubbo
admin.metadata-report.group=dubbo

admin.apollo.token=e16e5cd903fd0c97a116c873b448544b9d086de9
admin.apollo.appId=test
admin.apollo.env=dev
admin.apollo.cluster=default
admin.apollo.namespace=dubbo

編譯完執行 jave -jar dubbo-admin\dubbo-admin-distribution\target\dubbo-admin-0.1.jar
訪問本地 dubbo-admin 

dubbo服務提供者

1. 引入依賴

		<dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>2.7.3</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

2. application配置

server:
  port: 9080

spring:
  application:
    name: dubbo-p

dubbo:
  scan:
    base-packages: me.zingon.test.dubbop
  protocol:
    name: dubbo
    port: -1
  registry:
    address: zookeeper://127.0.0.1:${embedded.zookeeper.port}
    file: ${user.home}/dubbo-cache/${spring.application.name}/dubbo.cache
  metadata-report:
    address: zookeeper://127.0.0.1:2181

embedded:
  zookeeper:
    port: 2181

3. 創建接口（此接口dubbo消費者也需要使用，最好統一寫在一個模塊內）

public interface TestService{  
    Object getTest(String id);
} 

4. 創建接口實現（注意 Service注解要用dubbo的org.apache.dubbo.config.annotation.Service）

import me.zingon.test.interfac.TestService;
import org.apache.dubbo.config.annotation.Service;

import java.util.HashMap;
import java.util.Map;
//注意這個注解,可以通過此注解設置相關參數，如超時，重試次數。。。
@Service
public class TestServiceImpl implements TestService {
    @Override
    public Object getTest(String id) {
        Map<String,Object> result=new HashMap<>();
        result.put("id",id);
        result.put("test","this is dubbop");
        return result;
    }
}

5. 啟動

    此dubbo服務提供者已完成，只需要啟動此sproogboot項目，在dubbo-admin中即可看到此服務
   

點擊測試，即可通過dubbo測試此服務

dubbo服務消費者

1. 引入依賴，跟上一步一樣
2. application配置

spring:
  application:
    name: dubbo-c 
embedded:
  zookeeper:
    port: 2181 
dubbo:
  registry:
    address: zookeeper://127.0.0.1:${embedded.zookeeper.port}
    file: ${user.home}/dubbo-cache/${spring.application.name}/dubbo.cache

3. 創建接口（引入上一步創建的接口）
4. 調用此接口

import me.zingon.test.interfac.TestService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import java.util.Map;

@Service
public class CallService {
	//通過此注解注入 dubbo 服務提供者的接口
    @Reference
    private TestService testService;

    @PostConstruct
    public void test(){
        Map<String,Object> result= (Map<String, Object>) testService.getTest("asdasd");
        System.out.println(result.size());
        result.forEach((k,v)->{
            System.out.println(k+":"+v);
        });
    }

}
/* 最后執行結果： 2 test:this is dubbop id:asdasd */

總結

通過starter+注解的方式使用 dubbo 非常方便簡潔