Dubbo入门

系统间通信

系统架构演变

• 单一应用架构
  当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署的节点和成本。此时，用于简化增删查改工作量的数据访问框架（ORM）是关键。
• 垂直应用架构
  当访问量逐渐增大，单一应用增加机器所带来的加速度越来越小，将应用拆成互不相干的几个应用，以提升效率。此时，用于加速前端页面开发的Web框架（MVC）是关键。
• 分布式服务架构
  当垂直应用越来越多，应用之间的交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速地响应多变的市场需求。此时，用于提高业务复用及整合的分布式服务框架（RPC）是关键。

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

  
  架构演变

需求

现代网站应用的规模在不断扩大，传统的垂直架构已经无法应对，为了应对高并发的业务场景，满足解耦和的需求，分布式服务架构以及流动计算架构势在必行。系统被拆分成若干个互相独立又存在一定依赖的模块，需要高效的实现系统间通信的方式。

实现系统间通信的方式

• WebService
  基于soap协议，效率不高。
• RESTful形式的服务
  http + json，若服务太多，服务间的关系就显得混乱，需要治理。
• 使用RPC框架
  远程过程调用，屏蔽底层网络技术，通过网络从远程计算机程序上请求服务。

Dubbo

Dubbo是一个高性能的，基于Java的Alibaba开源RPC框架。和许多RPC系统一样，dubbo基于定义服务的思想，指定可以通过参数和返回类型远程调用的方法。从服务角度的模型来看，Dubbo在使用中可以分为提供者和消费者两个角色。提供者实现一个接口并运行一个dubbo服务器来处理消费者调用，消费者拥有一个相同的接口，通过调用该接口实现对提供者方法的调用。
Dubbo是基于Spring的，可以很方便地与Spring项目整合。在分布式项目中，提供者在Spring容器中注册提供服务的bean，消费者通过引用相应的服务，就可以实现注入。

Dubbo架构

• Provider：暴露服务的服务提供方
• Consumer：调用远程服务的服务消费方
• Registry：服务注册与发现的注册中心，相当于目录，不提供转发服务
• Monitor：统计服务调用次数和调用时间的监控中心
• Container：服务运行容器

ZooKeeper

ZooKeeper是一个分布式应用程序协调服务，主要是用来解决分布式应用中经常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等。
在本次与Dubbo整合的过程中，ZooKeeper充当的就是Dubbo架构中的注册中心（Registry）。

安装

1. 下载并解压ZooKeeper
2. 在解压的目录下新建data目录
3. 进入conf目录，复制一份zoo_sample.cfg，更名为zoo.cfg，修改dataDir属性，指向新建的data目录
4. 进入bin目录，通过./zkServer.sh start启动ZooKeeper
5. 通过./zkServer.sh status查看ZooKeeper状态
6. 通过./zkServer.sh stop关闭ZooKeeper

示例

依赖

除了基本的Spring依赖，还需要Dubbo、ZooKeeper、zkclient包，由于使用logback作为日志工具，需要排除log4j。

    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>2.5.7</version>
        <exclusions>
            <exclusion>
                <groupId>org.jboss.netty</groupId>
                <artifactId>netty</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>org.apache.zookeeper</groupId>
        <artifactId>zookeeper</artifactId>
        <version>3.4.9</version>
        <exclusions>
            <exclusion>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
            </exclusion>
            <exclusion>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <dependency>
        <groupId>com.101tec</groupId>
        <artifactId>zkclient</artifactId>
        <version>0.10</version>
    </dependency>

service

public interface HelloService {

    String sayHello(String name);
}

public class HelloServiceImpl implements HelloService {

    @Override
    public String sayHello(String name) {
        return "Hello! " + name;
    }
}

配置提供者

<?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="dubbo-provider"/>
    <!-- 在zookeeper注册 -->
    <dubbo:registry protocol="zookeeper" address="106.14.200.121:2181"/>
    <!-- 使用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880"/>
    <!-- 声明要暴露的接口 -->
    <dubbo:service interface="com.wch.ssm.service.HelloService" ref="helloService"/>

    <!-- 注册service -->
    <bean id="helloService" class="com.wch.ssm.service.impl.HelloServiceImpl"/>

</beans>

提供者

/**
 * dubbo服务提供者
 */
public class Provider {

    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context =
                new ClassPathXmlApplicationContext("classpath:spring/dubbo/provider.xml");
        context.start();
        System.in.read();
    }
}

配置消费者

<?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="dubbo-consumer"/>
    <!-- 在zookeeper注册 -->
    <dubbo:registry protocol="zookeeper" address="106.14.200.121:2181"/>
    <!-- 引用dubbo服务 -->
    <dubbo:reference id="helloService" interface="com.wch.ssm.service.HelloService"/>

</beans>

消费者

/**
 * dubbo服务消费者
 */
public class Consumer {

    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context =
                new ClassPathXmlApplicationContext("classpath:spring/dubbo/consumer.xml");
        context.start();

        String name = "wch";
        HelloService helloService = (HelloService) context.getBean("helloService");
        String say = helloService.sayHello(name);
        System.out.println(say);
    }
}

配置Dubbo监控中心

访问github-alibaba/dubbo，下载完整的dubbo项目并解压，进入dubbo-admin目录，打开命令行窗口，使用mvn clean package -DskipTests命令将dubbo-admin打成war包，由于相对路径问题，建议清空tomcat的ROOT目录，将war包解压后的文件放进ROOT目录，监控中心的配置文件dubbo.properties在WEB-INF目录下（将war包直接放置在webapps目录下亦可）。

# 注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
# root用户密码
dubbo.admin.root.password=root
# guest用户密码
dubbo.admin.guest.password=guest

启动项目

先启动提供者再启动消费者。打开dubbo-admin，可以对提供者和消费者进行监控。

Dubbo监控中心
Dubbo监控中心