AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

分布式系统_进程间通信_dubbo使用入门

2016-05-03 1245
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： Dubbo简介DUBBO是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，是阿里巴巴SOA服务化治理方案的核心框架，每天为2,000+个服务提供3,000,000,000+次访问量支持，并被广泛应用于阿里巴巴集团的各成员站点。Dubbo RPC框架不同于一般的RPC框架的地方在于，Dubbo RPC的目的在于实现SOA服务的治理和服务管理。其通过

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
Java
Apache
数据格式
NoSQL
负载均衡
Redis
Spring
XML
关键词：
分布式入门
Dubbo入门
分布式系统Dubbo
分布式dubbo入门
Dubbo分布式系统
fibojie
目录
相关文章
1176112968452250
|
2月前
|
安全 应用服务中间件 API
微服务分布式系统架构之zookeeper与dubbo-2
微服务分布式系统架构之zookeeper与dubbo-2
1176112968452250
72 1
郑小健
|
3月前
|
存储 SQL 分布式数据库
OceanBase 入门：分布式数据库的基础概念
【8月更文第31天】在当今的大数据时代，随着业务规模的不断扩大，传统的单机数据库已经难以满足高并发、大数据量的应用需求。分布式数据库应运而生，成为解决这一问题的有效方案之一。本文将介绍一款由阿里巴巴集团自主研发的分布式数据库——OceanBase，并通过一些基础概念和实际代码示例来帮助读者理解其工作原理。
郑小健
322 0
技术自由圈/原疯狂创客圈
|
1月前
|
Dubbo Java 应用服务中间件
Dubbo学习圣经：从入门到精通 Dubbo3.0 + SpringCloud Alibaba 微服务基础框架
尼恩团队的15大技术圣经，旨在帮助开发者系统化、体系化地掌握核心技术，提升技术实力，从而在面试和工作中脱颖而出。本文介绍了如何使用Dubbo3.0与Spring Cloud Gateway进行整合，解决传统Dubbo架构缺乏HTTP入口的问题，实现高性能的微服务网关。
技术自由圈/原疯狂创客圈
176 5
技术自由圈/原疯狂创客圈
|
1月前
|
消息中间件 关系型数据库 Java
‘分布式事务‘ 圣经：从入门到精通，架构师尼恩最新、最全详解 (50+图文4万字全面总结 )
本文 是 基于尼恩之前写的一篇 分布式事务的文章 升级而来 ， 尼恩之前写的 分布式事务的文章， 在全网阅读量 100万次以上 ， 被很多培训机构 作为 顶级教程。 此文修改了 老版本的 一个大bug ， 大家不要再看老版本啦。
技术自由圈/原疯狂创客圈
131 2
1176112968452250
|
2月前
|
负载均衡 监控 Dubbo
分布式框架-dubbo
分布式框架-dubbo
1176112968452250
32 5
1176112968452250
|
2月前
|
Dubbo Java 应用服务中间件
分布式-dubbo的入门
分布式-dubbo的入门
1176112968452250
29 4
1176112968452250
|
2月前
|
存储 Dubbo 应用服务中间件
分布式-Dubbo-Dubbo的由来
分布式-Dubbo-Dubbo的由来
1176112968452250
35 4
1176112968452250
|
2月前
|
XML 负载均衡 监控
分布式-dubbo-简易版的RPC框架
分布式-dubbo-简易版的RPC框架
1176112968452250
34 0
1176112968452250
|
2月前
|
负载均衡 监控 Dubbo
分布式-Dubbo-dubbo能解决什么问题
分布式-Dubbo-dubbo能解决什么问题
1176112968452250
23 0
郑小健
|
3月前
|
机器学习/深度学习 并行计算 PyTorch
PyTorch与DistributedDataParallel：分布式训练入门指南
【8月更文第27天】随着深度学习模型变得越来越复杂，单一GPU已经无法满足训练大规模模型的需求。分布式训练成为了加速模型训练的关键技术之一。PyTorch 提供了多种工具来支持分布式训练，其中 DistributedDataParallel (DDP) 是一个非常受欢迎且易用的选择。本文将详细介绍如何使用 PyTorch 的 DDP 模块来进行分布式训练，并通过一个简单的示例来演示其使用方法。
郑小健
343 2

热门文章

最新文章

  • 1
    Kubernetes上的服务网格 Istio - 分布式追踪篇
  • 2
    AgileEAS.NET SOA 中间件平台5.2版本下载、配置学习(二)：配置WinClient分布式运行环境
  • 3
    蚂蚁架构师郭援非：分布式数据库是金融机构数字化转型的最佳路径
  • 4
    WCF分布式安全开发实践(8):消息安全模式之用户名身份验证:Message_UserName_WSHttpBinding
  • 5
    Memcache分布式部署方案
  • 6
    在PyTorch中使用DistributedDataParallel进行多GPU分布式模型训练
  • 7
    【分布式】分布式事务基础概念（2PC，3PC，TCC）
  • 8
    实战！阿里神器 Seata 实现 TCC模式 解决分布式事务，真香！
  • 9
    WCF分布式安全开发实践(5):传输安全模式之Certificate身份验证:Transport_Certificate_WSHttpBinding
  • 10
    服务器内部分布式图片取得
  • 1
    Python中的并发编程：理解多线程与多进程的区别与应用
    48
  • 2
    `subprocess`模块是Python中用于生成新进程、连接到它们的输入/输出/错误管道，并获取它们的返回（退出）代码的模块。
    58
  • 3
    在Python中，`multiprocessing`模块提供了一种在多个进程之间共享数据和同步的机制。
    57
  • 4
    `multiprocessing`是Python的一个标准库，用于支持生成进程，并通过管道和队列、信号量、锁和条件变量等同步原语进行进程间通信（IPC）。
    30
  • 5
    Python的`signal`模块提供了访问底层操作系统提供的信号机制的方式。信号是操作系统用来通知进程发生了某种情况（如用户按下Ctrl+C）的一种机制。
    41
  • 6
    linux进程状态基本语法
    39
  • 7
    【Linux】多线程——线程概念|进程VS线程|线程控制（下）
    69
  • 8
    【Linux】多线程——线程概念|进程VS线程|线程控制（上）
    72
  • 9
    【Linux】进程信号（下）
    41
  • 10
    【Linux】进程信号（上）
    47

    • 相关课程

    更多
  • Dubbo开源、自研、商业化三位一体战略解读
  • Spring Boot+Vue.js+FastDFS实现分布式图片服务器
  • 基于Zookeeper、Dubbo构建互联网分布式基础架构
  • 分布式文件存储系统技术及实现
  • 分布式协调系统 Zookeeper 快速入门
  • Dubbo分布式服务治理实战

    • 相关电子书

    更多
  • 基于社区的分布式 风险感知模型
  • 如何利用Redisson分布式化传统Web项目
  • FLASH:大规模分布式图计算引擎及应用

    • 相关实验场景

    更多
  • 体验PolarDB-X透明分布式
  • 观察进程的并发性
  • 快速玩转Dubbo生态之一致性事务篇（Seata）
  • 快速玩转Dubbo生态之限流降级篇（Sentinel）
  • 快速上手使用Dubbo进行远程调用
  • Spring-cloud-bus-rocketmq入门与实践
    • 下一篇
    手把手教你白嫖阿里云服务器(免费领服务器)