快捷導(dǎo)航

SpringBoot中dubbo+zookeeper實(shí)現(xiàn)分布式開(kāi)發(fā)的應(yīng)用詳解

更新時(shí)間：2020年11月23日 10:02:11 作者：Listen-Y

這篇文章主要介紹了SpringBoot中dubbo+zookeeper實(shí)現(xiàn)分布式開(kāi)發(fā)的應(yīng)用詳解，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

總體實(shí)現(xiàn)思路是啟動(dòng)一個(gè)生產(chǎn)者項(xiàng)目注冊(cè), 將所含服務(wù)注冊(cè)到zookeeper的注冊(cè)中心, 然后在啟動(dòng)一個(gè)消費(fèi)者項(xiàng)目,將所需服務(wù)向zookeeper注冊(cè)中心進(jìn)行訂閱, 等待注冊(cè)中心的通知

注冊(cè)中心基于負(fù)載均衡算法給消費(fèi)者匹配到合適的生產(chǎn)者主機(jī),然后通知消費(fèi)者可以使用

實(shí)現(xiàn)生產(chǎn)者

導(dǎo)入zookeeper依賴包

<!-- Dubbo Spring Boot Starter -->
    <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>2.7.3</version>
    </dependency>
    <!--zookeeper的包-->
    <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
    <dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
    </dependency>
    <!-- 引入zookeeper -->
    <!--【新版的坑】zookeeper及其依賴包，解決日志沖突，還需要剔除日志依賴-->
    <dependency>
      <groupId>org.apache.curator</groupId>
      <artifactId>curator-framework</artifactId>
      <version>2.12.0</version>
    </dependency>
    <dependency>
      <groupId>org.apache.curator</groupId>
      <artifactId>curator-recipes</artifactId>
      <version>2.12.0</version>
    </dependency>
    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.14</version>
      <!--排除這個(gè)slf4j-log4j12-->
      <exclusions>
        <exclusion>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
      </exclusions>
    </dependency>

配置服務(wù)名字, 注冊(cè)中心地址, 掃描被注冊(cè)的包

server.port=8081
#當(dāng)前應(yīng)用名字
dubbo.application.name=provider-server
#注冊(cè)中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#掃描指定包下服務(wù)
dubbo.scan.base-packages=com.demo.service

實(shí)現(xiàn)一個(gè)接口,在接口中完成需求

public interface Translate {

  String translate(String str);
}

public interface Translate {

  String translate(String str);
}

實(shí)現(xiàn)一個(gè)消費(fèi)者

導(dǎo)入依賴, 和生產(chǎn)者的依賴是相同的

配置服務(wù)名字,注冊(cè)中心地址

server.port=8082
# 配置zookeeper
# 配置服務(wù)名字
dubbo.application.name=consumer.server
# 配置注冊(cè)中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

本來(lái)正常步驟是需要將服務(wù)提供者的接口打包，然后用pom文件導(dǎo)入，我們這里使用簡(jiǎn)單的方式，直接將服務(wù)的接口拿過(guò)來(lái)，路徑必須保證正確，即和服務(wù)提供者相同

在這里插入圖片描述實(shí)

現(xiàn)獲取翻譯服務(wù)

package com.demo.service;

import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

@Service //使用Spring的Service添加組件
public class Translation {

  @Reference //遠(yuǎn)程引用指定的服務(wù)，他會(huì)按照全類(lèi)名進(jìn)行匹配，看誰(shuí)給注冊(cè)中心注冊(cè)了這個(gè)全類(lèi)名
  private Translate translate;

  public String getTranslation(String str) {
    return translate.translate(str);
  }

}

實(shí)現(xiàn)controller

@RestController
public class TranslateController {

  @Autowired
  Translation translation;

  @RequestMapping("/tran/{str}")
  public String tran(@PathVariable("str")String str) {
    return translation.getTranslation(str);
  }
}

測(cè)試

首先啟動(dòng)zookeeper服務(wù)器和dubbo進(jìn)入到監(jiān)控頁(yè)面中

在這里插入圖片描述

切記不要關(guān)閉服務(wù)器和dubbo開(kāi)啟生產(chǎn)者這個(gè)springboot項(xiàng)目

在這里插入圖片描述

上圖顯示就是生產(chǎn)者注冊(cè)成功, 我們可以點(diǎn)擊ip查看詳情

在這里插入圖片描述

啟動(dòng)消費(fèi)者這個(gè)springboot項(xiàng)目

在這里插入圖片描述

訪問(wèn)地址, 但是要注意我們消費(fèi)者的tomcat啟動(dòng)端口已經(jīng)換成8082

翻譯成功

到此這篇關(guān)于SpringBoot中dubbo+zookeeper實(shí)現(xiàn)分布式開(kāi)發(fā)的應(yīng)用詳解的文章就介紹到這了,更多相關(guān)SpringBoot dubbo zookeeper分布式內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: