dubbo+zookeeper+springboot構建服務

来源:https://www.cnblogs.com/wangrudong003/archive/2018/05/11/9024992.html
-Advertisement-
Play Games

本次和大家分享的是dubbo框架應用的初略配置和zookeeper註冊中心的使用;說到註冊中心現在我使用過的只有兩種:zookeeper和Eureka,zk我結合dubbo來使用,而Eureka結合springcloud使用,因此後面將和大家分享一些關於微服務的一些篇章,希望對你有好的幫助。 安裝註 ...


  本次和大家分享的是dubbo框架應用的初略配置和zookeeper註冊中心的使用;說到註冊中心現在我使用過的只有兩種:zookeeper和Eureka,zk我結合dubbo來使用,而Eureka結合springcloud使用,因此後面將和大家分享一些關於微服務的一些篇章,希望對你有好的幫助。

  安裝註冊中心zookeeper

  dubbo框架之provider和consumer

  dubbo-admin部署

安裝註冊中心zookeeper

  首先,我們需要在網上搜索下zookeeper下載地址,我這裡是linux系統,所以下載了zookeeper-3.3.6.tar.gz包,通過 tar -zxvf zookeeper-3.3.6.tar.gz 解壓出來,需要註意的是一般的包裡面配置文件都是預設的sample版本,zookeeper預設配置文件名只zoo.cfg,為了不每次指定文件名來運行,因此需要我們自己在conf目錄下創建一個名稱為zoo.cfg的配置文件,文件內容可以從zoo_sample.cfg拷貝或者把這個文件重命名都行,內容如下 vim zoo.cfg :

 1 # The number of milliseconds of each tick
 2 tickTime=2000  #心跳頻率
 3 # The number of ticks that the initial 
 4 # synchronization phase can take
 5 initLimit=10   #限制連接
 6 # The number of ticks that can pass between 
 7 # sending a request and getting an acknowledgement
 8 syncLimit=5
 9 # the directory where the snapshot is stored.
10 dataDir=/tmp/zookeeper   #數據存儲文件夾
11 # the port at which the clients will connect
12 clientPort=2081  #zookeeper對外的埠

  這裡就不修改參數信息了,採用預設;簡單介紹下linux下怎麼編輯文件內容的常用的幾個命令:

  vim zoo.cfg:查看文件內容

  insert:執行插入命令

  esc:取消命令,再接著按:q:退出,:wq:保存並退出

  當有了zoo.cfg後,我們只需要進入她的bin目錄裡面查找zkServer.sh文件,通過執行: ./zkServer.sh start 命令啟動zookeeper註冊中心,正常啟動提示如:

  

  通常情況是zookeeper作為註冊中心在單獨的一臺伺服器上,而程式(這裡指我本地)需要調用另外註冊中心需要檢查zookeeper開放的埠是否能通,我本地是window10因此可以不需要通過zookeeper客戶端去驗證埠,只需要通過 telnet ip 2081 就能檢測出是否埠開放;

dubbo框架之provider和consumer

  首先為了方便,我們需要定義一個統一的介面,該介面就是業務抽出來的公用介面,我們單獨對這種介面包裝成一個module,我這裡是dubbo_api,我們在這個module中定義如下的介面:

1 public interface UserService {
2     
3     List<MoUser> getUsers();
4 }

  然後,創建一個provider模塊,這個模塊去依賴dubbo_api模塊,並且實現UserService介面,代碼如:

 1 public class UserServiceImpl implements UserService {
 2 
 3     @Value("${server.port}")
 4     private int port;
 5 
 6     /**
 7      * @return
 8      */
 9     @Override
10     public List<MoUser> getUsers() {
11 
12         List<MoUser> list = new ArrayList<>();
13         for (int i = 0; i < 5; i++) {
14             MoUser user = new MoUser();
15             user.setUserName("shenniu" + i);
16             user.setUserPwd("埠:" + port);
17             list.add(user);
18         }
19         return list;
20     }
21 }

  作為服務提供者,要使用dubbo框架就需要先引入dubbo,然後再做一些配置,首先我們需要在dubbo_provider模塊通過maven引入dubbo依賴,註冊中心用的zookeeper所以也需要通過maven引入相應的依賴:

 1 <dependency>
 2             <groupId>org.apache.zookeeper</groupId>
 3             <artifactId>zookeeper</artifactId>
 4             <version>3.4.8</version>
 5         </dependency>
 6         <dependency>
 7             <groupId>com.101tec</groupId>
 8             <artifactId>zkclient</artifactId>
 9             <version>0.3</version>
10         </dependency>
11         <dependency>
12             <groupId>com.alibaba</groupId>
13             <artifactId>dubbo</artifactId>
14             <version>2.5.3</version>
15             <exclusions>
16                 <exclusion>
17                     <groupId>org.springframework</groupId>
18                     <artifactId>spring</artifactId>
19                 </exclusion>
20             </exclusions>
21         </dependency>
22         <dependency>
23             <groupId>com.example</groupId>
24             <artifactId>dubbo_api</artifactId>
25             <version>0.0.1-SNAPSHOT</version>
26         </dependency>

  完成依賴後,剩下的就是對dubbo的provider的配置了,創建resources/dubbo-conf/server.xml的配置文件,文件內容:

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
 4        xsi:schemaLocation="http://www.springframework.org/schema/beans
 5             http://www.springframework.org/schema/beans/spring-beans.xsd
 6             http://code.alibabatech.com/schema/dubbo
 7             http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 8 
 9     <!-- 提供者名稱 -->
10     <dubbo:application name="demo-provider" />
11 
12     <!-- zookeeper註冊中心的服務地址 -->
13     <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" />
14 
15     <!-- 用dubbo協議在20880埠暴露服務,協議通信埠 -->
16     <dubbo:protocol name="dubbo" port="20880" />
17 
18     <!-- 用戶服務介面 -->
19     <dubbo:service interface="service.UserService" ref="userService" />
20 
21     <!-- 用戶服務介面實現 -->
22     <bean id="userService" class="com.example.demo.service.UserServiceImpl"/>
23 </beans>

  在DubboProviderApplication入口增加資源導入 @ImportResource("classpath:dubbo-conf/*.xml") ,到這裡我們的服務提供端就完成了,查看下啟動日誌:

  

  服務提供者啟動暫無異常,再來看調用方創建一個dubbo_consumer的moduel,同樣去引入dubbo_api公共介面的模塊依賴,然後創建一個UserController,並暴露一個get的user介面:

 1 @RestController
 2 public class UserController {
 3     @Autowired
 4     private UserService userService;
 5 
 6     @GetMapping("/users")
 7     public List<MoUser> getUsers(){
 8 
 9         return userService.getUsers();
10     }
11 }

  這裡的UserService是公共介面的註入;編碼完成後剩下的就是consumer端引入dubbo和zookeeper依賴了:

 1 <dependency>
 2             <groupId>org.apache.zookeeper</groupId>
 3             <artifactId>zookeeper</artifactId>
 4             <version>3.4.8</version>
 5         </dependency>
 6         <dependency>
 7             <groupId>com.101tec</groupId>
 8             <artifactId>zkclient</artifactId>
 9             <version>0.3</version>
10         </dependency>
11         <dependency>
12             <groupId>com.alibaba</groupId>
13             <artifactId>dubbo</artifactId>
14             <version>2.5.3</version>
15             <exclusions>
16                 <exclusion>
17                     <groupId>org.springframework</groupId>
18                     <artifactId>spring</artifactId>
19                 </exclusion>
20             </exclusions>
21         </dependency>

  我們同樣創建名稱resources/dubbo-conf/client.xml的配置文件,併在application入口引入這個資源:

1 @ImportResource("classpath:dubbo-conf/*.xml")
2 @SpringBootApplication
3 public class DubboConsumerApplication {
4     public static void main(String[] args) {
5         SpringApplication.run(DubboConsumerApplication.class, args);
6     }
7 }

  client.xml的配置內容如:

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
 4        xsi:schemaLocation="http://www.springframework.org/schema/beans
 5             http://www.springframework.org/schema/beans/spring-beans.xsd
 6             http://code.alibabatech.com/schema/dubbo
 7             http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 8 
 9     <!-- 服務名 -->
10     <dubbo:application name="demo-consumer" />
11 
12     <!-- zookeeper註冊中心暴露服務地址 -->
13     <dubbo:registry protocol="zookeeper" address="192.168.168.168:2081" />
14 
15     <!-- 用戶服務介面 -->
16     <dubbo:reference id="userService" interface="service.UserService" />
17 
18 </beans>

  這個時候一個簡單的服務提供者,服務調用者配置和編碼都完成了,3個module如下:

  

  然後分別啟動provider,consumer;再通過consumer暴露的controller介面請求介面,我這裡的地址是 http://localhost:8082/users :

  

  效果是Consumer通過註入的UserService介面依賴調用getUsers()拿到了Provider返回的結果,也表示此次dubbo框架的簡單使用算成功了。

dubbo-admin部署

  作為一個流行的rpc框架dubbo有這一個開源的監控工具dubbo-admin,不得不說現在網上現成的dubbo-admin.war包要麼現在下來不能用要麼就是下載需要csdn積分,版本多種多樣有點坑啊,果斷去git拉源碼自己打包,git地址: https://github.com/apache/incubator-dubbo-ops ,拉下來後我們只需要關註dubbo-admin工程,其他的暫可忽略;打開項目後,我們需要改的地方只有如下截圖配置(也可以對打包後的配置文件修改):

  

1 #zookeeper配置地址和埠
2 dubbo.registry.address=zookeeper://127.0.0.1:2081
3 #後臺登錄密碼
4 dubbo.admin.root.password=root
5 dubbo.admin.guest.password=guest

  執行打包後,能得到名稱:dubbo-admin-2.0.0.war包,然後放在tomcat中,再通過瀏覽器瀏覽,賬號和密碼:都是root;登錄後能看到我們之前的啟動的provider和consumer在裡面,這就是dubbo-admin監控註冊中心服務的界面,能夠直接對這些服務做點擊操作,其他的不多說自行嘗試吧。

  


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 1 學習計劃 1、Linux部署 n 安裝jdk n 安裝tomcat n 安裝MySQL n 將項目發佈到tomcat 2、擴展資料 2 Linux部署 2.1 安裝jdk 第一步:獲取Linux系統中jdk安裝包 第二步:使用secureCRT客戶端工具連到伺服器 第三步:使用命令創建一個目錄, ...
  • 一、字典的概念 字典跟列表很像,特別是表達方式通過花括弧代替方括弧。當然,字典的元素通過左邊部分為鍵右邊部分為值通過冒號來分割。 二、字典的創建 {'jack': 4098, 'sape': 4139, 'yellow': 8466}{'jack': 4098, 'sape': 4139, 'yel ...
  • 【程式1】 題目:古典問題:有一對兔子,從出生後第3個月起每個月都生一對兔子,小兔子長到第三個月後每個月又生一對兔子,假如兔子都不死,問每個月的兔子總數為多少? 1.程式分析:兔子的規律為數列1,1,2,3,5,8,13,21.... 具體分析如下: 分析:從第一個兔子開始,第1個月1只兔子,由於“ ...
  • 在研究學術之餘,來複習一下java的SpringMVC框架,最近也沒什麼項目,所以也有一段時間沒有看這個框架了,都有點陌生了,現在每天都在看論文,研究方案,做實驗,在論文看不下去的時候就來學習一下SPringMVC也是不錯的選擇,哈哈哈!!!!!! 1. springmvc框架 1.1 什麼是spr ...
  • 一.protobuf 安裝 protobuf版本:2.6.1 下載地址:https://github.com/google/protobuf/archive/v2.6.1.zip 解壓之後進入目錄 修改autogen.sh 將autogen.sh內的上述內容修改為 然後執行autogen.sh ./ ...
  • DTL 變數 標簽 過濾器 1. 語法:{ { 變數|過濾器 }},例如{ { name|lower }},表示將變數name的值變為小寫輸出 2. 使用管道符號 (|)來應用過濾器 3. 通過使用過濾器來改變變數的計算結果 4. 可以在if標簽中使用過濾器結合運算符 ...
  • pandas 基礎 serise 0 4 1 7 2 5 3 3 dtype: int64 array([ 4, 7, 5, 3], dtype=int64) RangeIndex(start=0, stop=4, step=1) 1 7 3 3 dtype: int64 1 7 2 5 dtype ...
  • 這是java的一條規則。那麼為什麼會有這條規則呢?要想弄懂這個問題,就需要弄懂局部內部類對象和局部變數的生命周期的誰更長的問題。 首先,看一段代碼,以沒有將變數聲明為final的代碼作為例子,代碼如下: 如上面的第7行代碼所示,變數x沒有被聲明為final,如果是這樣的話,當執行完第26行的outM ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...