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

2023-08-04 15:52:03 75

这篇文章主要介绍了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.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文件






contextConfigLocation
classpath:spring/applicationContext-provider.xml


org.springframework.web.context.ContextLoaderListener

（3）创建服务接口

packagecom.test.dubbo.api;
publicinterfaceHelloService{
publicStringsayHello(Stringname);
}

（4）创建服务实现类

packagecom.test.service.impl;

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

@Service//把此服务注册到zookeeper
publicclassHelloServiceImplimplementsHelloService{
publicStringsayHello(Stringname){
return"hello"+name;
}
}

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

（5）在src/main/resources下创建applicationContext-provider.xml

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

可以用tomcat启动项目

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

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

packagecom.test;

importorg.springframework.context.support.ClassPathXmlApplicationContext;

importjava.io.IOException;

publicclassDemoProvider{

publicstaticvoidmain(String[]args)throwsIOException{
//加载配置文件，启动容器
ClassPathXmlApplicationContextapp=newClassPathXmlApplicationContext("classpath:spring/applicationContext-provider.xml");
app.start();
System.in.read();//等待控制台回车。如果不回车就一直卡这儿不继续
}
}

3.服务消费者开发

开发步骤：

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

（2）配置web.xml文件





springmvc
org.springframework.web.servlet.DispatcherServlet


contextConfigLocation
classpath:spring/springmvc.xml




springmvc
*.do

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

（4）编写Controller

packagecom.test.controller;
importcom.alibaba.dubbo.config.annotation.Reference;
importcom.itheima.dubbo.api.HelloService;
importorg.springframework.stereotype.Controller;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.ResponseBody;

@Controller
@RequestMapping("/demo")
publicclassHelloController{
@Reference//这里使用dubbo提供的，用来代替@Autowired来注入服务
privateHelloServicehelloService;

@RequestMapping("/hello")
@ResponseBody
publicStringgetName(Stringname){
//远程调用
Stringresult=helloService.sayHello(name);
System.out.println(result);
returnresult;
}
}

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

（5）在src/main/resources下创建spring文件夹，再创建springmvc.xml文件

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

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

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

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

热门推荐

随机推荐