dubbo入门

Posted 2020-09-18 xuyatao

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了dubbo入门相关的知识，希望对你有一定的参考价值。

1. 学习大纲

1、了解什么是dubbo？

2、我们使用dubbo能做什么？

3、 Dubbo入门

4、 Dubbo管理

2. 什么是dubbo？

2.1. 简介

DUBBO是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，是阿里巴巴SOA服务化治理方案的核心框架，每天为2,000+个服务提供3,000,000,000+次访问量支持，并被广泛应用于阿里巴巴集团的各成员站点。

Dubbo是Alibaba开源的分布式服务框架，它最大的特点是按照分层的方式来架构，使用这种方式可以使各个层之间解耦合（或者最大限度地松耦合）。从服务模型的角度来看，Dubbo采用的是一种非常简单的模型，要么是提供方提供服务，要么是消费方消费服务，所以基于这一点可以抽象出服务提供方（Provider）和服务消费方（Consumer）两个角色。关于注册中心、协议支持、服务监控等内容。

2.2. RPC

2.3. 官网

http://dubbo.io/

2.4. 版本说明

我们使用2.5.3版本。

2.5. 下载

Dubbo官网并没有提供下载服务，但是dubbo将源码托管于github，并且将jar包发布到maven的中央仓库，所以可以从github和maven中央仓库来下载。

2.5.1. 源码下载

https://github.com/alibaba/dubbo

2.5.2. 发布包下载

http://repo1.maven.org/maven2/com/alibaba/dubbo/

3. 通过Maven构建dubbo（非必须）

既然可以下载得到源码以及发布包，那么为什么要去构建dubbo呢？，我们先来看下dubbo的主要模块：

其中，核心框架、管理控制台、简易监控中心、简易注册中心是我们需要的模块，目前，只有核心模块可以下载到，其它的均无法直接下载，所以我们需要构建dubbo。

当然了，在提供的资料中以及有构建好的模块提供，也可以选择不重新构建。

3.1. 导入源码到Eclipse

先导入编译依赖到Eclipse：

再导入dubbo源码到Eclipse：

导入完成：

3.2. 安装hessian-lite到本地仓库

3.3. 安装opensesame到本地仓库

3.4. 构建dubbo

构建完成:

[INFO] Reactor Summary:

[INFO]

[INFO] dubbo-parent ....................................... SUCCESS [ 0.349 s]

[INFO] dubbo-common ....................................... SUCCESS [ 4.351 s]

[INFO] dubbo-container .................................... SUCCESS [ 0.007 s]

[INFO] dubbo-container-api ................................ SUCCESS [ 0.718 s]

[INFO] dubbo-container-spring ............................. SUCCESS [ 0.368 s]

[INFO] dubbo-container-jetty .............................. SUCCESS [ 0.343 s]

[INFO] dubbo-container-log4j .............................. SUCCESS [ 0.432 s]

[INFO] dubbo-container-logback ............................ SUCCESS [ 0.431 s]

[INFO] dubbo-remoting ..................................... SUCCESS [ 0.003 s]

[INFO] dubbo-remoting-api ................................. SUCCESS [ 1.717 s]

[INFO] dubbo-remoting-netty ............................... SUCCESS [ 0.678 s]

[INFO] dubbo-remoting-mina ................................ SUCCESS [ 0.528 s]

[INFO] dubbo-remoting-grizzly ............................. SUCCESS [ 0.776 s]

[INFO] dubbo-remoting-p2p ................................. SUCCESS [ 0.793 s]

[INFO] dubbo-remoting-http ................................ SUCCESS [ 0.781 s]

[INFO] dubbo-remoting-zookeeper ........................... SUCCESS [ 0.484 s]

[INFO] dubbo-rpc .......................................... SUCCESS [ 0.004 s]

[INFO] dubbo-rpc-api ...................................... SUCCESS [ 1.174 s]

[INFO] dubbo-rpc-default .................................. SUCCESS [ 1.051 s]

[INFO] dubbo-rpc-injvm .................................... SUCCESS [ 0.367 s]

[INFO] dubbo-rpc-rmi ...................................... SUCCESS [ 0.359 s]

[INFO] dubbo-rpc-hessian .................................. SUCCESS [ 0.427 s]

[INFO] dubbo-rpc-http ..................................... SUCCESS [ 0.415 s]

[INFO] dubbo-rpc-webservice ............................... SUCCESS [ 2.279 s]

[INFO] dubbo-cluster ...................................... SUCCESS [ 1.123 s]

[INFO] dubbo-registry ..................................... SUCCESS [ 0.007 s]

[INFO] dubbo-registry-api ................................. SUCCESS [ 0.839 s]

[INFO] dubbo-monitor ...................................... SUCCESS [ 0.004 s]

[INFO] dubbo-monitor-api .................................. SUCCESS [ 0.366 s]

[INFO] dubbo-filter ....................................... SUCCESS [ 0.004 s]

[INFO] dubbo-filter-validation ............................ SUCCESS [ 0.429 s]

[INFO] dubbo-filter-cache ................................. SUCCESS [ 0.398 s]

[INFO] dubbo-registry-default ............................. SUCCESS [ 0.419 s]

[INFO] dubbo-monitor-default .............................. SUCCESS [ 0.370 s]

[INFO] dubbo-registry-multicast ........................... SUCCESS [ 0.443 s]

[INFO] dubbo-config ....................................... SUCCESS [ 0.005 s]

[INFO] dubbo-config-api ................................... SUCCESS [ 1.157 s]

[INFO] dubbo-config-spring ................................ SUCCESS [ 1.080 s]

[INFO] dubbo-rpc-thrift ................................... SUCCESS [ 0.898 s]

[INFO] dubbo-rpc-memcached ................................ SUCCESS [ 0.469 s]

[INFO] dubbo-rpc-redis .................................... SUCCESS [ 0.607 s]

[INFO] dubbo-registry-zookeeper ........................... SUCCESS [ 0.574 s]

[INFO] dubbo-registry-redis ............................... SUCCESS [ 0.724 s]

[INFO] dubbo .............................................. SUCCESS [ 5.777 s]

[INFO] dubbo-simple ....................................... SUCCESS [ 0.003 s]

[INFO] dubbo-registry-simple .............................. SUCCESS [ 5.491 s]

[INFO] dubbo-monitor-simple ............................... SUCCESS [ 11.807 s]

[INFO] dubbo-admin ........................................ SUCCESS [ 4.867 s]

[INFO] dubbo-demo ......................................... SUCCESS [ 0.003 s]

[INFO] dubbo-demo-api ..................................... SUCCESS [ 0.237 s]

[INFO] dubbo-demo-provider ................................ SUCCESS [ 9.309 s]

[INFO] dubbo-demo-consumer ................................ SUCCESS [ 9.491 s]

[INFO] ------------------------------------------------------------------------

[INFO] BUILD SUCCESS

[INFO] ------------------------------------------------------------------------

[INFO] Total time: 01:16 min

[INFO] Finished at: 2016-05-31T11:22:10+08:00

[INFO] Final Memory: 73M/1725M

[INFO] ------------------------------------------------------------------------

3.5. 找到对应的模块包

3.5.1. 核心框架

3.5.2. 管理控制台

3.5.3. 简易监控中心

3.5.4. 简易注册中心

4. Dubbo框架说明

4.1. 背景

4.2. 服务治理

4.3. 架构

调用关系：

1. 服务容器负责启动，加载，运行服务提供者。

2. 服务提供者在启动时，向注册中心注册自己提供的服务。

3. 服务消费者在启动时，向注册中心订阅自己所需的服务。

4. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

5. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

6. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

5. 快速入门

5.1. 实现功能

存在2个系统，A系统和B系统，A系统调用B系统的接口获取数据，用于查询用户列表。

5.2. 安装zookeeper

解压得到如下：

修改配置文件zoo.cfg：该目录必须存在。

启动zookeeper服务：

5.3. 搭建B系统

5.3.1. 创建工程

5.3.2. 导入依赖

<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">

<groupId>cn.itcast.dubbo</groupId>

<artifactId>dubbo-b</artifactId>

<version>1.0.0-SNAPSHOT</version>

<groupId>org.springframework</groupId>

<artifactId>spring-webmvc</artifactId>

<version>4.1.3.RELEASE</version>

</dependency>

</dependency>

<groupId>com.alibaba</groupId>

<artifactId>dubbo</artifactId>

<artifactId>spring</artifactId>

<groupId>org.springframework</groupId>

</exclusion>

</exclusions>

</dependency>

</dependencies>

<build>

<groupId>org.apache.tomcat.maven</groupId>

<artifactId>tomcat7-maven-plugin</artifactId>

</configuration>

</plugin>

</plugins>

</build>

</project>

5.3.3. 配置log4j文件

log4j.properties：

log4j.rootLogger=DEBUG,A1

log4j.appender.A1=org.apache.log4j.ConsoleAppender

log4j.appender.A1.layout=org.apache.log4j.PatternLayout

log4j.appender.A1.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss,SSS} [%t] [%c]-[%p] %m%n

5.3.4. 创建User对象

package cn.itcast.dubbo.pojo;

// 使用dubbo要求传输的对象必须实现序列化接口

public class User implements java.io.Serializable {

private static final long serialVersionUID = -2668999087589887337L;

private Long id;

private String username;

private String password;

private Integer age;

public Long getId() {

return id;

}

public void setId(Long id) {

this.id = id;

}

public String getUsername() {

return username;

}

public void setUsername(String username) {

this.username = username;

}

public String getPassword() {

return password;

}

public void setPassword(String password) {

this.password = password;

}

public Integer getAge() {

return age;

}

public void setAge(Integer age) {

this.age = age;

}

5.3.5. 创建UserService（接口）提供查询服务

package cn.itcast.dubbo.service;

import java.util.List;

import cn.itcast.dubbo.pojo.User;

public interface UserService {

/**

* 查询所有的用户数据

* @return

public List<User> queryAll();

}

5.3.6. 创建UserServiceImpl实现类

package cn.itcast.dubbo.service.impl;

import java.util.ArrayList;

import java.util.List;

import cn.itcast.dubbo.pojo.User;

import cn.itcast.dubbo.service.UserService;

public class UserServiceImpl implements UserService {

/**

* 实现查询，这里做模拟实现，不做具体的数据库查询

public List<User> queryAll() {

List<User> list = new ArrayList<User>();

for (int i = 0; i < 10; i++) {

User user = new User();

user.setAge(10 + i);

user.setId(Long.valueOf(i + 1));

user.setPassword("123456");

user.setUsername("username_" + i);

list.add(user);

}

return list;

}

5.3.7. 编写dubbo配置文件

具体配置：

<beans xmlns="http://www.springframework.org/schema/beans"

   xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"

   xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"

   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-4.0.xsd

   http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd

   http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd

   http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

 

   <!-- 提供方应用信息，用于计算依赖关系 -->

   <dubbo:application name="dubbo-b-server" />

   <!-- 这里使用的注册中心是zookeeper -->

   <dubbo:registry address="zookeeper://127.0.0.1:2181" client="zkclient"/>

   <!-- 用dubbo协议在20880端口暴露服务 -->

   <dubbo:protocol name="dubbo" port="20880" />

   <!-- 将该接口暴露到dubbo中 -->

   <dubbo:service interface="cn.itcast.dubbo.service.UserService" ref="userServiceImpl" />
   <!-- 将具体的实现类加入到Spring容器中 -->

   <bean id="userServiceImpl" class="cn.itcast.dubbo.service.impl.UserServiceImpl" />

 

 

</beans>

5.3.8. 导入zookeeper依赖

<groupId>org.apache.zookeeper</groupId>

<artifactId>zookeeper</artifactId>

</dependency>

<groupId>com.github.sgroschupf</groupId>

<artifactId>zkclient</artifactId>

</dependency>

5.3.9. 编写Web.xml

<?xml version="1.0" encoding="UTF-8"?>

<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">

<display-name>dubbo-b</display-name>

<context-param>

<param-name>contextConfigLocation</param-name>

<param-value>classpath:dubbo/dubbo-*.xml</param-value>

</context-param>

<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>

</listener>

<welcome-file-list>

<welcome-file>index.jsp</welcome-file>

</welcome-file-list>

</web-app>

5.3.10. 启动tomcat

查看tomcat启动日志：

2016-06-03 09:38:35,307 [localhost-startStop-1] [com.alibaba.dubbo.registry.zookeeper.ZookeeperRegistry]-[INFO] [DUBBO] Register: dubbo://192.168.56.1:20880/cn.itcast.dubbo.service.UserService?anyhost=true&application=dubbo-b-server&dubbo=2.5.3&interface=cn.itcast.dubbo.service.UserService&methods=queryAll&pid=5436&side=provider&timestamp=1464917914608, dubbo version: 2.5.3, current host: 127.0.0.1

可以看到，已经将UserService服务注册到zookeeper注册中心，协议采用的是dubbo。

5.4. 搭建A系统

5.4.1. 创建工程

创建完成：

5.4.2. 导入依赖

<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">

<groupId>cn.itcast.dubbo</groupId>

<artifactId>dubbo-a</artifactId>

<version>0.0.1-SNAPSHOT</version>

<groupId>org.springframework</groupId>

<artifactId>spring-webmvc</artifactId>

<version>4.1.3.RELEASE</version>

</dependency>

</dependency>

<groupId>com.alibaba</groupId>

<artifactId>dubbo</artifactId>

<artifactId>spring</artifactId>

<groupId>org.springframework</groupId>

</exclusion>

</exclusions>

</dependency>

<groupId>org.apache.zookeeper</groupId>

<artifactId>zookeeper</artifactId>

</dependency>

<groupId>com.github.sgroschupf</groupId>

<artifactId>zkclient</artifactId>

</dependency>

</dependencies>

</project>

5.4.3. 配置log4j文件

log4j.properties：

log4j.rootLogger=DEBUG,A1

log4j.appender.A1=org.apache.log4j.ConsoleAppender

log4j.appender.A1.layout=org.apache.log4j.PatternLayout

log4j.appender.A1.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss,SSS} [%t] [%c]-[%p] %m%n

5.4.4. 从b系统中拷贝User对象、UserService接口道a系统

5.4.5. 编写dubbo配置文件

dubbo-consumer.xml：

<beans xmlns="http://www.springframework.org/schema/beans"

   xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"

   xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"

   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-4.0.xsd

   http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd

   http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd

   http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

 

   <!-- 提供方应用信息，用于计算依赖关系 -->

   <dubbo:application name="dubbo-a-consumer" />

 

   <!-- 这里使用的注册中心是zookeeper -->

   <dubbo:registry address="zookeeper://127.0.0.1:2181" client="zkclient"/>

  

   <!-- 从注册中心中查找服务 -->

   <dubbo:reference id="userService" interface="cn.itcast.dubbo.service.UserService"/>

 

</beans>

5.4.6. 编写UserService测试用例

package cn.itcast.dubbo.service;

import static org.junit.Assert.*;

import java.util.List;

import org.junit.Before;

import org.junit.Test;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import cn.itcast.dubbo.pojo.User;

public class UserServiceTest {

private UserService userService;

@Before

public void setUp() throws Exception {

ApplicationContext applicationContext = new ClassPathXmlApplicationContext(

"classpath:dubbo/*.xml");

this.userService = applicationContext.getBean(UserService.class);

}

@Test

public void testQueryAll() {

List<User> users = this.userService.queryAll();

for (User user : users) {

System.out.println(user);

}

5.4.7. 查看效果

可以看到，已经查询到10条数据，那么，也就是说A系统通过B系统提供的服务获取到了数据。

5.5. 解决代码重复问题

通过刚刚的示例我们可以发现，其中User对象和UserService在A系统和B系统中都使用，那么，我们是否应该讲该代码复用呢？

答案是肯定的。

在使用dubbo时，provider需要将提供服务所需要的java代码（bean、interface等）单独打包成jar提供给consumer使用。

5.5.1. 创建dubbo-b-api

5.5.2. 将dubbo-b中的pojo和service接口移动到dubbo-b-api中

结果如下：

5.5.3. 在dubbo-b的pom.xml文件中添加dubbo-b-api的依赖

5.5.4. 在dubbo-a的pom.xml文件中添加dubbo-b-api的依赖，并且将pojo与service接口删除

删除代码：

5.5.5. 测试

测试，发现，和之前实现一样。

6. 监控

原理：服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

6.1. 搭建监控服务

6.2. 修改配置文件

修改注册中心的地址：

6.3. 在dubbo-b中配置监控

6.4. 启动

启动成功：

6.5. 查看界面

输入地址：http://127.0.0.1:8088/

说明：端口在这里指定：

6.6. 功能

查看服务：

统计：

图表：

7. 管理

dubbo提供了一套在线管理整个服务的功能，管理控制台为阿里内部裁剪版本，开源部分主要包含：路由规则，动态配置，服务降级，访问控制，权重调整，负载均衡，等管理功能。

7.1. 安装

将dubbo-admin-2.5.3.war部署到tomcat的webapps目录下：

7.2. 修改配置文件

7.3. 启动tomcat

7.4. 查看管理界面

使用用户登录：

http://127.0.0.1:8080/

效果：

功能：

8. dubbo的配置详解

8.1. <dubbo:protocol/>

服务提供者协议配置：
配置类：com.alibaba.dubbo.config.ProtocolConfig
说明：如果需要支持多协议，可以声明多个<dubbo:protocol>标签，并在<dubbo:service>中通过protocol属性指定使用的协议。

以上是关于dubbo入门的主要内容，如果未能解决你的问题，请参考以下文章

dubbo远程调用（rpc）--＞快速入门+管理控制台+整合Springboot开发

dubbo 从入门到精通监控中心搭建

推荐net开发cad入门阅读代码片段

探花交友day00—探花交友前置Dubbo

Dubbo的使用

标签	属性	对应URL参数	类型	是否必填	缺省值	作用	描述	兼容性
<dubbo:protocol>	id		string	可选	dubbo	配置关联	协议BeanId，可以在<dubbo:service protocol="">中引用此ID，如果ID不填，缺省和name属性值一样，重复则在name后加序号。	2.0.5以上版本
<dubbo:protocol>	name	<protocol>	string	必填	dubbo	性能调优	协议名称	2.0.5以上版本
<dubbo:protocol>	port	<port>	int	可选	dubbo协议缺省端口为20880，rmi协议缺省端口为1099，http和hessian协议缺省端口为80 如果配置为-1 或者没有配置port，则会分配一个没有被占用的端口。Dubbo 2.4.0+，分配的端口在协议缺省端口的基础上增长，确保端口段可控。	服务发现	服务端口	2.0.5以上版本
<dubbo:protocol>	host	<host>	string	可选	自动查找本机IP	服务发现	-服务主机名，多网卡选择或指定VIP及域名时使用，为空则自动查找本机IP，-建议不要配置，让Dubbo自动获取本机IP	2.0.5以上版本
<dubbo:protocol>	threadpool	threadpool	string	可选	fixed	性能调优	线程池类型，可选：fixed/cached	2.0.5以上版本
<dubbo:protocol>	threads	threads	int	可选	100	性能调优	服务线程池大小(固定大小)	2.0.5以上版本
<dubbo:protocol>	iothreads	threads	int	可选	cpu个数+1	性能调优	io线程池大小(固定大小)	2.0.5以上版本
<dubbo:protocol>	accepts	accepts	int	可选	0	性能调优	服务提供方最大可接受连接数	2.0.5以上版本
<dubbo:protocol>	payload	payload	int	可选	88388608(=8M)	性能调优	请求及响应数据包大小限制，单位：字节	2.0.5以上版本
<dubbo:protocol>	codec	codec	string	可选	dubbo	性能调优	协议编码方式	2.0.5以上版本
<dubbo:protocol>	serialization	serialization	string	可选	dubbo协议缺省为hessian2，rmi协议缺省为java，http协议缺省为json	性能调优	协议序列化方式，当协议支持多种序列化方式时使用，比如：dubbo协议的dubbo,hessian2,java,compactedjava，以及http协议的json等	2.0.5以上版本
<dubbo:protocol>	accesslog	accesslog	string/boolean	可选		服务治理	设为true，将向logger中输出访问日志，也可填写访问日志文件路径，直接把访问日志输出到指定文件	2.0.5以上版本
<dubbo:protocol>	path	<path>	string	可选		服务发现	提供者上下文路径，为服务path的前缀	2.0.5以上版本