当前位置:  开发笔记 > 后端 > 正文

Spring整合Dubbo框架过程及原理解析

这篇文章主要介绍了Spring整合Dubbo框架过程及原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

这篇文章主要介绍了Spring整合Dubbo框架过程及原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

Dubbo作为一个RPC框架,其最核心的功能就是要实现跨网络的远程调用。演示过程创建两个小工程,一个作为服务的提供者,一个作为服务的消费者。通过Dubbo来实现服务消费者远程调用服务提供者的方法。

dubbo 的使用需要一个注册中心,这里以Zookeeper为例来演示

1.Dubbo架构

Dubbo架构图(Dubbo官方提供)如下:

节点角色说明:

节点 角色名称
Provider 暴露服务的服务提供方
Consumer 调用远程服务的服务消费方
Registry 服务注册与发现的注册中心
Monitor 统计服务的调用次数和调用时间的监控中心
Container 服务运行容器

调用关系说明:

服务容器负责启动,加载,运行服务提供者。

服务提供者在启动时,向注册中心注册自己提供的服务。

服务消费者在启动时,向注册中心订阅自己所需的服务。

注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。

服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。

服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。

2.服务提供者开发

(1) 创建maven工程(打包方式为war)dubbodemo_provider,添加依赖pom.xml代码如下

<?xml version="1.0" encoding="UTF-8"?>

  
  4.0.0
  war
  
  dubbodemo_provider
 
 
    
      com.alibaba
      dubbo
      2.6.6
    
    
    
      io.netty
      netty-all
      4.1.32.Final
    
    
      org.apache.curator
      curator-framework
      4.0.0
      
        
          org.apache.zookeeper
          zookeeper
        
      
    
    
      org.apache.zookeeper
      zookeeper
      3.4.7
    
    
      com.github.sgroschupf
      zkclient
      0.1
    
    
      javassist
      javassist
      3.12.1.GA
    
    
      com.alibaba
      fastjson
      1.2.47
    
  
 

(2) 配置web.xml文件

<?xml version="1.0" encoding="UTF-8"?>


 
 
  contextConfigLocation
  classpath:spring/applicationContext-provider.xml
 
 
  org.springframework.web.context.ContextLoaderListener
 

(3) 创建服务接口

package com.test.dubbo.api;
public interface HelloService {
  public String sayHello(String name);
}

(4) 创建服务实现类

package com.test.service.impl;

import com.test.dubbo.api.HelloService;
//这个service并不是spring提供的,是dubbo的service代替的
import com.alibaba.dubbo.config.annotation.Service;

@Service //把此服务注册到zookeeper
public class HelloServiceImpl implements HelloService {
  public String sayHello(String name) {
   return "hello " + name;
  }
}

==注意==:服务实现类上使用的Service注解是Dubbo提供的,用于对外发布服务

(5) 在src/main/resources下创建applicationContext-provider.xml

<?xml version="1.0" encoding="UTF-8"?>

  
  
  
  
  
  
  
  

6)启动服务 也就是把spring容器启动即可

可以用tomcat启动项目

也可以用main方法加载spring配置文件,也就是启动了spring容器

在com.itheima包下创建一个DemoProvider类来启动spring容器,代码如下

package com.test;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.io.IOException;

public class DemoProvider {

  public static void main(String[] args) throws IOException {
//    加载配置文件,启动容器
    ClassPathXmlApplicationContext app = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-provider.xml");
    app.start();
    System.in.read(); //等待控制台回车。如果不回车就一直卡这儿不继续
  }
}

3.服务消费者开发

开发步骤:

(1) 创建maven工程(打包方式为war)dubbodemo_consumer,pom.xml配置和上面服务提供者相同

(2) 配置web.xml文件

<?xml version="1.0" encoding="UTF-8"?>


 
  springmvc
  org.springframework.web.servlet.DispatcherServlet
  
  
   contextConfigLocation
   classpath:spring/springmvc.xml
  
 

 
  springmvc
  *.do
 

(3) 将服务提供者工程中的HelloService接口复制到当前工程

(4) 编写Controller

package com.test.controller;
import com.alibaba.dubbo.config.annotation.Reference;
import com.itheima.dubbo.api.HelloService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@RequestMapping("/demo")
public class HelloController {
  @Reference//这里使用dubbo提供的,用来代替@Autowired来注入服务
  private HelloService helloService;

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

==注意==:Controller中注入HelloService使用的是Dubbo提供的@Reference注解

(5) 在src/main/resources下创建spring文件夹,再创建springmvc.xml文件

<?xml version="1.0" encoding="UTF-8"?>


    
  

  
  
  
  
  
  

  
  


dubbo的使用小demo已经完成。大家可以尝试一下

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。

推荐阅读
保佑欣疼你的芯疼
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有