友情提醒

先看文章目录，大致了解文章知识点结构，点击文章目录可直接跳转到文章指定位置。

第一章、概念介绍

1.1）什么是RPC框架

RPC 【Remote Procedure Call】是指远程过程调用，是一种进程间通信方式，是一种技术思想，而不是规范。它允许程序调用另一个地址空间（网络的另一台机器上）的过程或函数，而不用开发人员显式编码这个调用的细节。调用本地方法和调用远程方法一样。

1.2）什么是分布式系统

分布式系统是若干独立计算机（服务器）的集合，这些计算机对于用户来说就像单个相关系统，分布式系统（distributed system）是建立在网络之上的服务器端一种结构。
部署在独立服务器上的各个子系统（项目），相互之间可以调用，形成一个大型分布式系统
独立部署的服务器没有额外要求，只需要满足子系统需求即可。
分布式系统中的计算机可以使用不同的操作系统，可以运行不同应用程序提供服务，将服务分散部署到多个计算机服务器上。

1.3）Dubbo概述

Dubbo官网网址：官网链接
①Apache Dubbo 是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。可以和Spring框架无缝集成。

②Dubbo是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案、服务治理方案。

③面向接口代理：调用接口的方法，在A服务器调用B服务器的方法，由dubbo实现对B的调用，无需关心实现的细节，就像MyBatis访问Dao的接口，可以操作数据库一样。不用关心Dao接口方法的实现。这样开发是方便，舒服的。

④支持多种协议：dubbo , hessian , rmi , http, webservice , thrift , memcached , redis。dubbo官方推荐使用dubbo协议。dubbo协议默认端口20880

1.3）Dubbo基本架构

①服务提供者（Provider）：暴露服务的服务提供方，服务提供者在启动时向注册中心注册自己提供的服务。服务容器spring负责启动，加载，运行服务提供者。

②服务消费者（Consumer）: 调用远程服务的服务消费方，服务消费者在启动时，向注册中心订阅自己所需的服务，服务消费者从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

③注册中心（Registry）：注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者 –如果信息有变，注册中心提供新的信息给消费者

④监控中心（Monitor）：服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心 –监控服务提供者、消费者状态，与开发没有直接关系

第二章、服务提供者(直连)

2.1）目录结构和依赖

pom文件

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.bjpowernode.dubbo</groupId><artifactId>001-link-orderservice-provider</artifactId><version>1.0.0</version><dependencies><!--Spring --><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>4.3.16.RELEASE</version></dependency><!--Dubbo依赖--><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.6.2</version></dependency></dependencies><build><plugins><!--JDK1.8编译插件--><plugin><artifactId>maven-compiler-plugin</artifactId><version>3.1</version><configuration><source>1.8</source><target>1.8</target></configuration></plugin></plugins></build></project>

2.2）model层

order

package com.bjpowernode.dubbo.model;import java.io.Serializable;public class Order implements Serializable {private String id;private String goodsName;private Double price;private Integer amount;public Order() {}public Order(String id, String goodsName, Double price, Integer amount) {this.id = id;this.goodsName = goodsName;this.price = price;this.amount = amount;}public String getId() {return id;}public void setId(String id) {this.id = id;}public String getGoodsName() {return goodsName;}public void setGoodsName(String goodsName) {this.goodsName = goodsName;}public Double getPrice() {return price;}public void setPrice(Double price) {this.price = price;}public Integer getAmount() {return amount;}public void setAmount(Integer amount) {this.amount = amount;}@Overridepublic String toString() {return "Order{" +"id='" + id + '\'' +", goodsName='" + goodsName + '\'' +", price=" + price +", amount=" + amount +'}';}
}

2.3）service层

OrderService

package com.bjpowernode.dubbo.service;import com.bjpowernode.dubbo.model.Order;public interface OrderService {public Order addOrder(Integer userId,String goodsName, Double price,Integer amount);
}

OrderServiceImpl

package com.bjpowernode.dubbo.service;import com.bjpowernode.dubbo.model.Order;public class OrderServiceImpl implements OrderService{public Order addOrder(Integer userId, String goodsName, Double price, Integer amount) {return new Order("110",goodsName,price,amount);}
}

OrderApplication

package com.bjpowernode.dubbo;import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;import java.io.IOException;public class OrderApplication {public static void main(String[] args) throws IOException {/*** 启动spring容器：阅读配置文件*   1、 new ClassPathXmlApplicationContext("orderservce-provider.xml");*   2、 new FileSystemXmlApplicationContext("D:/orderservce-provider.xml");*   3、tomcat启动*/new ClassPathXmlApplicationContext("orderservce-provider.xml");//标准键盘输入：线程会阻塞System.in.read();}
}

2.4）resources配置文件

orderservce-provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"><!--服务项目名称：唯一 ，它的名称是dubbo内部使用的唯一标识    饭店名称--><dubbo:application name="001-link-order-service-provider"></dubbo:application><!--定义协议：告诉消费者如何访问  怎么访问--><dubbo:protocol name="dubbo" port="20880"></dubbo:protocol><!--dubbo:service:提供（暴露）服务     菜单interface:区分不同的服务ref：关联真正提供服务的bean对象registry="N/A"：直连--><dubbo:serviceinterface="com.bjpowernode.dubbo.service.OrderService"ref="orderServiceImpl" registry="N/A"/><!--真正提供服务的bean对象    厨师--><bean id="orderServiceImpl" class="com.bjpowernode.dubbo.service.OrderServiceImpl"></bean>
</beans>

第三章、服务消费者(直连)

3.1）目录结构和依赖

pom文件

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.bjpowernode.dubbo</groupId><artifactId>002-link-main-web</artifactId><version>1.0.0</version><dependencies><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>4.3.16.RELEASE</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.6.2</version></dependency><dependency><groupId>com.bjpowernode.dubbo</groupId><artifactId>001-link-orderservice-provider</artifactId><version>1.0.0</version></dependency></dependencies></project>

3.2）service层

ShopService

package com.bjpowernode.dubbo.service;import com.bjpowernode.dubbo.model.Order;public interface ShopService {public Order buyGoods(Integer userId, String goodsName, Double price, Integer amount);}

ShopServiceImpl

package com.bjpowernode.dubbo.service;import com.bjpowernode.dubbo.model.Order;public class ShopServiceImpl implements ShopService {OrderService orderService;public void setOrderService(OrderService orderService) {this.orderService = orderService;}public Order buyGoods(Integer userId, String goodsName, Double price, Integer amount) {// new OrderServiceImpl().addOrder()return orderService.addOrder(userId, goodsName, price, amount);}
}

ShopApplication

package com.bjpowernode.dubbo;import com.bjpowernode.dubbo.model.Order;
import com.bjpowernode.dubbo.service.ShopService;
import org.springframework.context.support.ClassPathXmlApplicationContext;public class ShopApplication {public static void main(String[] args) {ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("shop-consume.xml");ShopService shopServiceImpl = (ShopService)context.getBean("shopServiceImpl");Order order = shopServiceImpl.buyGoods(1111, "apple", 10d, 2);System.out.println(order);}
}

3.3）resources配置文件

shop-consume.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"><!--服务项目名称：唯一--><dubbo:application name="002-link-main-web"></dubbo:application><!--dubbo:reference:生成一个 代表远程服务的 bean对象id="remoteOrderService"：bean对象名称url:dubbo服务地址interface：区分不同的服务registry="N/A":直连--><dubbo:referenceid="remoteOrderService"url="dubbo://localhost:20880"interface="com.bjpowernode.dubbo.service.OrderService"registry="N/A"/><bean id="shopServiceImpl" class="com.bjpowernode.dubbo.service.ShopServiceImpl"><property name="orderService" ref="remoteOrderService"></property></bean></beans>

第四章、注册中心Zookeeper

4.1）注册中心概述

通过将服务统一管理起来，可以有效地优化内部应用对服务发布/使用的流程和管理。服务注册中心可以通过特定协议来完成服务对外的统一。Dubbo 提供的注册中心有如下几种类型可供选：

1、Multicast注册中心：组播方式
2、Redis注册中心：使用Redis作为注册中心
3、Simple注册中心：就是一个dubbo服务。作为注册中心。提供查找服务的功能。
4、Zookeeper注册中心：使用Zookeeper作为注册中心

注册中心工作方式

4.2）下载Zookeeper注册中心

①Zookeeper是一个高性能的，分布式的，开放源码的分布式应用程序协调服务。Zookeeper运行需要java环境。

官网下载地址: http://zookeeper.apache.org/

②点击download下载

③找到历史版本in the archive

④下载3.5.6版本

4.3）Windows安装Zookeeper

①下载的文件zookeeper-3.5.4-beta.tar.gz. 解压后到目录就可以了，例如d:/servers/ zookeeper-3.5.4
修改zookeeper-3.5.4/conf/ 目录下配置文件

②复制zoo-sample.cfg改名为zoo.cfg，然后打开文件，查看文件内容

查看zoo.cfg文件内容

文件内容介绍
tickTime: 心跳的时间默认2000毫秒. Zookeeper服务器之间或客户端与服务器之间每2秒就会发送一个心跳。表明存活状态。

dataDir: 数据目录，可以是任意目录。存储zookeeper的快照文件、pid文件，默认为/tmp/zookeeper

clientPort: 客户端连接zookeeper的端口，即zookeeper对外的服务端口，默认为2181
④在文件配置最下面加入需要使用的端口号

admin.serverPort=8888

⑤bin目录下双击cmd文件，启动zookeeper

windows启动zookeeper成功

4.3）Linux安装Zookeeper

①VMware虚拟机下载安装，虚拟机中安装Linux系统CentOS7（图文详解）
Linux安装教程链接

②Zookeeper的运行需要Linux系统先安装好jdk.
安装jdk教程链接

③使用xftp工具将刚刚下载好的zookeeper-3.5.6-beta.tar.gz 文件传输到Linux系统下的/usr/local/目录
xftp工具的使用教程链接

④解压压缩文件到/usr/local/目录

tar -zxvf zookeeper-3.5.6-beta.tar.gz -C /usr/local/

⑤进入解压后的conf目录

cd apache-zookeeper-3.8.1-bin/conf

⑥拷贝文件 zoo-sample.cfg 为 zoo.cfg

zoo_sample.cfg

⑦使用vim命令修改zoo.cfg文件内容

vim zoo.cfg

增加如下内容后保存退出

admin.serverPort=9999

⑦切换到bin目录下，启动zookeeper，关闭zookeeper

切换bin目录

cd ..
cd bin

启动zookeeper

./zkServer.sh start

关闭zookeeper

./zkServer.sh stop

第五章、dubbo使用注册中心

5.1）项目加入zookeeper客户端依赖

每个模块均要加入如下代码

<!-- zookeeper客户端依赖 -->
<dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>4.1.0</version>
</dependency>

5.2）配置文件修改

服务提供者和消费者均要加入注册中心

 <dubbo:registry address="zookeeper://192.168.52.128:2181" check="false"></dubbo:registry>

直连的服务配置修改为注册中心方式

    <!--暴露服务--><dubbo:service interface="com.bjpowernode.dubbo.service.UserInfoService"ref="userInfoServiceImpl"  retries="2"  timeout="20000"version="1.36"></dubbo:service>

5.3）dubbo其他配置

①关闭检查

 <dubbo:registry address="zookeeper://192.168.52.128:2181" check="false"></dubbo:registry>

②重试次数

<dubbo:service retries="2" />
或
<dubbo:reference retries="2" />

③超时时间
由于网络或服务端不可靠。为了避免超时导致客户端资源（线程）挂起耗尽，必须设置超时时间。

dubbo消费端
指定接口超时配置
<dubbo:reference interface="com.foo.BarService" timeout="2000" />

dubbo服务端
指定接口超时配置
<dubbo:server interface="com.foo.BarService" timeout="2000" />

④版本号
服务提供者增加版本号

    <!--暴露服务--><dubbo:service interface="com.bjpowernode.dubbo.service.UserInfoService"ref="userInfoServiceImpl"  retries="2"  timeout="20000"version="2.0.0"></dubbo:service>

服务消费者增加版本号

  <dubbo:referenceid="remoteUserInfoService2"interface="com.bjpowernode.dubbo.service.UserInfoService"version="2.0.0"/>