2. 程式人生 > >分散式系統_程序間通訊_dubbo使用入門

分散式系統_程序間通訊_dubbo使用入門

阿新 • • 發佈：2019-01-29

Dubbo簡介

DUBBO是一個分散式服務框架，致力於提供高效能和透明化的RPC遠端服務呼叫方案，是阿里巴巴SOA服務化治理方案的核心框架，每天為2,000+個服務提供3,000,000,000+次訪問量支援，並被廣泛應用於阿里巴巴集團的各成員站點。

Dubbo RPC框架不同於一般的RPC框架的地方在於，Dubbo RPC的目的在於實現SOA服務的治理和服務管理。其通過服務註冊中心來發現服務，並通過服務中心來分發服務來實現服務的負載均衡，通過服務發現來解耦服務，使得整個服務能力可以高效地進行擴充套件。

Dubbo使用入門

本章節結合Spring Boot 1.3.12.RELEASE和Dubbo來講解，Dubbo的使用說明。Dubbo　RPC的基本結構中包括了，服務提供者和服務消費者。下面分別從服務提供者和服務消費者來說明。

dubbo-provider

基本的程式碼結構說明

dubbo-provider
    src 
      main
        com.egoo
            service
                Demo.java
                DemoImpl.java
            Application.java
      resources
        dubbo
            provider.xml

pom.xml

<?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>com.egoo</groupId>
    <artifactId
 
>dubbo-provider</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <java.version>1.7</java.version>
        <dubbo.version>2.4.10</dubbo.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-logging</artifactId>
        </dependency>

        <!-- RPC -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo.version}</version>
            <exclusions>
                <exclusion>
                    <artifactId>spring</artifactId>
                    <groupId>org.springframework</groupId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
                <version>1.3.2.RELEASE</version>
                <scope>import</scope>
                <type>pom</type>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>1.3.2.RELEASE</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.1</version>
                <configuration>
                    <fork>true</fork>
                    <meminitial>512m</meminitial>
                    <maxmem>1048m</maxmem>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

應用配置
resources->dubbo->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="DemoProvider"  />

    <!-- 使用multicast廣播註冊中心暴露服務地址 -->
    <dubbo:registry address="multicast://224.5.6.7:1234" />

    <!-- 用dubbo協議在20880埠暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880" />

    <bean id="demoImpl" class="com.egoo.service.DemoImpl" />

    <!-- service -->
    <!--將介面暴露給服務中心-->
    <dubbo:service interface="com.egoo.service.Demo" version="1.0.0" ref="demoImpl"  id="demo" />

</beans>

建立對應的服務

服務介面
package com.egoo.service;

/**
 * Created by fiboliu on 16-5-3.
 */
public interface Demo {

    String greeting(String message);
}
服務實現
package com.egoo.service;

/**
 * Created by fiboliu on 16-5-3.
 */
public class DemoImpl implements Demo {

    public String greeting(String message) {

        return message;
    }
}

Application.java //main function

package com.egoo;

import org.springframework.boot.SpringApplication;
import org.springframework.context.annotation.ImportResource;

import java.io.IOException;

/**
 * Created by fiboliu on 16-5-3.
 */
@ImportResource({"classpath:dubbo/provider.xml"})
public class Application {

    public static void main(String args[]) {

        SpringApplication.run(Application.class, args);

        try {

            System.out.println("啟動成功,按任意鍵關閉");
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

dubbo-consumer

基本的程式碼結構說明

dubbo-consumer
    src 
      main
        com.egoo
            service
                Demo.java
            Application.java
      resources
        dubbo.properties
        dubbo
            consumer.xml

pom.xml

<?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>com.egoo</groupId>
    <artifactId>dubbo-consumer</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <java.version>1.7</java.version>
        <dubbo.version>2.4.10</dubbo.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-logging</artifactId>
        </dependency>

        <!-- RPC -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo.version}</version>
            <exclusions>
                <exclusion>
                    <artifactId>spring</artifactId>
                    <groupId>org.springframework</groupId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
                <version>1.3.2.RELEASE</version>
                <scope>import</scope>
                <type>pom</type>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <version>1.3.2.RELEASE</version>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.1</version>
                <configuration>
                    <fork>true</fork>
                    <meminitial>512m</meminitial>
                    <maxmem>1048m</maxmem>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

resources檔案
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="DemoConsumer"  />

    <!-- 使用multicast廣播註冊中心暴露服務地址 -->
    <dubbo:registry address="multicast://224.5.6.7:1234" />

    <!-- 用dubbo協議在20880埠暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880" />

    <dubbo:reference id="demo" interface="com.egoo.service.Demo" version="1.0.0" />

</beans>

dubbo.properties

##
# Copyright 1999-2011 Alibaba Group.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#      http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
##
dubbo.container=log4j,spring
dubbo.application.name=consumer
dubbo.application.owner=egoo
dubbo.registry.address=multicast://224.5.6.7:1234
#dubbo.registry.address=zookeeper://127.0.0.1:2181
#dubbo.registry.address=redis://127.0.0.1:6379
#dubbo.registry.address=dubbo://127.0.0.1:9090
#dubbo.monitor.protocol=registry
dubbo.log4j.file=logs/dubbo-demo-consumer.log
dubbo.log4j.level=WARN

介面檔案(保證和provider介面檔案一致)

package com.egoo.service;

/**
 * Created by fiboliu on 16-5-3.
 */
public interface Demo {

    String greeting(String message);
}

Application.java

package com.egoo;

import com.egoo.service.Demo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.ImportResource;

/**
 * Created by fiboliu on 16-5-3.
 */
@SpringBootApplication
@ImportResource({"classpath:dubbo/consumer.xml"})
public class Application {

    public static void main(String args[]) {
        ApplicationContext context = SpringApplication.run(Application.class, args);
        Demo demo = (Demo) context.getBean("demo");
        System.out.println(demo.greeting("hello world!!"));
    }

}

相關推薦

分散式系統_程序間通訊_dubbo使用入門

Dubbo簡介 DUBBO是一個分散式服務框架，致力於提供高效能和透明化的RPC遠端服務呼叫方案，是阿里巴巴SOA服務化治理方案的核心框架，每天為2,000+個服務提供3,000,000,000+次訪問量支援，並被廣泛應用於阿里巴巴集團的各成員站點。 Dub

Linux系統程式設計——程序間通訊：共享記憶體

概述 共享記憶體是程序間通訊中最簡單的方式之一。共享記憶體允許兩個或更多程序訪問同一塊記憶體，就如同 malloc() 函式向不同程序返回了指向同一個實體記憶體區域的指標。當一個程序改變了這塊地址中的內容的時候，其它程序都會察覺到這個更改。 共享記憶體的特點： 1）共

Linux系統程式設計——程序間通訊：訊息佇列

概述 訊息佇列提供了一種在兩個不相關的程序之間傳遞資料的簡單高效的方法，其特點如下： 1）訊息佇列可以實現訊息的隨機查詢。訊息不一定要以先進先出的次序讀取，程式設計時可以按訊息的型別讀取。 2）訊息佇列允許一個或多個程序向它寫入或者讀取訊息。 3）與無名管道、命名管道一

Linux系統程式設計——程序間通訊：管道（pipe）

管道的概述 管道也叫無名管道，它是是 UNIX 系統 IPC（程序間通訊） 的最古老形式，所有的 UNIX 系統都支援這種通訊機制。 無名管道有如下特點： 1、半雙工，資料在同一時刻只能在一個方向上流動。 2、資料只能從管道的一端寫入，從另一端讀出。

Linux系統程式設計——程序間通訊：訊號中斷處理

什麼是訊號？ 訊號是 Linux 程序間通訊的最古老的方式。訊號是軟體中斷，它是在軟體層次上對中斷機制的一種模擬，是一種非同步通訊的方式 。訊號可以導致一個正在執行的程序被另一個正在執行的非同步程序中斷，轉而處理某一個突發事件。 “中斷”在我們生活中經常遇到，譬如，我正在

Linux系統程式設計——程序間通訊概述

程序是一個獨立的資源分配單元，不同程序（這裡所說的程序通常指的是使用者程序）之間的資源是獨立的，沒有關聯，不能在一個程序中直接訪問另一個程序的資源（例如開啟的檔案描述符）。 但是，程序不是孤立的，不同的程序需要進行資訊的互動和狀態的傳遞等，因此需要程序間通訊( IPC：Inter Pr

Linux系統下-程序間通訊（訊息佇列-詳解）

Linux下程序間通訊方式： # 管道( pipe )：管道是一種半雙工的通訊方式，資料只能單向流動，而且只能在具有親緣關係的程序間使用。程序的親緣關係通常是指父子程序關係。 # 有名管道 (named pipe) ： 有名管道也是半雙工的通訊方式，但是它允許無親緣關係程序

程序間通訊——共享記憶體（Shared Memory）簡易原理和建立_獲得函式

共享記憶體是System V版本的最後一個程序間通訊方式。共享記憶體，顧名思義就是允許兩個不相關的程序訪問同一個邏輯記憶體，共享記憶體是兩個正在執行的程序之間共享和傳遞資料的一種非常有效的方式。不同程序之間共享的記憶體通常為同一段實體記憶體。程序可以將同一段實體記憶體連線到他們自己的地址空間中，所有

Android系統程序間通訊 IPC 機制Binder中的Server啟動過程原始碼分析

                        在前面一篇文章中，介紹了在Android系統中Binder程序間通訊機制中的Server角色是如何獲得Service Manager遠端介面的，即defaultServiceManager函式的實現。Server獲得了Service Manager遠端介面之後，

Android 8.0系統原始碼分析--Binder程序間通訊（一）

 開始我們的沉澱之路，老羅的書中第二章講的是Android HAL層的知識，而且直接自己實現了一個虛擬的freg驅動程式，後面的幾節是分別從native、java層如何訪問這個虛擬的驅動程式介面，我這裡沒有這樣的環境，所以就不分析這節了，第三章的智慧指標我對比8.0系統原

linux 系統下使用socket進行本地程序間通訊

使用套接字除了可以實現網路間不同主機間的通訊外，還可以實現同一主機的不同程序間的通訊，且建立的通訊是雙向的通訊。socket程序通訊與網路通訊使用的是統一套介面，只是地址結構與某些引數不同。 其主要流程如下： 程式碼實現如下： 客戶端：

程序與系統呼叫、程序間通訊--Head First C讀書筆記

程序與系統呼叫 程序 程序是儲存器中執行的程式。Windows通過taskmgr檢視，Linux通過ps -ef檢視系統中執行的程序。作業系統用一個數字來標識程序，它叫程序識別符號(process identifier，簡稱PID)。 system()

Linux 系統應用程式設計——程序間通訊（下）

        在前面，我們學習了傳統的程序間通訊方式——無名管道（pipe）、有名管道（fifo）和訊號（signal）。         下面我們來學習 System V  IPC 物件： 1、共享記憶體（share memory）； 2、訊號燈（semaohore）；

Python 之小白的系統程序的理解之程序間通訊

程序間通訊-QueueProcess之間有時需要通訊，作業系統提供了很多機制來實現程序間的通訊。1. Queue的使⽤可以使⽤multiprocessing模組的Queue實現多程序之間的資料傳遞，Queue本身是⼀個訊息列隊程式，⾸先⽤⼀個⼩例項來演示⼀下Queue的⼯作原

Linux 系統應用程式設計——程序間通訊（上）

       現在再Linux應用較多的程序間通訊方式主要有以下幾種： 1）無名管道（pipe）及有名管道（fifo）：無名管道可用於具有親緣關係程序間的通訊；有名管道除具有管道相似的功能外，它還允許無親緣關係程序使用； 2）訊號（signal）：訊號是在軟體層次上對中斷機

java：程序間通訊的方式

程序間通訊的方式有哪些，各有什麼優缺點： 1）管道：管道是一種半雙工的通訊方式，資料只能單向流動，而且只能在具有親緣關係的程序之間使用。程序的親緣關係通常是指父子程序關係。 2）有名管道（FIFO）：有名管道也是半雙工的通訊方式，但是允許在沒有親緣關係的程序之間使用，管道是先進先出的通訊方式

一、程序間通訊概述

轉：https://blog.csdn.net/gatieme/article/details/50908749 另一篇更詳細：https://www.cnblogs.com/LUO77/p/5816326.html 沒有轉載這篇，是因為這篇博文描述的太詳細，，，後面有需要再進一步深入

iOS--CFMessagePort實現程序間通訊

CFMessagePort屬於CoreFoundation框架中的類。因此可以在http://opensource.apple.com/tarballs/CF/CF-855.17.tar.gz中在原始碼，如果感興趣可以去看看。 下面說下CFMessagePortRef的具體使用。 首先建立一

android程序間通訊--Binder

深入理解之程序間通訊–Binder 同一個程式中的兩個方法能夠直接呼叫的根本原因是處於相同的記憶體空間中。兩個不同的應用程式因為不在同一個程序中，他們是沒有辦法直接通過記憶體地址來訪問到對方的函式和變數的。同一個程序中物件的傳遞是傳遞的記憶體地址，這個地址並不是真正的實體地址，而是邏

Linux程序間通訊（IPC）方式總結

程序間通訊概述 程序通訊的目的 資料傳輸  一個程序需要將它的資料傳送給另一個程序，傳送的資料量在一個位元組到幾M位元組之間 共享資料  多個程序想要操作共享資料，一個程序對共享資料 通知事件 一個程序需要向另一個或一組程序傳送訊息，通知它（它們）