分散式學習系列【dubbo實踐】

来源:http://www.cnblogs.com/yuxuan/archive/2016/11/30/6119200.html
-Advertisement-
Play Games

分散式學習系列【dubbo實踐】 dubbo架構 組成部分:provider,consumer,registry,monitor; provider,consumer註冊,訂閱類似於消息隊列的註冊訂閱 一、環境安裝 1、dubbo admin 管理控制台安裝(Windows環境) #下載dubbo- ...


分散式學習系列【dubbo入門實踐】

dubbo架構

  

  

  組成部分:provider,consumer,registry,monitor; provider,consumer註冊,訂閱類似於消息隊列的註冊訂閱

  

一、環境安裝

1、dubbo admin 管理控制台安裝(Windows環境)

     #下載dubbo-admin-2.5.3.war,部署到tomcat下,根據需要編輯WEB-INF/dubbo.properties文件:

  dubbo.registry.address=zookeeper://127.0.0.1:2181

  dubbo.admin.root.password=root

  dubbo.admin.guest.password=guest

 

  #dubbo admin 部署問題:版本2.5.3啟動報錯:Bean property 'URIType' is not writable or has an invalid

  原因:使用了JDK1.8;

  解決方法:將環境變數JAVA_HOME設置為JDK1.7;

2、zookeeper 安裝

  dubbo對註冊中心實現了抽象,實現的註冊中心有:ZooKeeper,Redis,Multicast;這裡採用zookeeper進行演示。

  下載zookeeper解壓,在zookeeper->conf目錄下複製一份zoo_sample.cfg為zoo.cfg,修改配置

  添加配置:(預設不會自動創建,需要手動添加)

  dataDir=D:\\zookeeper\\data   
  dataLogDir=D:\\zookeeper\\log

  下載後windows下直接進入doc,進入zookeeper->bin目錄運行zkServer.cmd命令;

      可以用netstat -ano|findstr "2181"檢查是否啟動成功  

   TCP 0.0.0.0:2181 0.0.0.0:0 LISTENING 5716
  TCP 127.0.0.1:2181 127.0.0.1:53785 ESTABLISHED 5716
  TCP 127.0.0.1:53785 127.0.0.1:2181 ESTABLISHED 9752
  TCP [::]:2181 [::]:0 LISTENING 5716    

       也可用JPS查看:  

   8608 SmartGit
  8992 Jps
  5716 QuorumPeerMain
  9752 Bootstrap

 

3、啟動tomcat訪問:localhost:8080

 

 

 二、實踐步驟

#創建服務介面  

public interface DemoService {
    String sendMessage(String message);
}

#創建介面實現

public class DemoServiceImpl implements DemoService {
    @Override
    public String sendMessage(String message){
        System.out.println("this demoService get message:"+message);
        return "provirder return message success";
    }
}

#創建提供方spring配置文件provider.xml  

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans        http://www.springframework.org/schema/beans/spring-beans.xsd        http://code.alibabatech.com/schema/dubbo        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!-- 消費方應用名,用於計算依賴關係,不是匹配條件,不要與提供方一樣 -->
    <dubbo:application name="dubbo-demo-test"  />
    <!-- 使用zookeeper註冊中心暴露服務地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
    <!-- 生成遠程服務代理,可以和本地bean一樣使用demoService -->
    <dubbo:reference id="demoService" interface="com.demo.DemoService" />
</beans>

#創建提供方啟動程式:DemoProvider 

public class DemoProvider {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("provider.xml");
        context.start();
        System.out.println("provider started ...");
        System.in.read();
    }
}

#創建消費方spring配置文件consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans        http://www.springframework.org/schema/beans/spring-beans.xsd        http://code.alibabatech.com/schema/dubbo        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!-- 消費方應用名,用於計算依賴關係,不是匹配條件,不要與提供方一樣 -->
    <dubbo:application name="dubbo-demo-test"  />
    <!-- 使用zookeeper註冊中心暴露服務地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />
    <!-- 生成遠程服務代理,可以和本地bean一樣使用demoService -->
    <dubbo:reference id="demoService" interface="com.demo.DemoService" />
</beans>

#創建消費方方啟動程式:DemoConsumer   

public class DemoConsumer {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("consumer.xml");
        context.start();
        DemoService demoService = (DemoService) context.getBean("demoService");
        String returnMessage = demoService.sendMessage("consumer send message: hello my first dubbo service");
        System.out.println("provider return message:"+returnMessage);
    }
}

  

 #添加項目maven依賴

分別加入spring IOC,zkClient,dubbo依賴

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-core</artifactId>
    <version>3.0.5.RELEASE</version>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-context</artifactId>
    <version>3.0.5.RELEASE</version>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.5.3</version>
</dependency>
<dependency>
    <groupId>com.github.sgroschupf</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.1</version>
</dependency>

  

#啟動提供方服務,消費方進行調用

運行啟動提供方DemoProvider,啟動後進入待服務狀態

觀察dubbo admin發現已經剛纔的啟動服務在zookeepr成功註冊

 

這時消費方可以進行調用,運行DemoConsumer 

此時服務端收到請求:

調用方收到響應:

 

附上示例代碼:  http://files.cnblogs.com/files/yuxuan/dubbo-demo.rar

 


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

-Advertisement-
Play Games
更多相關文章
  • jQuery簡介 jQuery是一個快速、簡潔的JavaScript框架,是繼Prototype之後又一個優秀的JavaScript代碼庫(或JavaScript框架)。jQuery設計的宗旨是“write Less,Do More”,即倡導寫更少的代碼,做更多的事情。它封裝JavaScript常用 ...
  • Initialization & Cleanup ___ Guaranteed initialization with the constructor In Java, the class designer can guarantee initialization of every object b ...
  • Spring是SSH中的管理員,負責管理其它框架,協調各個部分的工作。今天一起學習一下Spring的事務管理。Spring的事務管理分為聲明式跟編程式。聲明式就是在Spring的配置文件中進行相關配置;編程式就是用註解的方式寫到代碼里。下麵先說聲明式: Spring配置文件中關於事務配置總是由三個組 ...
  • 前些陣子忙完了公司前端靜態頁面的事情了之後,簡單學習了下php的基礎知識,今天想了想回顧一下php連接資料庫的方式,寫一下隨筆存一下看看 php連接資料庫埠和新建資料庫 連接成功後,創建簡單的數據表 在連接資料庫的時候,要保證資料庫的伺服器埠是打開的,不然無法連接到,書寫代碼之前,可以使用nav ...
  • 1.DriverManager用來建立和資料庫的鏈接以及管理JDBC驅動程式 driverManager的常用方法 2.Connection代表Java程式和資料庫的連接 Connection的常用方法 3.Statement用來執行靜態的SQL語句。例如:對於insert,update和delet ...
  • 本視頻為activiti工作流的web流程設計器整合視頻教程 整合Acitiviti線上流程設計器(Activiti-Modeler 5.21.0 官方流程設計器) 本視頻共講了兩種整合方式 1. 流程設計器和其它工作流項目分開部署的方式 2. 流程設計器和SSM框架項目整合在一起的方式 視頻大小 ...
  • 多個中斷源在它們的搶占式優先順序相同的情況下,子優先順序不論是否相同,如果某個中斷已經在服務當中,則其它中斷源都不能打斷它;只有搶占式優先順序高的中斷才可以打斷其它搶占式優先順序低的中斷。 就是說, 組優先順序不同的時候高優先順序可以搶占低優先順序進程。 組優先順序相同的時候,子優先順序不能搶占。 ...
  • A 調用攝像頭拍照,自定義裁剪編輯頭像 B 集成代碼生成器 [正反雙向](單表、主表、明細表、樹形表,開發利器)+快速構建表單; 技術:313596790freemaker模版技術 ,0個代碼不用寫,生成完整的一個模塊,帶頁面、建表sql腳本,處理類,service等完整模塊C 集成阿裡巴巴資料庫連 ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...