最近想学习一下dubbo,看了很多前辈们的文章和资料,现对自己的理解做个总结:
要说dubbo就先了解一下RPC:
概念:
RPC(Remote Procedure Call):远程过程调用,是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。它使得在本地调用远端的程序就好像是在调用本地的程序一样。
RPC协议假定某些传输协议是存在的,如TCP或UDP,为通信程序之间携带信息数据。在OSI网络通信模型(七层模型)中,RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。
RPC调用过程:
客户端以本地服务方式调用服务
client stub作为代理,然后处理调用与调用的参数
client stub发送调用到远端的系统,通过TCP或UDP
server stub处理client stub发过来的调用与参数
server stub调用真正提供的服务
server stub处理回复,然后发送给客户端
Dubbo
1、什么是dubbo :Dubbo是阿里巴巴SOA服务化治理方案的核心框架,是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案。
   soa:“面向服务架构”,它提供的是一种架构风格和理念,而并非是一种技术或者产品。SOA提倡将不同应用程序的业务功能封装成“服务”并宿主起来,通常以接口和契约的形式暴露并提供给外界应用访问(通过交换消息),达到不同系统可重用的目的。
 2、Dubbo的技术架构图如下:
我们解释一下这个架构图:
a、Consumer服务消费者(花钱的),Provider服务提供者(给钱的),Container服务容器(领钱的地方)。
b、服务提供者先启动,然后注册服务(registry)。
c、Monitor这是一个监控,图中虚线表明Consumer 和Provider通过异步的方式发送消息至Monitor,Consumer和Provider会将信息存放在本地磁盘,平均1min会发送一次信息。Monitor在整个架构中是可选的。
d、Monitor功能需要单独配置,不配置或者配置以后,Monitor挂掉并不会影响服务的调用。
 
3、Dubbo服务消费者调用过程
 
上图是服务消费的主过程:
首先通过 ReferenceConfig 类的 private void init() 方法会先检查初始化所有的配置信息后,调用 private T createProxy(Map map) 创建代理,消费者最终得到的是服务的代理, 在 createProxy 接着调用 Protocol 接口实现的 Invoker refer(Class type, URL url) 方法生成 Invoker 实例(如上图中的红色部分),这是服务消费的关键。接下来把 Invoker 通过 ProxyFactory 代理工厂转换为客户端需要的接口(如: HelloWorld ),创建服务代理并返回。
消费端的初始化过程
1、把服务引用的信息封装成URL并注册到zk注册中心;
2、监听注册中心的服务的上下线;
3、连接服务提供端,创建NettyClient对象;
4、将这些信息包装成DubboInvoker消费端的调用链,创建消费端Invoker实例的服务代理并返回;
消费端的服务引用过程
1、经过负载均衡策略,调用提供者;
2、选择其中一个服务的URL与提供者netty建立连接,使用ProxyFactory 创建远程通信,或者本地通信的,Invoker发到netty服务端;
3、服务器端接收到该Invoker信息后,找到对应的本地Invoker,处理Invocation请求;
4、获取异步,或同步处理结果;
异步 不需要返回值:直接调用ExchangeClient.send()方法;
同步 需要返回值:使用ExchangeClient.request()方法,返回一个ResponseFuture,一直阻塞到服务端返回响应结果;
 
 4、最简单的dubbo实例
1. 服务提供方和消费方都需要的包(这里我新建的maven工程为pom工程,将共同的项目依赖写到pom.xml中)
总的项目结构为 
这里写图片描述
pom.xml文件内容为
  4.0.0
  com.test
  dubbo-demo
  0.0.1-SNAPSHOT
  pom
   
        0.3.0
        
        2.5.3
        2.8.4
        4.3.6.RELEASE
        1.7
        UTF-8
    
    
      
            com.alibaba
            dubbo
            2.5.3
            
                
                    org.springframework
                    spring
                
            
        
        
            com.github.sgroschupf
            zkclient
            0.1
        
        
        
            org.springframework
            spring-core
            ${spring.version}
        
        
            org.springframework
            spring-beans
            ${spring.version}
        
        
            org.springframework
            spring-context
            ${spring.version}
        
        
            org.springframework
            spring-jdbc
            ${spring.version}
        
        
            org.springframework
            spring-web
            ${spring.version}
        
        
            org.springframework
            spring-webmvc
            ${spring.version}
        
        
            org.springframework
            spring-aop
            ${spring.version}
        
        
            org.springframework
            spring-tx
            ${spring.version}
        
        
            org.springframework
            spring-orm
            ${spring.version}
        
        
            org.springframework
            spring-context-support
            ${spring.version}
        
        
            org.springframework
            spring-test
            ${spring.version}
        
        
            org.springframework
            spring-jms
            ${spring.version}
        
        
            org.aspectj
            aspectjrt
            1.6.11
        
        
            org.aspectj
            aspectjweaver
            1.6.11
        
    
   
    demo-api
    dubbo-consumer
    dubbo-provider
   
2. 在demo-api中定义服务接口(注意服务提供方和消费方都需要依赖这个项目)
package com.test;
public interface DemoService{  
     String sayHello(String name);  
} 
3. 服务提供方实现
项目结构 
这里写图片描述
实现接口
package com.test;
import org.springframework.stereotype.Service;
import com.test.DemoService;
@Service("demoService")
public class DemoServiceImpl implements DemoService{
    @Override
    public String sayHello(String name) {
        // TODO Auto-generated method stub
        return name; 
    }  
}
声明暴露服务:
      
      
      
       
      
      
      
      
在springmvc.xml中扫描service注解并将dubbo-provider.xml中的相关的dubbo配置引入进来
    
    
    
加载Spring配置,启动服务:
package com.test;
import java.io.IOException;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Test {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:springmvc.xml");
        context.start();
        System.out.println("Dubbo provider start...");
        try {
            System.in.read();   // 按任意键退出
        } catch (IOException e) {
            e.printStackTrace();
        } 
    }
}
  4. 服务消费者实现
项目结构 
这里写图片描述
在dubbo-consumer.xml中声明所所需要消费的服务
    
          
        
           
          
             
          
        
   
在springmvc.xml中扫描service注解并将dubbo-consumer.xml中的相关的dubbo配置引入进来
    
    
    
加载Spring配置,调用服务:
package com.test;
import java.io.IOException;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Test {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] { "classpath:springmvc.xml" });
        context.start();
        DemoService demoService = (DemoService) context.getBean("demoService");
        System.out.println(demoService.sayHello("哈哈哈"));
        try {
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
如果出现以下结果则调用成功
这里写图片描述
通过dubbo-admin管理后台可以看到服务的提供方与消费方
具体搭建可参考博客:http://blog.csdn.net/jingyangv587/article/details/78904369
提供方: 
这里写图片描述
消费者: 
这里写图片描述https://www.cnblogs.com/lixiangfei/p/9732800.html