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代码如下

   4.0.0wardubbodemo_provider  com.alibabadubbo2.6.6 io.nettynetty-all4.1.32.Final org.apache.curatorcurator-framework4.0.0  org.apache.zookeeperzookeeper org.apache.zookeeperzookeeper3.4.7 com.github.sgroschupfzkclient0.1 javassistjavassist3.12.1.GA com.alibabafastjson1.2.47

(2) 配置web.xml文件

    contextConfigLocationclasspath: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

   

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文件

    springmvcorg.springframework.web.servlet.DispatcherServlet contextConfigLocationclasspath: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文件

   

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

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

以上就是Spring整合Dubbo框架过程及原理解析的详细内容,更多请关注0133技术站其它相关文章!

赞(0) 打赏
未经允许不得转载:0133技术站首页 » Java