[dubbo学习] 简单的dubbo功能

gaoyongstone

2020-06-05

关注关注

1.Dubbo结构图

[dubbo学习] 简单的dubbo功能

生产者-消费者模型，生产者和消费者都需要在注册中心进行注册，生产者生产接口，通过api暴露给消费者使用

注册中心管理服务提供方的url

监控模块负责监控管理整个流程

生产者(Provider)整个发布，订阅流程：

启动容器，加载，运行服务提供者
服务提供者在启动时，在注册中心发布注册自己提供的服务
服务消费者在启动时，在注册中心订阅自己所需的服务。

如果存在服务失败或者变更的情况，Dubbo就进行如下的操作：

注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

2.Dubbo实例

2.1 zookeeper

2.1.1 zookeeper 下载

zookeeper下载:https://zookeeper.apache.org/releases.html

[dubbo学习] 简单的dubbo功能

2.1.2 zookeeper安装

windows 安装

1.解压下载的压缩包

2.修改 zoo_sample.cfg 为 zoo.cfg

[dubbo学习] 简单的dubbo功能

3.bin目录下启动 zkServer.cmd

Linux 安装

1.解压下载的压缩包

2.修改 zoo_sample.cfg 为 zoo.cfg

3.修改zoo.cfg

# The number of milliseconds of each tick
tickTime=2000
# The number of ticks that the initial 
# synchronization phase can take
initLimit=10
# The number of ticks that can pass between 
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.
# do not use /tmp for storage, /tmp here is just 
# example sakes.
dataDir=/home/tjtl/dubbo/apache-zookeeper-3.6.1-bin/data
# the port at which the clients will connect
clientPort=2181
# the maximum number of client connections.
# increase this if you need to handle more clients
#maxClientCnxns=60
#
# Be sure to read the maintenance section of the 
# administrator guide before turning on autopurge.
#
# http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
#
# The number of snapshots to retain in dataDir
#autopurge.snapRetainCount=3
# Purge task interval in hours
# Set to "0" to disable auto purge feature
#autopurge.purgeInterval=1
admin.serverPort=8888
## Metrics Providers
#
# https://prometheus.io Metrics Exporter
#metricsProvider.className=org.apache.zookeeper.metrics.prometheus.PrometheusMetricsProvider
#metricsProvider.httpPort=7000
#metricsProvider.exportJvmInfo=true


server.1=zoo1:2888:3888

4.在 /home/tjtl/dubbo/apache-zookeeper-3.6.1-bin/ 目录下建立文件夹data

mkdir /home/tjtl/dubbo/apache-zookeeper-3.6.1-bin/data

5.在第4步建立的文件夹下建立文件myid

6.执行命令

echo “1” > myid

"1" 对应 zoo.cfg 文件中 “server.1” 中的 “1"

7.在bin目录下启动

./zkServer.sh start-foreground

Linux 下安装遇到问题处理

1.报错 java.net.SocketException:Unresolved address

　　处理: 在/etc/hosts中配置主机映射

127.0.0.1 master

　　 [dubbo学习] 简单的dubbo功能

2.2 dubbo-admin安装

下载Url https://github.com/apache/dubbo

修改/dubbo-admin-2.5.4/WEB-INF/dubbo.properties

dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.admin.root.password=root
dubbo.admin.guest.password=guest

使用maven自己手动打包mvn package -Dmaven.skip.test=true

将war包放入tomcat下，执行tomcat

访问url:http://127.0.0.1:8090/dubbo-admin-2.5.4

访问用户名:root

访问密码:root

[dubbo学习] 简单的dubbo功能

2.3 dubbo 生产者消费者 API

项目目录

[dubbo学习] 简单的dubbo功能

API提供生产者的接口暴露，生产者在service中实现暴露接口，消费者通过controller进行消费

springboot-dubbo.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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>springboot-dubbo</groupId>
    <artifactId>springboot-dubbo</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>

    <modules>
        <module>dubbo-api</module>
        <module>dubbo-provider</module>
        <module>dubbo-consumer</module>
    </modules>

</project>

2.3.1 创建生产者

[dubbo学习] 简单的dubbo功能

生产者在service中进行接口实现

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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.soft</groupId>
    <artifactId>dubbo-provider</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>dubbo-provider</name>
    <description>dubbo-provider</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

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

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

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

        <!--服务提供者的接口API-->
        <dependency>
            <groupId>com.soft</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>v1.0</version>
        </dependency>

        <!-- dubbo依赖 -->
        <dependency>
            <groupId>com.alibaba.spring.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.0.0</version>
        </dependency>

        <!-- 引入zookeeper的依赖 -->
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

application.properties

############### dubbo 配置 ###############################
# 端口
server.port=9011
spring.dubbo.application.name=dubbo-provider
spring.dubbo.application.registry=zookeeper://IP:2181

DubboProviderApplication.java

package com.soft.provider;

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@EnableDubboConfiguration //开启Dubbo的自动配置
@SpringBootApplication
public class DubboProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(DubboProviderApplication.class, args);
    }

}

ProviderDemoImpl.java

package com.soft.provider.service;

import com.alibaba.dubbo.config.annotation.Service;
import com.soft.api.service.IProviderDemo;
import org.springframework.stereotype.Component;

/**
 * dubbo 服务层测试
 * @author suphowe
 */
//使用com.alibaba.dubbo.config.annotation.Service,作用是暴露服务,不要使用Spring中的@Service
@Service
@Component
public class ProviderDemoImpl implements IProviderDemo {

    @Override
    public String providerReturnString(String name) {
        return "Provider Return:".concat(name);
    }

}

2.3.2 创建消费者

[dubbo学习] 简单的dubbo功能

消费者在controller中进行消费

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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <groupId>com.soft</groupId>
    <artifactId>dubbo-consumer</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>dubbo-consumer</name>
    <description>dubbo-consumer</description>

    <properties>
        <java.version>1.8</java.version>
    </properties>

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

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

        <!--服务提供者的接口API-->
        <dependency>
            <groupId>com.soft</groupId>
            <artifactId>dubbo-api</artifactId>
            <version>v1.0</version>
        </dependency>

        <!-- dubbo依赖 -->
        <dependency>
            <groupId>com.alibaba.spring.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.0.0</version>
        </dependency>

        <!-- 引入zookeeper的依赖 -->
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

application.properties

############### dubbo 配置 ###############################
# 端口
server.port=9021
spring.dubbo.application.name=dubbo-consumer
spring.dubbo.application.registry=zookeeper://Ip:2181

DubboConsumerApplication.java

package com.soft.consumer;

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@EnableDubboConfiguration //开启Dubbo的自动配置
@SpringBootApplication
public class DubboConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(DubboConsumerApplication.class, args);
    }

}

ConsumerController.java

package com.soft.consumer.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.soft.api.service.IProviderDemo;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ConsumerController {

    @Reference
    private IProviderDemo providerDemo;

    @RequestMapping(value = "/callInterfase")
    public String callInterfase() {
        String hello = providerDemo.providerReturnString("consumer test ");
        System.out.println(providerDemo.providerReturnString("consumer print "));
        return hello;
    }
}

2.3.3 创建API

[dubbo学习] 简单的dubbo功能

API提供生产者暴露的接口

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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>springboot-dubbo</groupId>
        <artifactId>springboot-dubbo</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>

    <groupId>com.soft</groupId>
    <artifactId>dubbo-api</artifactId>
    <version>v1.0</version>


</project>

IProviderDemo.java

package com.soft.api.service;

public interface IProviderDemo {

    String providerReturnString(String name);
}

2.4 测试

依次启动生产者和消费者

[dubbo学习] 简单的dubbo功能

范围http://127.0.0.1:9021/callInterfase

[dubbo学习] 简单的dubbo功能

查看http://127.0.0.1:8090/dubbo-admin-2.5.4/

[dubbo学习] 简单的dubbo功能

Success!

dubbo https

gaoyongstone

0 关注 0 粉丝 0 动态

关注关注

Dubbo中的时间轮(Time Wheel)算法应用

Netty、Quartz、Kafka 以及 Linux 都有定时任务功能。在任务量大、性能要求高的场景，为了将任务存取及取消操作时间复杂度降为 O，会采用时间轮算法。指针周期性跳动，跳动到一个槽位，就执行该槽位的定时任务。需要高效的定时器算法以减少总体中断

ATenhong 2020-10-15

女朋友问我：Dubbo的服务引用过程

本文转载自微信公众号「三太子敖丙」，作者三太子敖丙。这篇文章我就带着大家再来看看 Dubbo 服务引入全流程，这篇服务引入写完下一篇就要来个全链路打通了，看看大家看完会不会有种任督二脉都被打通的感觉。在写文章的过程中丙还发现官网的一点小问题，下文中会提

supperme 2020-09-08

Java 200+ 面试题补充③ Dubbo 模块

今天 Java 面试粉丝群里，一个一年开发经验的小伙伴只用了三天时间，找了一个 13 薪 1.5 万的工作，真是替他感到开心。高兴之余，让我们来看，今天的内容。本文是 Java 最常见的 200+ 面试题的第三个补充模块。Dubbo 是一款高性能、轻量级

doctorvian 2020-08-02

上线前一个小时，dubbo这个问题可把我折腾惨了

前因那是一个月黑风高的夜晚，不管有没有圆圆的月亮，都无法解救要加班的我。这就是苦涩的人生啊！那天正好是春节回家的日子，定了晚上的票，然后还是上线的日子。测试在做回归测试的时候，发现一个老功能报错了，什么鬼，都没改过那块代码怎么会出问题？案件疑点重重呀。。。

aNian 2020-08-01

Dubbo不用注册中心实现远程调用的简单用法demo

return "Hello ,liaoyang make you see " + msg;

gaoyongstone 2020-07-05

微服务架构框架？这里为你汇总了15种

2019年有一个统计说，两千家企业里，45%在使用微服务，16%在实验开发和测试微服务架构，24%在学习微服务准备转型，只有剩下的15%的企业没有使用微服务。对于中大型架构系统来说，微服务更加便捷，微服务成为很多企业架构重构的方向，同时也对架构师提出更高的

kongjunlongaa 2020-06-29

Dubbo telnet 命令能做什么？

dubbo 服务发布之后，我们可以利用 telnet 命令进行调试、管理。telnet localhost 20880 //键入回车进入 Dubbo 命令模式。ls -l XxxService：显示服务的方法详细信息列表。

Fightingxr 2020-06-26

spring cloud 知识点

spring cloud 是一系列框架的有序集合。它利用 spring boot 的开发便利性巧妙地简化了分布式系统基础设施的开发，如服务发现注册、配置中心、消息总线、负载均衡、断路器、数据监控等，都可以用 spring boot 的开发风格做到一键启动和

whileinsist 2020-06-24

Dubbo-扩展机制-SPI

从上面可以看出Java中的SPI最大的缺点是会加载一些不必要的组件。ExtensionLoader类是扩展加载器，这是dubbo实现SPI扩展机制等核心，几乎所有实现的逻辑都被封装在ExtensionLoader中

doctorvian 2020-06-16

Dubbo-URL、数据包结构

在 dubbo 中，也使用了类似的 URL，主要用于在各个扩展点之间传递数据，组成此 URL 对象的具体参数如下:. 基于扩展点自适应机制，通过 URL 的 registry:// 协议头识别，就会调用 RegistryProtocol 的 export(

XuNeely 2020-06-16

Dubbo-服务提供者初始化

事件发布，执行onApplicationEvent，开始执行ServiceBean暴露export操作。当Spring容器处理完<dubbo:service>标签后，会在Spring容器中生成一个ServiceBean ，服务的发布也会在Ser

wangyangsoftware 2020-06-16

Dubbo-服务暴露流程

zk节点上生成providers节点的过程。// FIXME When the provider subscribes, it will affect the scene : a certain JVM exposes the service and ca

大步流星 2020-06-16

Dubbo-服务消费者远程调用

* 这里输入编号 3，让 Arthas 关联到启动类为 com.....Consumer 的 Java 进程上。* 3. 由于 Demo 项目中只有一个服务接口，因此此接口的代理类类名为 proxy0，此时使用 sc 命令搜索这个类名。public cla

aNian 2020-06-16

涂鸦智能 dubbo-go 亿级流量的实践与探索

潘天颖，Github ID @pantianying，开源爱好者，就职于涂鸦智能。dubbo 是一个基于 Java 开发的高性能的轻量级 RPC 框架，dubbo 提供了丰富的服务治理功能和优秀的扩展能力。而 dubbo-go 在 java 与 golan

gaoyongstone 2020-06-16

9.实战交付一套dubbo微服务到k8s集群(2)之Jenkins部署

[200 ~]# ssh-keygen -t rsa -b 2048 -C "" -N "" -f /root/.ssh/id_rsa

MartellJenkins 2020-06-11

Dubbo学习

前言为什么要学Dubbo什么是RPCDubbo的产生背景单一应用架构垂直应用架构分布式服务架构流动计算架构Dubbo面临的需求Dubbo的架构Demo time新建一个maven项目提供服务的API提供服务的provider消费服务的consumer参考。

范群松 2020-06-11

Dubbo 迈出云原生重要一步 - 应用级服务发现解析

社区版本 Dubbo 从 2.7.5 版本开始，新引入了一种基于实例（应用）粒度的服务发现机制，这是我们为 Dubbo 适配云原生基础设施的一步重要探索。在最开始的社区版本，我们给这个机制取了一个神秘的名字 - 服务自省，下文将进一步解释这个名字的由来，并

Fightingxr 2020-06-08

线程隔离浅析

随着微服务的流行，单体应用被拆分成一个个独立的微进程，可能一个简单的请求，需要多个微服务共同处理，这样其实是增加了出错的概率，所以如何保证在单个微服务出现问题的时候，对整个系统的负面影响降到最低，这就需要用到我们今天要介绍的线程隔离。connection在

XuNeely 2020-06-07

SPI

SPI 全称为 Service Provider Interface，是一种服务发现机制。SPI 的本质是将接口实现类的全限定名配置在文件中，并由服务加载器读取配置文件，加载实现类。正因此特性，我们可以很容易的通过 SPI 机制为我们的程序提供拓展功能。D

大步流星 2020-06-05

dubbo 整合ssm配置

-- 配置本地存根-->. --声明需要调用的远程服务的接口；生成远程服务代理 -->. -- retries="":重试次数，不包含第一次调用，0代表不重试-->. -- 幂等、非幂等 -->. -- 配置

aNian 2020-06-03

安科网

[dubbo学习] 简单的dubbo功能

gaoyongstone

1.Dubbo结构图

2.Dubbo实例

2.1 zookeeper

2.1.1 zookeeper 下载

2.1.2 zookeeper安装

Linux 安装

2.2 dubbo-admin安装

2.3 dubbo 生产者消费者 API

2.3.1 创建生产者

2.3.2 创建消费者

2.3.3 创建API

2.4 测试

gaoyongstone

相关推荐

Dubbo中的时间轮(Time Wheel)算法应用

女朋友问我：Dubbo的服务引用过程

Java 200+ 面试题补充③ Dubbo 模块

上线前一个小时，dubbo这个问题可把我折腾惨了

Dubbo不用注册中心实现远程调用的简单用法demo

微服务架构框架？这里为你汇总了15种

Dubbo telnet 命令能做什么？

spring cloud 知识点

Dubbo-扩展机制-SPI

Dubbo-URL、数据包结构

Dubbo-服务提供者初始化

Dubbo-服务暴露流程

Dubbo-服务消费者远程调用

涂鸦智能 dubbo-go 亿级流量的实践与探索

9.实战交付一套dubbo微服务到k8s集群(2)之Jenkins部署

Dubbo学习

Dubbo 迈出云原生重要一步 - 应用级服务发现解析

线程隔离浅析

SPI

dubbo 整合ssm配置

gaoyongstone

[dubbo学习] 简单的dubbo功能

1.Dubbo结构图

2.Dubbo实例

2.1 zookeeper

2.1.1 zookeeper 下载

2.1.2 zookeeper安装

Linux 安装

2.2 dubbo-admin安装

2.3 dubbo 生产者 消费者 API

2.3.1 创建生产者

2.3.2 创建消费者

2.3.3 创建API

2.4 测试

相关推荐

2.3 dubbo 生产者消费者 API