dubbo学习笔记

前言

1. 单一应用架构
当网站流量很小时，应用规模小时，只需一个应用，将所有功能都部署在一起，以减少部署服务器数量和成本。这种结构的应用适合小型系统，小型网站，或者企业的内部系统，用户较少，请求量不大，对请求的处理时间没有太高的要求。 将所有功能都部署到一个服务器，简单易用。开发项目的难度低。
2. 分布式服务架构
当应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。此时，用于提高业务复用及整合的分布式服务框架(RPC)是关键。分布式系统将服务作为独立的应用，实现服务共享和重用。
3. RPC
【Remote Procedure Call】是指远程过程调用，是一种进程间通信方式，是一种技术思想，而不是规范。rpc 通讯是基于 tcp 或udp 议序列化方式（xml/json/二进制）。使用rpc要序列化
4. 分布式服务架构
分布式系统是若干独立计算机（服务器）的集合，这些计算机对于用户来说就像单个相关系统，分布式系统（distributed system）是建立在网络之上的服务器端一种结构。分布式系统中的计算机可以使用不同的操作系统，可以运行不同应用程序提供服务，将服务分散部署到多个计算机服务器上。

dubbo框架 一、dubbo 概述

Apache Dubbo (incubating) |ˈdʌbəʊ| 是一款高性能、轻量级的开源 Java RPC 框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。
Dubbo 是一个分布式服务框架，致力于提供高性能和透明化的 RPC 远程服务调用方案、服务治理方案
**面向接口代理：**调用接口的方法，在 A 服务器调用 B 服务器的方法，由 dubbo 实现对 B 的调用，无需关心实现的细节，就像 MyBatis 访问 Dao 的接口，可以操作数据库一样。不用关心 Dao 接口方法的实现。

二、dubbo 架构

dubbo官网

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

调用关系说明:

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

dubbo支持的协议:

支持多种协议：dubbo , hessian , rmi , http, webservice , thrift , memcached , redis。 dubbo 官方推荐使用 dubbo 协议。dubbo 协议默认端口 20880
使用 dubbo 协议，spring 配置文件加入：

三、dubbo 架构使用示例

dubbo建议将服务接口、服务模型、服务异常等均放在公共包中

3.1直连方式 dubbo

创建三个项目，分别为接口项目，服务消费项目，服务提供项目。其中接口项目为普通maven工程，其他服务提供和服务消费都是maven web工程。

3.1.1 创建interface接口工程 3.1.1.1 创建对应实体类以及相应的接口

代码示例：

//实体类代码
public class User implements Serializable {

    private Integer id;

    private String username;


    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }
}

//接口
public interface UserService {

    
    User queryUserById(Integer id);
    
    Integer queryAllUserCount();

}

3.1.1.2 Maven install

有build success即可

3.1.2 创建userservice-provider服务提供者工程 3.1.2.1 服务提供者pom.xml导入接口依赖以及dubbo以及spring相关依赖

    

        
        
            org.springframework
            spring-context
            4.3.16.RELEASE
        
        
            org.springframework
            spring-webmvc
            4.3.16.RELEASE
        

        
        
            com.alibaba
            dubbo
            2.6.2
        

        
        
            com.wkcto.dubbo
            003-link-interface
            1.0.0
        

    

3.1.2.2 创建接口类的实现类，并实现对应方法

public class UserServiceImpl implements UserService {

    @Override
    public User queryUserById(Integer id) {
        User user = new User();
        user.setId(id);
        user.setUsername("zhangsan");
        return user;
    }

    @Override
    public Integer queryAllUserCount() {
        return 52;
    }
}

3.1.2.3 编写dubbo配置文件

3.1.2.4 编写web文件，注册dubbo配置文件的监听

	
		contextConfigLocation
		classpath:dubbo-userservice-provider.xml
	
	
		org.springframework.web.context.ContextLoaderListener
	

3.1.3 创建consumer服务消费者工程 3.1.3.1 编写pom.xml添加相关依赖

    
        
        
            org.springframework
            spring-context
            4.3.16.RELEASE
        
        
            org.springframework
            spring-webmvc
            4.3.16.RELEASE
        

        
        
            com.alibaba
            dubbo
            2.6.2
        

        
        
            com.wkcto.dubbo
            003-link-interface
            1.0.0
        
    

3.1.3.2 编写spring配置文件

3.1.3.3 编写dubbo配置文件

3.1.3.4 编写controller

@Controller
public class UserController {

    @Autowired
    private UserService userService;

    @RequestMapping(value = "/userDetail")
    public String userDetail(Model model,Integer id) {

        //根据用户标识获取用户详情
        User user = userService.queryUserById(id);

        //获取用户总人数
        Integer allUserCount = userService.queryAllUserCount();

        model.addAttribute("user",user);
        model.addAttribute("allUserCount",allUserCount);

        return "userDetail";
    }
}

3.1.3.5 编写web配置文件

	
		dispatcherServlet
		org.springframework.web.servlet.DispatcherServlet
		
			contextConfigLocation
			classpath:applicationContext.xml,classpath:dubbo-consumer.xml
		
	
	
		dispatcherServlet
		/
	

3.2 使用注册中心-Zookeeper的安装 安装配置 Zookeeper

下载的文件 zookeeper-3.5.4-beta.tar.gz. 解压后到目录就可以了，复制 zoo-sample.cfg 改名为 zoo.cfg，修改 zoo.cfg配置内容：
1.dataDir : zookeeper 数据的存放目录
2. admin.serverPort=8888
原因：zookeeper 3.5.x 占用 8080

3.3 使用注册中心-Zookeeper的方式使用dubbo

使用zookeeper注册中心的方式使用dubbo。总的来说和直连方式差不多。主要差别是服务提供者和服务消费者的dubbo配置文件

服务提供对应的dubbo配置文件

服务消费对应的dubbo配置文件