欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot系列教程之dubbo和Zookeeper集成方法

 更新時間:2020年09月05日 11:11:07   作者:小小白菜拱大豬  
這篇文章主要介紹了SpringBoot系列教程之dubbo和Zookeeper集成方法,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下

今日學習新的內(nèi)容:dubbo

  dubbo是阿里巴巴公司開源的一個高性能優(yōu)秀的服務(wù)框架,一款高性能、輕量級的開源Java RPC框架,它提供了三大核心能力:面向接口的遠程方法調(diào)用,智能容錯和負載均衡,以及服務(wù)自動注冊和發(fā)現(xiàn)。

zookeeper

  zooKeeper是一個分布式的,開放源碼的分布式應(yīng)用程序協(xié)調(diào)服務(wù),它是一個為分布式應(yīng)用提供一致性服務(wù)的軟件,提供的功能包括:配置維護、域名服務(wù)、分布式同步、組服務(wù)等。

SpringBoot整合dubbo和Zookeeper

1、了解Dubbo基本概念

在這里插入圖片描述
服務(wù)提供者(Provider):暴露服務(wù)的服務(wù)提供方,服務(wù)提供者在啟動時,向注冊中心注冊自己提供的服務(wù)。
服務(wù)消費者(Consumer):調(diào)用遠程服務(wù)的服務(wù)消費方,服務(wù)消費者在啟動時,向注冊中心訂閱自己所需的服務(wù),服務(wù)消費者,從提供者地址列表中,基于軟負載均衡算法,選一臺提供者進行調(diào)用,如果調(diào)用失敗,再選另一臺調(diào)用。
注冊中心(Registry)(中臺):注冊中心返回服務(wù)提供者地址列表給消費者,如果有變更,注冊中心將基于長連接推送變更數(shù)據(jù)給消費者
監(jiān)控中心(Monitor):服務(wù)消費者和提供者,在內(nèi)存中累計調(diào)用次數(shù)和調(diào)用時間,定時每分鐘發(fā)送一次統(tǒng)計數(shù)據(jù)到監(jiān)控中心

他們的關(guān)系如下:
1、服務(wù)容器啟動后,運行加載服務(wù)提供者provider;
2、服務(wù)提供者成功啟動,往注冊中心提供自己能提供的服務(wù);
3、服務(wù)消費者consumer成功啟動,往注冊中心訂閱自己要消費的服務(wù);
4、注冊中心Registry返回服務(wù)提供者地址列表給消費者,如果有變更,注冊中心將基于長連接推送變更數(shù)據(jù)給消費者。
5、服務(wù)消費者,從提供者地址列表中,基于軟負載均衡算法,選一臺提供者進行調(diào)用,如果調(diào)用失敗,再選另一臺調(diào)用。
6、服務(wù)消費者和提供者,在內(nèi)存中累計調(diào)用次數(shù)和調(diào)用時間,定時每分鐘發(fā)送一次統(tǒng)計數(shù)據(jù)到監(jiān)控中心。

2、在docker中安裝zookeeper

安裝:

(自動獲取到最新的zookeeper版本)
docker pull zookeeper 

啟動:

docker run --name zk01 -p 2181:2181 --restart always -d 6ad6cb039dfa
6ad6cb039dfa(鏡像id)

阿里云安全組規(guī)則和Linux系統(tǒng)防火墻都記得開放2181端口。


3、新建工程(1)新建工程,工程里新建兩個模塊,provider模塊

在這里插入圖片描述

(2)consumer模塊

在這里插入圖片描述

4、給兩個模塊導(dǎo)入相同的pom.xml文件

  zkclient使用起來還是有點坑,注意清除一些包中依賴,也是看狂神視頻學到的,這里在使用2.7.7版本時候用了新的注解出了點問題,還是改回來使用2.7.3,使用新版本還有點點區(qū)別,在代碼中我也給出一些警示了。

<dependencies>
    <!--    dubbo 7.3倒是可以,7.7的就出錯連接不上了-->
    <dependency>
      <groupId>org.apache.dubbo</groupId>
      <artifactId>dubbo-spring-boot-starter</artifactId>
      <version>2.7.3</version>
    </dependency>

    <!--    zookeeper client zkclient-->
    <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient -->
    <dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
    </dependency>


    <!-- 引入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>
      <!--排除這個slf4j-log4j12-->
      <exclusions>
        <exclusion>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
      </exclusions>
    </dependency>

5、添加service層售票接口、接口實現(xiàn)類  (1)ITicketService

public interface ITicketService {
  String saleTicket(String name);
}

  (2)TicketServiceImpl

注意使用的包名稱一定要一致,不是spring帶的Service

package top.weidaboy.provider.service.Impl;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;
import top.weidaboy.provider.service.ITicketService;
//zookeeper:服務(wù)注冊與發(fā)現(xiàn)
@Service      //使用后被注入,項目已啟動就自動注冊到注冊中心
@Component  //放到spring容器中去
//新版:import org.apache.dubbo.config.annotation.DubboService;
//@DubboService //將服務(wù)發(fā)布出去
public class TicketServiceImpl implements ITicketService {

  @Override
  public String saleTicket(String name) {
    return "確認買票: "+name;
  }
}

6、application.proterties文件配置dubbo詳細信息

server.port=8081
#當前應(yīng)用起名
dubbo.application.name=provider-server
#找到zookeeper注冊中心地址
dubbo.registry.address=zookeeper://你的IP:2181
#掃描提供指定包下的服務(wù)
dubbo.scan.base-packages=top.weidaboy.provider.service

7、啟動服務(wù)提供者代碼

  啟動成功后,該程序會往對應(yīng)的注冊中心地址注冊新的服務(wù),供給需要消費的消費者使用
在這里插入圖片描述

8、編寫服務(wù)消費者代碼

  既然有了服務(wù)提供者,那么就在consumer模塊中創(chuàng)建消費者來使用服務(wù),分以下三步:

(1)創(chuàng)建消費者服務(wù),以及實現(xiàn)接口

  UserService:

public interface IUserService {
  //買票
  String buyTicket(String name);
}

   UserServiceImpl:

@Service//注入到容器中, 這個import org.springframework.stereotype.Service;
public class UserServiceImpl implements IUserService {

  @Reference
   //遠程引用指定的服務(wù),
  //該注解會按照全類名來進行匹配,看是哪個給注冊中心注冊了這個全類名
  ITicketService ticketService; //相同的接口名

  @Override
  public String buyTicket(String name) {
    return ticketService.saleTicket(name);
  }
}

(2)在consumer模塊中添加服務(wù)提供者的接口代碼

  要求:在consumer模塊提供方的代碼路徑必須與provider模塊的路徑一樣,只需導(dǎo)入接口類
ITicketService:

public interface ITicketService {
  String saleTicket(String name);
}

 代碼結(jié)構(gòu)如圖:丑了點嘿嘿,湊合看吧

在這里插入圖片描述

(3)修改application.proterties文件

  注意:這是在consumer模塊下的文件,因為消費者只是需要消費服務(wù),無須注冊,就可以不用掃描對應(yīng)的服務(wù)包名了

server.port=8082 #需要不同端口
#給當前應(yīng)用起名:
dubbo.application.name=consumer-server
#注冊中心
dubbo.registry.address=zookeeper://你的IP:2181

9、編寫測試類

@SpringBootTest
class WeidaboyApplicationTests {
  @Autowired
  IUserService userService;
  @Test
  void contextLoads() {
    System.out.println(userService.buyTicket("唐人街探案三"));
  }
}

10、測試調(diào)用不同端口的服務(wù)

  運行測試類,要求我們剛剛啟動的服務(wù)提供者的程序不要關(guān)閉,并且兩個端口不能相互占用,注冊中心地址一樣。

在這里插入圖片描述

測試成功!

小結(jié)

  本次學習內(nèi)容實現(xiàn):SpingBoot整合了dubbo和zookeeper實現(xiàn)分布式開發(fā)的應(yīng)用,將提供服務(wù)和消費服務(wù)進行拆分,讓不同系統(tǒng)去管理,整體是為了更方便,更有目的的開發(fā)項目,長路漫漫,繼續(xù)前進吧!

到此這篇關(guān)于SpringBoot系列教程之dubbo和Zookeeper集成方法的文章就介紹到這了,更多相關(guān)SpringBoot dubbo和Zookeeper集成內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • 詳解Java中的不可變對象

    詳解Java中的不可變對象

    這篇文章主要介紹了Java中的不可變對象的相關(guān)知識,文中代碼非常詳細,幫助大家更好的理解和學習,感興趣的朋友可以參考下
    2020-06-06
  • 什么是jsoup及jsoup的使用

    什么是jsoup及jsoup的使用

    jsoup是一款基于Java的HTML解析器,它提供了一套非常省力的API,不但能直接解析某個URL地址、HTML文本內(nèi)容,而且還能通過類似于DOM、CSS或者jQuery的方法來操作數(shù)據(jù),所以?jsoup?也可以被當做爬蟲工具使用,這篇文章主要介紹了什么是jsoup及jsoup的使用,需要的朋友可以參考下
    2023-10-10
  • Java 如何繞過迭代器遍歷時的數(shù)據(jù)修改異常

    Java 如何繞過迭代器遍歷時的數(shù)據(jù)修改異常

    這篇文章主要介紹了Java 繞過迭代器遍歷時的數(shù)據(jù)修改異常的方法,幫助大家更好的理解和學習使用Java,感興趣的朋友可以了解下
    2021-02-02
  • java實現(xiàn)簡易的計算器界面

    java實現(xiàn)簡易的計算器界面

    這篇文章主要為大家詳細介紹了java實現(xiàn)簡易的計算器界面,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2022-04-04
  • centos7安裝java的多種方式總結(jié)

    centos7安裝java的多種方式總結(jié)

    這篇文章主要給大家介紹了關(guān)于centos7安裝java的多種方式,文中通過實例代碼以及圖文介紹的非常詳細,對大家學習或者使用java具有一定的參考學習價值,需要的朋友可以參考下
    2023-01-01
  • idea啟動命令過長的問題及解決

    idea啟動命令過長的問題及解決

    當IDEA啟動命令過長時,可以通過修改workspace.xml文件或調(diào)整啟動類配置來解決,方案一是在.idea文件或項目目錄中修改workspace.xml;方案二是通過運行配置(run->edit)來保存啟動設(shè)置,這兩種方法都可以有效縮短命令長度,解決啟動錯誤
    2024-09-09
  • Java實現(xiàn)輕松處理日期和時間的API小結(jié)

    Java實現(xiàn)輕松處理日期和時間的API小結(jié)

    這篇文章主要為大家詳細介紹了Java中的日期和時間API,可以輕松處理日期和時間,文中的示例代碼講解詳細,感興趣的小伙伴可以跟隨小編一起學習一下
    2024-03-03
  • java實現(xiàn)馬踏棋盤算法(騎士周游問題)

    java實現(xiàn)馬踏棋盤算法(騎士周游問題)

    這篇文章主要為大家詳細介紹了java實現(xiàn)馬踏棋盤算法,解決騎士周游問題,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2022-02-02
  • SpringMVC全局異常處理小結(jié)

    SpringMVC全局異常處理小結(jié)

    在開發(fā)中,不管是dao層、service層還是controller層,都有可能拋出異常,在springmvc中,能將所有類型的異常處理從各處理過程解耦出來,既保證了相關(guān)處理過程的功能較單一,也實現(xiàn)了異常信息的統(tǒng)一處理和維護,本文介紹SpringMVC全局異常處理,感興趣的朋友一起看看吧
    2024-03-03
  • Java實現(xiàn)大文件的分片上傳與下載(springboot+vue3)

    Java實現(xiàn)大文件的分片上傳與下載(springboot+vue3)

    這篇文章主要為大家詳細介紹了java基于springboot+vue3如何大文件的分片上傳與下載,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2023-06-06

最新評論