系统间通信
系统架构演变
- 单一应用架构
当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署的节点和成本。此时，用于简化增删查改工作量的数据访问框架（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）。
安装
- 下载并解压ZooKeeper
- 在解压的目录下新建data目录
- 进入conf目录，复制一份zoo_sample.cfg，更名为zoo.cfg，修改dataDir属性，指向新建的data目录
- 进入bin目录，通过./zkServer.sh start启动ZooKeeper
- 通过./zkServer.sh status查看ZooKeeper状态
- 通过./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监控中心
