目录

• Dubbo入门 背景
• zookeeper安装
• 发布Dubbo服务
• Dubbo Admin管理
• 消费Dubbo服务
• 抽取与依赖版本管理

Dubbo入门

背景

随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，亟需一个治理系统确保架构有条不紊的演进。

当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。此时，用于简化增删改查工作量的数据访问框架(ORM)是关键。

当访问量逐渐增大，单一应用增加机器带来的加速度越来越小，将应用拆成互不相干的几个应用，以提升效率。此时，用于加速前端页面开发的Web框架(MVC)是关键。

当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。此时，用于提高业务复用及整合的分布式服务框架(RPC)是关键。

当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。此时，用于提高机器利用率的资源调度和治理中心(SOA)是关键。

zookeeper安装

http://zookeeper.apache.org/

http://mirrors.hust.edu.cn/apache/zookeeper/

下载好我们解压出来直接启动bin目录下zkServer.bat是不行的，我们暂时将zoo_sample.cfg改成zoo.cfg然后就可以正常启动了，启动后我们可以看到默认的端口2181到时候我们的Dubbo就调用这个端口

发布Dubbo服务

https://github.com/apache/incubator-dubbo

下载后我们参照里面的Demo先来搞一个provider。（dubbo-provider）

<!--  配置阿里云  -->
<mirror>
<id>nexus-aliyun</id>
<mirrorOf>*</mirrorOf>
<name>Nexus aliyun</name>
<url>http://maven.aliyun.com/nexus/content/groups/public</url>
</mirror>

<dependencies>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.0</version>
</dependency>
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.10</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>4.0.1</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.46</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.25</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.4</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.0.35.Final</version>
</dependency>
</dependencies>

package com.miya.dubbo.service;
/**
* 服务提供者接口
* @author SimpleWu
*
*/
public interface MyProviderService {
public String sayHello(String name);
}

实现接口

package com.miya.dubbo.service.impl;
import com.miya.dubbo.service.MyProviderService;
/**
* 服务提供者接口实现类
* @author SimpleWu
*
*/
public class MyProviderServiceImpl implements MyProviderService {

@Override
public String sayHello(String name) {
return "服务1 ： MyProviderServiceImpl 。。 sayHello ";
}
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<!-- 提供方应用名称，用于计算依赖关系 -->
<dubbo:application name="demo-provider" />

<!-- 使用zookeeper注册中心暴露服务地址 -->
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>

<!-- 使用dubbo协议，在20880端口暴露服务 -->
<dubbo:protocol name="dubbo" port="20880"/>

<!-- service实现类作为本地的一个bean -->
<bean id="myProviderService" class="com.miya.dubbo.service.impl.MyProviderServiceImpl"/>

<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.miya.dubbo.service.MyProviderService" ref="myProviderService"/>
</beans>

发布服务之前需要先启动zookeeper，启动后图示：

创建测试类发布服务

public static void main(String[] args){
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "dubbo-provider.xml" });
context.start();
System.out.println("服务提供者向zookeeper中心注册服务成功 暴露的端口为：20880");
try {
System.in.read();
} catch (IOException e) {
e.printStackTrace();
}
}

发布后图示：

如果看到我们的服务接口后就说明服务发布成功！

Dubbo Admin管理

我们需要将WAR包发布到Tomcat里面最好独立运行，我们将Tomcat wepapps下的ROOT全部删掉将WAR包解压到里面，然后启动Tomcat（必须先开启我们的zookeeper），我们直接访问localhost:8080会弹出：

默认的账号root密码root登陆

我们可以看到这个页面

我们可以在这里管理我们的服务

目前我们点击服务是没有查询到服务的，我们将我们之前的那个服务运行发布上去可以看到

我们可以点击服务名进去管理我们的服务

在这里可以对应的去操作我们的服务，注意我们的服务就是在20880端口暴露的，这里我们的服务也是20880说明我们的服务成功发布。

消费Dubbo服务

创建一个maven项目(dubbo-consumer)开启消费者：

<dependencies>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.0</version>
</dependency>
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.10</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>4.0.1</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.46</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.25</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.4</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.0.35.Final</version>
</dependency>
</dependencies>

package com.miya.dubbo.service;
/**
* 服务提供者接口
* @author SimpleWu
*
*/
public interface MyProviderService {
public String sayHello(String name);
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

<!-- 消费方应用名称，用于计算依赖关系，不是匹配条件，不要与提供方名称一样  -->
<dubbo:application name="demo-consumer"/>

<!-- 使用zookeeper注册中心暴露服务地址 -->
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>

<!-- 生成远程服务代理，可以与本地bean一样使用  check属性，启动时候是否检查 一般设置成false 启动时候不检查 -->
<dubbo:reference id="myProviderService" check="false" interface="com.miya.dubbo.service.MyProviderService"/>

</beans>

package com.miya.dubbo.test;

import java.io.IOException;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.miya.dubbo.service.MyProviderService;

public class ConsumerTest {
public static void main(String[] args) {
//读取消费者配置文件
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"dubbo-consumer.xml"});
context.start();
//获取消费实例
MyProviderService demoProviderService=(MyProviderService) context.getBean("myProviderService");
String result=demoProviderService.sayHello("Miya");
System.out.println("远程调用的结果："+result);
try {
System.in.read();
} catch (IOException e) {
e.printStackTrace();
}
context.close();
}
}

打开zookeeper-->Tomcat发布Dubbo Admin管理中心-->启动消费者测试程序

我们可以看到消费者已经有了，图示：

抽取与依赖版本管理

在前面两个项目中我们会发现两个项目中有两个相同的接口（MyProviderServiceImpl.java），这样是不好的，我们现在参照官方demo来创建一个maven工程（dubbo-api）

我们将接口我们将这个接口放到api这个项目中去，然后将dubbo-consumer,dubbo-provider这两个工程中的接口删掉，这个时候我们这两个项目会报错因为找不到这个接口，我们可以将这两个项目添加依赖：

<dependency>
<groupId>com.miya</groupId>
<artifactId>dubbo-api</artifactId>
</dependency>

我们只要依赖dubbo-api就可以获取到了吗？

我们在dubbo-consumer,dubbo-provider这两个工程中会发现POM.xml中的版本号，如果我们需要修改版本要一个一个去修改有两个工程不是要改两次？那夸张以点，一万不是得改半条命？

这个时候我们还是创建一个maven工程（dubbo-parent），这个工程Packaging我们选择POM，这个项目负责版本统一。首先我们抽取相同的依赖，然后给他们定义统一的版本管理方式。

<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.miya</groupId>
<artifactId>dubbo-parent</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>pom</packaging>
<!-- 依赖版本管理 -->
<properties>
<dubbo-api.version>0.0.1-SNAPSHOT</dubbo-api.version>
<dubbo.version>2.6.0</dubbo.version>
<zkclient.version>0.10</zkclient.version>
<curator-framework.version>4.0.1</curator-framework.version>
<fastjson.version>1.2.46</fastjson.version>
<log4j.version>1.2.17</log4j.version>
<slf4j-api.version>1.7.25</slf4j-api.version>
<commons-lang3.version>3.4</commons-lang3.version>
<netty-all.version>4.0.35.Final</netty-all.version>
</properties>

<!--依赖管理 -->
<dependencyManagement>
<dependencies>
<dependency>
<groupId>com.miya</groupId>
<artifactId>dubbo-api</artifactId>
<version>${dubbo-api.version}</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>${dubbo.version}</version>
</dependency>
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>${zkclient.version}</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>${curator-framework.version}</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>${fastjson.version}</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>${log4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j-api.version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>${commons-lang3.version}</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>${netty-all.version}</version>
</dependency>
</dependencies>
</dependencyManagement>
</project>