碼上歡樂
相關內容    簡體    繁體

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

本文轉載自   查看原文   2019-11-03 11:34   2028    java

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

公司項目升級，需要實現springBoot + Dubbo，並支持一個接口多個實現的情況。遇到了幾個坑，在這里記錄下。

1. 安裝Zookeeper

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

  1. 將下載好的壓縮包，解壓到對應目錄
  2. cd apache-zookeeper-3.5.6-bin/conf/ // 切換到配置目錄
  3. mv zoo_sample.cfg zoo.cfg //更改默認配置文件名稱
  4. 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
# 發送心跳的間隔時間， 毫秒為單位
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

  1. cd到zookeeper的bin目錄下
  2. ./zkServer.sh start 啟動
  3. ./zkServer.sh stop 停止

開始搭建項目

1. 生產者

目錄結構如下：

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. 消費者

目錄結構如下：

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包

項目結構如下：

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();

}

運行項目

啟動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時，說明消費者沒有接收到生產者的代理對象。需要檢查兩個地方：

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

附加：Dubbo-admin

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

重要的子模塊有兩個：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(子模塊中也有)，寫的很詳細。

至此，大功告成！

歡迎訪問我的個人博客


免責聲明！

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



猜您在找 springboot 配合多個cachemanager SpringBoot整合Dubbo,並實現dubbo實現動態調用 Jmeter實現dubbo接口壓測案例 一個類實現多個接口 autofac 一個接口多個實現的順序執行 一個接口有多個實現類的調用方式 Jmeter官方插件實現Dubbo接口測試 springboot+dubbo整合sleuth+zipkin實現鏈路追蹤 Springboot2.3+Dubbo2.7.3實現灰度跳轉 springboot+dubbo+myBatis實現微服務集成
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM