Dubbo配合SpringBoot，實現接口多個實現(group)

SpringBoot配合Dubbo位谋，使用@Service和@Reference，group實現接口多實現

公司項目升級堰燎，需要實現springBoot + Dubbo掏父，并支持一個接口多個實現的情況。遇到了幾個坑秆剪，在這里記錄下赊淑。

1. 安裝Zookeeper

在官網上下載最新版本3.5.6(注意下載 bin 包)

將下載好的壓縮包爵政，解壓到對應目錄

cd apache-zookeeper-3.5.6-bin/conf/ // 切換到配置目錄

mv zoo_sample.cfg zoo.cfg //更改默認配置文件名稱

vi zoo.cfg // 編輯配置文件，自定義dataDir陶缺，我的配置貼在下面

這里會遇到第一個坑：zk從3.5.5開始钾挟，帶有bin名稱的包才是我們想要的下載可以直接使用的里面有編譯后的二進制的包，而tar.gz的包里面是只是源碼饱岸，無法直接使用掺出。不小心下了 apache-zookeeper-3.5.6.tar.gz 這個包，啟動時會報錯"錯誤: 找不到或無法加載主類 org.apache.zookeeper.server.quorum.QuorumPeerMain"苫费。

zoo.cfg

# 發(fā)送心跳的間隔時間汤锨， 毫秒為單位
tickTime=2000
# 集群用到，初始化連接時百框，leader最多能容忍client多少個心跳間隔闲礼，默認是10，就代表10*2000=20000 琅翻， 毫秒
initLimit=10
# 集群用到位仁，正常通信時柑贞，如果client超過此時間間隔沒有心跳
syncLimit=5
# 保存數據的目錄
dataDir=/Users/ouitsu/document/apache-zookeeper-3.5.6-bin/data
# 暴露的接口
clientPort=2181
# zk3.5的新特性方椎，Zookeeper AdminServer，默認端口是8080钧嘶，坑的一批
admin.serverPort=12181

這里是第二個坑棠众，zk的Zookeeper AdminServer默認端口和Dubbo admin默認端口沖突，會報錯：Unable to start AdminServer, exiting abnormally org.apache.zookeeper.server有决，在這里定義端口即可解決闸拿。

配置完成，開始啟動zk

cd到zookeeper的bin目錄下

./zkServer.sh start 啟動

./zkServer.sh stop 停止

2. 開始搭建項目

1. 生產者

目錄結構如下：

image

provider_pom文件如下

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.uaepay.pay.channel</groupId>
    <artifactId>dubbo_provider</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>dubbo_provider</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>com.alibaba.spring.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>uaepay.cmf.channel</groupId>
            <artifactId>dubbo_facade</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.12</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.2.0.RELEASE</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

    <repositories>
        <repository>
            <id>spring-milestones</id>
            <name>Spring Milestones</name>
            <url>https://repo.spring.io/milestone</url>
        </repository>
    </repositories>

</project>

provider_application:

package com.uaepay.pay.channel.dubbo_provider;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo  //啟動dubbo的配置
public class DubboProviderApplication {

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

兩個生產實現

package com.uaepay.pay.channel.dubbo_provider.service;

import com.alibaba.dubbo.config.annotation.Service; // 這里要注意引用dubbo的Service
import org.springframework.stereotype.Component; // 對應的书幕，使用spring的Component
import uaepay.cmf.channel.MockResponseService;
import uaepay.cmf.channel.vo.User;

@Service(group = "mockResponseServiceImpl") // 定義group
@Component
public class MockResponseServiceImpl implements MockResponseService {

    @Override
    public User getUserInfo() {
        User user = new User();
        user.setUserName("1111");
        return user;
    }
}

package com.uaepay.pay.channel.dubbo_provider.service;

import com.alibaba.dubbo.config.annotation.Service;// 使用alibaba.dubbo的Service注解
import org.springframework.stereotype.Component;// 使用Spring的Component注解
import uaepay.cmf.channel.MockResponseService;
import uaepay.cmf.channel.vo.User;

@Service(group = "mockResponseServiceImpl2") //定義group
@Component
public class MockResponseServiceImpl2 implements MockResponseService {

    @Override
    public User getUserInfo() {
        User user = new User();
        user.setUserName("222222");
        return user;
    }
}

application.properties

dubbo.application.name=dubbo-provider-service
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.port=20782
dubbo.protocol.dispatcher=message
dubbo.protocol.threadpool=fixed
dubbo.protocol.threads=200
server.port=8871

2. 消費者

目錄結構如下：

image

pom文件

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.uaepay.pay.channel</groupId>
    <artifactId>dubbo_consumer</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>dubbo_consumer</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>

        <dependency>
            <groupId>uaepay.cmf.channel</groupId>
            <artifactId>dubbo_facade</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.12</version>
        </dependency>

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.28</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

ConsumerApplication：

package com.uaepay.pay.channel.dubbo_consumer;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo
public class DubboConsumerApplication {

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

消費者的實現類

package com.uaepay.pay.channel.dubbo_consumer.service;

import com.alibaba.dubbo.config.annotation.Reference;// 使用Dubbo的reference 獲取對應實現
import com.alibaba.fastjson.JSON;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import uaepay.cmf.channel.MockResponseService;

import java.util.LinkedHashMap;
import java.util.TreeMap;

@RestController
@RequestMapping("/test")
public class MockServiceImpl {

    @Reference(group = "mockResponseServiceImpl")//對應定義group
    private MockResponseService mockResponseServiceImpl;

    @Reference(group = "mockResponseServiceImpl2")// 對應定義group
    private MockResponseService mockResponseServiceImpl2;

    @RequestMapping("/getUserInfo")
    public  void getUserInfo(){
        System.out.println("得到的詳情為..."+JSON.toJSONString(mockResponseServiceImpl.getUserInfo()));
    }

    @RequestMapping("/getUserInfo1")
    public  void getUserInfo11(){
        System.out.println("得到的詳情為..."+JSON.toJSONString(mockResponseServiceImpl2.getUserInfo()));
    }
}

application.properties

dubbo.application.name=dubbo-consumer-service
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.consumer.check=false
server.port=8862

facade包

項目結構如下：

image

pom文件

<?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>uaepay.cmf.channel</groupId>
  <artifactId>dubbo_facade</artifactId>
  <version>1.0-SNAPSHOT</version>

  <name>dubbo_facade</name>
  <url>http://www.example.com</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.7</maven.compiler.source>
    <maven.compiler.target>1.7</maven.compiler.target>
  </properties>

  <dependencies>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>4.11</version>
      <scope>test</scope>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <optional>true</optional>
    </dependency>
    <dependency>
      <groupId>commons-lang</groupId>
      <artifactId>commons-lang</artifactId>
      <version>2.4</version>
    </dependency>
  </dependencies>

  <build>
    <pluginManagement>
      <plugins>
        <plugin>
          <artifactId>maven-clean-plugin</artifactId>
          <version>3.1.0</version>
        </plugin>
        <plugin>
          <artifactId>maven-resources-plugin</artifactId>
          <version>3.0.2</version>
        </plugin>
        <plugin>
          <artifactId>maven-compiler-plugin</artifactId>
          <version>3.8.0</version>
        </plugin>
        <plugin>
          <artifactId>maven-surefire-plugin</artifactId>
          <version>2.22.1</version>
        </plugin>
        <plugin>
          <artifactId>maven-jar-plugin</artifactId>
          <version>3.0.2</version>
        </plugin>
        <plugin>
          <artifactId>maven-install-plugin</artifactId>
          <version>2.5.2</version>
        </plugin>
        <plugin>
          <artifactId>maven-deploy-plugin</artifactId>
          <version>2.8.2</version>
        </plugin>
        <plugin>
          <artifactId>maven-site-plugin</artifactId>
          <version>3.7.1</version>
        </plugin>
        <plugin>
          <artifactId>maven-project-info-reports-plugin</artifactId>
          <version>3.0.0</version>
        </plugin>
      </plugins>
    </pluginManagement>
  </build>
</project>

實體類

package uaepay.cmf.channel.vo;
import java.io.Serializable;

public class User implements Serializable {
    private String userName;
    public String getUserName() {
        return userName;
    }
    public void setUserName(String userName) {
        this.userName = userName;
    }
}

接口

package uaepay.cmf.channel;
import uaepay.cmf.channel.vo.User;

public interface MockResponseService {

    public User getUserInfo();

}

3. 運行項目

啟動provider

Socket connection established to 127.0.0.1/127.0.0.1:2181, initiating session
Session establishment complete on server 127.0.0.1/127.0.0.1:2181, sessionid = 0x100000dd3c5000c, negotiated timeout = 30000

成功打印出這些新荤，說明生產者已經注冊成功，如果未出現台汇，檢查一下是不是沒引入com.101tec.zkclient的依賴苛骨，或者zk是否成功啟動。

啟動Consumer

<dubbo:reference object="com.alibaba.dubbo.common.bytecode.proxy0@3da222de" singleton="true" interface="uaepay.cmf.channel.MockResponseService" uniqueServiceName="mockResponseServiceImpl/uaepay.cmf.channel.MockResponseService" generic="false" group="mockResponseServiceImpl" listener="" filter="" id="uaepay.cmf.channel.MockResponseService" /> has been built.
<dubbo:reference object="com.alibaba.dubbo.common.bytecode.proxy0@4aae626d" singleton="true" interface="uaepay.cmf.channel.MockResponseService" uniqueServiceName="mockResponseServiceImpl2/uaepay.cmf.channel.MockResponseService" generic="false" group="mockResponseServiceImpl2" listener="" filter="" id="uaepay.cmf.channel.MockResponseService" /> has been built.

成功打印這個祷杈，證明消費者配置成功舟肉。

如果打印的是 <dubbo:reference singleton="true" interface="uaepay.cmf.channel.MockResponseService..../> 且訪問報空指針蜂厅，打印參數中不包含 object時，說明消費者沒有接收到生產者的代理對象严衬。需要檢查兩個地方：

依賴是否加上了com.101tec.zkclient
application.properties中是否加入了屬性 dubbo.consumer.check=false

4. 附加：Dubbo-admin

dubbo提供dubbo的后臺管理，在github上下載笆呆，拉到本地的項目結構是這樣的：

image

重要的子模塊有兩個：Dubbo-admin-server和Dubbo-admin-ui

Dubbo-admin-server：
- 默認端口8080
- 是一個springboot項目请琳，直接啟動即可
Dubbo-admin-ui：
- 需要使用npm粱挡，沒安裝npm的點這里
- cd到Dubbo-admin-ui路徑，npm install 安裝依賴
- 依賴安裝完成俄精，npm run dev
- 運行成功打開http://localhost:8081 即可

如果有具體步驟不懂抱怔，可以查看項目中的README.md(子模塊中也有)，寫的很詳細嘀倒。

至此屈留，大功告成！

最后編輯于：2019.11.03 14:09:32

?著作權歸作者所有,轉載或內容合作請聯系作者

人面猴
序言：七十年代末测蘑，一起剝皮案震驚了整個濱河市灌危，隨后出現的幾起案子，更是在濱河造成了極大的恐慌碳胳，老刑警劉巖勇蝙，帶你破解...
沈念sama閱讀 218,122評論 6贊 505
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件，死亡現場離奇詭異挨约，居然都是意外死亡味混，警方通過查閱死者的電腦和手機，發(fā)現死者居然都...
沈念sama閱讀 93,070評論 3贊 395
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進店門诫惭，熙熙樓的掌柜王于貴愁眉苦臉地迎上來翁锡，“玉大人，你說我怎么就攤上這事夕土」菹危” “怎么了？”我有些...
開封第一講書人閱讀 164,491評論 0贊 354
道士緝兇錄：失蹤的賣姜人
文/不壞的土叔我叫張陵怨绣，是天一觀的道長角溃。經常有香客問我，道長篮撑，這世上最難降的妖魔是什么减细？我笑而不...
開封第一講書人閱讀 58,636評論 1贊 293
?港島之戀（遺憾婚禮）
正文為了忘掉前任，我火速辦了婚禮赢笨，結果婚禮上未蝌，老公的妹妹穿的比我還像新娘。我一直安慰自己质欲，他們只是感情好树埠，可當我...
茶點故事閱讀 67,676評論 6贊 392
惡毒庶女頂嫁案：這布局不是一般人想出來的
文/花漫我一把揭開白布。她就那樣靜靜地躺著嘶伟，像睡著了一般怎憋。火紅的嫁衣襯著肌膚如雪。梳的紋絲不亂的頭發(fā)上，一...
開封第一講書人閱讀 51,541評論 1贊 305
城市分裂傳說
那天绊袋，我揣著相機與錄音毕匀，去河邊找鬼。笑死癌别，一個胖子當著我的面吹牛皂岔，可吹牛的內容都是我干的。我是一名探鬼主播展姐，決...
沈念sama閱讀 40,292評論 3贊 418
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開眼躁垛，長吁一口氣：“原來是場噩夢啊……” “哼！你這毒婦竟也來了圾笨？” 一聲冷哼從身側響起教馆，我...
開封第一講書人閱讀 39,211評論 0贊 276
萬榮殺人案實錄
序言：老撾萬榮一對情侶失蹤，失蹤者是張志新（化名）和其女友劉穎擂达，沒想到半個月后土铺，有當地人在樹林里發(fā)現了一具尸體，經...
沈念sama閱讀 45,655評論 1贊 314
?護林員之死
正文獨居荒郊野嶺守林人離奇死亡板鬓，尸身上長有42處帶血的膿包…… 初始之章·張勛以下內容為張勛視角年9月15日...
茶點故事閱讀 37,846評論 3贊 336
?白月光啟示錄
正文我和宋清朗相戀三年悲敷，在試婚紗的時候發(fā)現自己被綠了。大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片俭令。...
茶點故事閱讀 39,965評論 1贊 348
活死人
序言：一個原本活蹦亂跳的男人離奇死亡后德，死狀恐怖，靈堂內的尸體忽然破棺而出唤蔗，到底是詐尸還是另有隱情探遵，我是刑警寧澤窟赏，帶...
沈念sama閱讀 35,684評論 5贊 347
?日本核電站爆炸內幕
正文年R本政府宣布妓柜，位于F島的核電站，受9級特大地震影響涯穷，放射性物質發(fā)生泄漏棍掐。R本人自食惡果不足惜，卻給世界環(huán)境...
茶點故事閱讀 41,295評論 3贊 329
男人毒藥：我在死后第九天來索命
文/蒙蒙一拷况、第九天我趴在偏房一處隱蔽的房頂上張望作煌。院中可真熱鬧，春花似錦赚瘦、人聲如沸粟誓。這莊子的主人今日做“春日...
開封第一講書人閱讀 31,894評論 0贊 22
一樁弒父案起意，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽鹰服。三九已至，卻和暖如春，著一層夾襖步出監(jiān)牢的瞬間悲酷，已是汗流浹背套菜。一陣腳步聲響...
開封第一講書人閱讀 33,012評論 1贊 269
情欲美人皮
我被黑心中介騙來泰國打工，沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留设易，地道東北人逗柴。一個月前我還...
沈念sama閱讀 48,126評論 3贊 370
代替公主和親
正文我出身青樓，卻偏偏與公主長得像顿肺，于是被迫代替她去往敵國和親戏溺。傳聞我的和親對象是個殘疾皇子，可洞房花燭夜當晚...
茶點故事閱讀 44,914評論 2贊 355

Dubbo配合SpringBoot，實現接口多個實現(group)

SpringBoot配合Dubbo位谋，使用@Service和@Reference，group實現接口多實現

1. 安裝Zookeeper

zoo.cfg

2. 開始搭建項目

1. 生產者

provider_pom文件如下

provider_application:

兩個生產實現

application.properties

2. 消費者

pom文件

ConsumerApplication：

消費者的實現類

application.properties

facade包

pom文件

實體類

接口

3. 運行項目

啟動provider

啟動Consumer

4. 附加：Dubbo-admin

推薦閱讀更多精彩內容