dubbo简单了解

来自于尚硅谷Dubbo教程(dubbo经典之作)，方便复习使用

分布式系统是若干独立计算机的集合，这些计算机对于用户来说就像单个相关系统

单一应用架构

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

缺点：性能扩展比较难、协同开发问题、不利于升级维护

垂直应用架构

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

通过切分业务来实现各个模块独立部署，降低了维护和部署的难度，团队各司其职更易管理，性能扩展也更方便，更有针对性。

缺点： 公用模块无法重复利用，开发性的浪费

分布式服务架构

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

流动计算架构

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

RPC【Remote Procedure Call】是指远程过程调用，是一种进程间通信方式,A服务器的代码调用B服务器的功能

RPC两个核心模块：通讯，序列化。

通过网络通信传递数据。

不同服务之间如何通信，如何传递数据，如何调用，dubbo这个rpc框架来完成！

官网：Apache Dubbo

Apache Dubbo (incubating) |ˈdʌbəʊ| 是一款高性能、轻量级的开源Java RPC框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。

服务提供者（Provider）：暴露服务的服务提供方，服务提供者在启动时，向注册中心注册自己提供的服务。服务消费者（Consumer）: 调用远程服务的服务消费方，服务消费者在启动时，向注册中心订阅自己所需的服务，服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。注册中心（Registry）：注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者监控中心（Monitor）：服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心

调用关系说明：

服务容器负责启动，加载，运行服务提供者。服务提供者在启动时，向注册中心注册自己提供的服务。服务消费者在启动时，向注册中心订阅自己所需的服务。注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。 dubbo环境搭建 zookeeper注册中心安装

安装可以参考：尚硅谷Dubbo教程(dubbo经典之作)_哔哩哔哩_bilibili

首先官网下载安装zookeeper，也可直接使用这个资源，提取码：6666

解压zookeeper，运行zkServer.cmd ，初次运行会报错，没有zoo.cfg配置文件

修改zoo.cfg配置文件

将conf下的zoo_sample.cfg复制一份改名为zoo.cfg，直接粘贴在当前文件夹中

注意几个重要位置：

dataDir=./ 临时数据存储的目录（可写相对路径）

clientPort=2181 zookeeper的端口号

这里推荐将zoo.cfg中的dataDir修改成：dataDir=…/data

在目录下创建一个名为data的文件夹：

启动zkServer.cmd

连接服务器zkCli.cmd

基本操作：

create -e /ysk 123 创建一个临时节点，值为123
ls / 列出根节点
get /列出根节点值

资源，提取码：6666

进入目录 修改路径dubbo-admin配置，指定地址

在dubbo-admin中的pom.xml中，dubbo2.6以后都是jar包形成，之前都是war包,在pom.xml目录下cmd,通过mvn clean package打包

target目录cmd下：java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

地址栏输入：http://localhost:7001/ 账号密码均是root

某个电商系统，订单服务需要调用用户服务获取某个用户的所有地址；

我们现在 需要创建两个服务模块进行测试

测试预期结果：订单服务web模块在A服务器，用户服务模块在B服务器，A可以远程调用B的功能。

实体类：

public class UserAddress implements Serializable {
	
	private Integer id;
    private String userAddress; //用户地址
    private String userId; //用户id
    private String consignee; //收货人
    private String phoneNum; //电话号码
    private String isDefault; //是否为默认地址    Y-是     N-否
}

接口：

UserService.java:

public interface UserService {
	
	
	public List getUserAddressList(String userId);

}

OrderService.java:

public interface OrderService {
	
	
	public List initOrder(String userId);

}

引入接口工程的依赖文件：

    com.ysk
    gmall-interface
    1.0-SNAPSHOT

引入dubbo:

  
    
      com.alibaba
      dubbo
      2.6.2
    
    
    
    
      org.apache.curator
      curator-framework
      2.12.0
    
  

实现类:

public class UserServiceImpl implements UserService {

	@Override
	public List getUserAddressList(String userId) {
		System.out.println("UserServiceImpl.....old...");
		// TODO Auto-generated method stub
		UserAddress address1 = new UserAddress(1, "北京市昌平区宏福科技园综合楼3层", "1", "李老师", "010-56253825", "Y");
		UserAddress address2 = new UserAddress(2, "深圳市宝安区西部硅谷大厦B座3层（深圳分校）", "1", "王老师", "010-56253825", "N");
		
		return Arrays.asList(address1,address2);
	}

配置文件：

测试：

public class MainApplication {
	
	public static void main(String[] args) throws IOException {
		ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("provider.xml");
		ioc.start();
		
		System.in.read();
	}

和提供者一样引入相关的依赖

实现类：

@Service
public class OrderServiceImpl implements OrderService {

	@Autowired
	private UserService userService;
	@Override
	public List initOrder(String userId) {
		// TODO Auto-generated method stub
		System.out.println("用户id："+userId);
		//1、查询用户的收货地址
		List addressList = userService.getUserAddressList(userId);
		for (UserAddress userAddress : addressList) {
			System.out.println(userAddress.getUserAddress());
		}
		return addressList;
	}
	

}

测试：

ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");

OrderService orderService = applicationContext.getBean(OrderService.class);

orderService.initOrder("1");
System.out.println("调用完成....");
System.in.read();

下载 dubbo-ops，https://github.com/apache/incubator-dubbo-ops ，或者直接赋值上文管理控制台的解压目录下名为dubbo-monitor……

修改配置指定注册中心地址，进入 dubbo-monitor-simplesrcmainresourcesconf,修改 dubbo.properties文件

打包dubbo-monitor-simple，在pom.xml文件下，cmd,mvn package

解压 tar.gz 文件，并运行start.bat

启动访问8080

在consumer.xml中加入：

重新运行：

可以看到服务信息