Dubbo之入门

• Dubbo简介
• • 什么是RPC
  • Dubbo核心能力
• Dubbo架构
• 服务注册中心Zookeeper
• • Zookeeper
  • 安装Zookeeper
  • 启动、停止Zookeeper
• Dubbo快速入门
• • 服务提供方开发
  • 服务消费方开发
• Dubbo管理控制台
• • 安装
  • 使用

Dubbo是一款高性能的Java RPC框架。其前身是阿里巴巴公司开源的、轻量级的Java RPC框架，可以和Spring框架无缝集成，2018年阿里巴巴把这个框架捐献给apache基金会。

• RPC全称为remote procedure call，即远程过程调用。
  比如两台服务器A和B，A服务器上部署一个应用，B服务器上部署一个应用，A服务器想要调用B服务器上的应用提供的方法，由于两个应用不在一个内存空间，不能直接调用，所以需要网络来表达调用的语义和传达调用的数据。
• RPC不是一个具体的技术，而是指整个网络远程调用过程。
  RPC是一个泛化的概念，严格来说一切远程调用的手段都属于RPC范畴。Java的RPC框架有：RMI、Hessian、Dubbo等。

面向接口的远程方法调用、智能容错和负载均衡、服务自动注册和发现

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

Dubbo官网推荐使用Zookeeper作为服务注册中心

Zookeeper 是 Apache Hadoop 的子项目，是一个树型的目录服务，支持变更推送，适合作为 Dubbo服务的注册中心，工业强度较高，可用于生产环境，并推荐使用。
Zookeeper树型目录服务：

流程说明：

• 服务提供者(Provider)启动时: 向 /dubbo/com.foo.BarService/providers 目录下写入自己的URL 地址
• 服务消费者(Consumer)启动时: 订阅 /dubbo/com.foo.BarService/providers 目录下的提供者URL 地址。并向 /dubbo/com.foo.BarService/consumers 目录下写入自己的 URL 地址
• 监控中心(Monitor)启动时: 订阅 /dubbo/com.foo.BarService 目录下的所有提供者和消费者URL 地址

下载地址：http://archive.apache.org/dist/zookeeper/
第一步：安装 jdk https://blog.csdn.net/weixin_43915128/article/details/121090963
第二步：把 zookeeper 的压缩包上传到 linux 系统
第三步：解压缩压缩包 tar -zxvf zookeeper-3.4.6.tar.gz -C /usr 第四步：进入zookeeper-3.4.6目录，创建data目录 mkdir data
第五步：进入conf目录 ，把zoo_sample.cfg 改名为zoo.cfg cd conf
mv zoo_sample.cfg zoo.cfg
第六步：打开zoo.cfg文件, 修改dataDir=/usr/zookeeper-3.4.6/data(自己data所在目录)

进入Zookeeper的bin目录，
启动服务命令： ./zkServer.sh start
停止服务命令： ./zkServer.sh stop
查看服务状态： ./zkServer.sh status
客户端连接： ./zkCli.sh

新建maven项目

    
        UTF-8
        1.8
        1.8
        5.0.5.RELEASE
    
    
        
            org.springframework
            spring-context
            ${spring.version}
        
        
            org.springframework
            spring-beans
            ${spring.version}
        
        
            org.springframework
            spring-webmvc
            ${spring.version}
        
        
            org.springframework
            spring-jdbc
            ${spring.version}
        
        
            org.springframework
            spring-aspects
            ${spring.version}
        
        
            org.springframework
            spring-jms
            ${spring.version}
        
        
            org.springframework
            spring-context-support
            ${spring.version}
        

        
            com.alibaba
            dubbo
            2.6.0
        
        
            org.apache.zookeeper
            zookeeper
            3.4.7
        
        
            com.github.sgroschupf
            zkclient
            0.1
        
        
            javassist
            javassist
            3.12.1.GA
        
        
            com.alibaba
            fastjson
            1.2.76
        
        
            mysql
            mysql-connector-java
            5.1.49
        
        
            com.alibaba
            druid
            1.1.21
        
        
            org.mybatis
            mybatis-spring
            2.0.6
        
    
    
        
            
                org.apache.maven.plugins
                maven-compiler-plugin
                2.3.2
                
                    1.8
                    1.8
                
            
            
                org.apache.tomcat.maven
                tomcat7-maven-plugin
                
                    8083
                    /
                
            
        
    

配置web.xml

    
        contextConfigLocation
        classpath*:application.xml
    
    
        org.springframework.web.context.ContextLoaderListener
    

创建服务接口

package com.dmlll.service;
public interface HelloService {
    public String sayHello(String name);
}

创建服务实现类

import com.alibaba.dubbo.config.annotation.Service;
import com.dmlll.service.HelloService;
import org.springframework.transaction.annotation.Transactional;

@Transactional
@Service(interfaceClass = HelloService.class)
public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name) {
        return " 8083 hello "+ name;
    }
}

注意：服务实现类上使用的Service注解是Dubbo提供，用于对外发布服务
创建application.xml

启动服务
tomcat7:run

复制上面的maven，修改端口号和服务名
配置web.xml

    
        contextConfigLocation
        classpath*:application*.xml
    
    
        org.springframework.web.context.ContextLoaderListener
    
    
    
        dispatcherServlet
        org.springframework.web.servlet.DispatcherServlet
        
            contextConfigLocation
            classpath:application-web.xml
        
    
    
        dispatcherServlet
        /
    

将服务提供者工程中的HelloService接口复制到当前工程
编写Controller

import com.alibaba.dubbo.config.annotation.Reference;
import com.dmlll.service.HelloService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/consumer")
public class HelloController {
    @Reference
    private HelloService helloService;

    @RequestMapping("hello")
    public String sayHello(String name){
        //远程调用
        String result = helloService.sayHello(name);
        System.out.println(result);
        return result;
    }
}

注意：Controller中注入HelloService使用的是Dubbo提供的@Reference注解
在src/main/resources下创建application-web.xml

运行测试
tomcat7:run
访问localhost:8082/consumer/hello?name=dam

我们在开发时，需要知道Zookeeper注册中心都注册了哪些服务，有哪些消费者来消费这些服务。我们可以通过部署一个管理中心来实现。其实管理中心就是一个web应用，部署到tomcat即可。

（1）下载dubbo-admin-2.6.0.war文件复制到tomcat的webapps目录下
（2）启动tomcat，此war文件会自动解压
（3）修改WEB-INF下的dubbo.properties文件，注意dubbo.registry.address对应的值需要对应当前使用的Zookeeper的ip地址和端口号
dubbo.registry.address=zookeeper://192.168.134.129:2181 dubbo.admin.root.password=root
dubbo.admin.guest.password=guest
（4）重启tomcat

（1）访问http://localhost:8080/dubbo-admin-2.6.0/，输入用户名(root)和密码(root)
（2）启动服务提供者工程和服务消费者工程，可以在查看到对应的信息