Dubbo入门

Posted zhuifenglang

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Dubbo入门相关的知识,希望对你有一定的参考价值。

一、dubbo介绍

随着互联网的不断发展,网站的规模也越来越大,常规的垂直应用架构已经不能再满足开发的需求,分布式服务架构和流式计算架构已成为趋势。

单一应用架构:当网站流量很小时,只需要一个应用,将所有的功能都部署在一起,以减少部署节点个成本。

垂直应用架构:当访问量逐渐增大,单一应用增加机器带来的加速度越来越小,将应用拆成互不相干的几个应用,以提升效率。

分布式服务架构:当垂直应用越来越多,应用之间交互不可避免,将核心业务抽离出来,作为独立的服务,逐渐形成稳定的服务中心,使前端应用能更快速的响应多变的市场需求。

流式计算架构:当服务越来越多,容量的评估,小服务资源的浪费等问题逐渐显现,此时需要增加一个调度中心基于访问压力实时管理集群容量,提高集群利用率。

那什么是dubbo呢?dubbo是一个分布式服务架构,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案。核心部分包含远程通信、集群容错、自动发现。

二、dubbo工作原理

(1) 连通性:

注册中心负责服务地址的注册与查找,相当于目录服务,服务提供者和消费者只在启动时与注册中心交互,注册中心不转发请求,压力较小

监控中心负责统计各服务调用次数,调用时间等,统计先在内存汇总后每分钟一次发送到监控中心服务器,并以报表展示

服务提供者向注册中心注册其提供的服务,并汇报调用时间到监控中心,此时间不包含网络开销

服务消费者向注册中心获取服务提供者地址列表,并根据负载算法直接调用提供者,同时汇报调用时间到监控中心,此时间包含网络开销

注册中心,服务提供者,服务消费者三者之间均为长连接,监控中心除外

注册中心通过长连接感知服务提供者的存在,服务提供者宕机,注册中心将立即推送事件通知消费者

注册中心和监控中心全部宕机,不影响已运行的提供者和消费者,消费者在本地缓存了提供者列表

注册中心和监控中心都是可选的,服务消费者可以直连服务提供者

(2) 健壮性:

监控中心宕掉不影响使用,只是丢失部分采样数据

数据库宕掉后,注册中心仍能通过缓存提供服务列表查询,但不能注册新服务

注册中心对等集群,任意一台宕掉后,将自动切换到另一台

注册中心全部宕掉后,服务提供者和服务消费者仍能通过本地缓存通讯

服务提供者无状态,任意一台宕掉后,不影响使用

服务提供者全部宕掉后,服务消费者应用将无法使用,并无限次重连等待服务提供者恢复

(3) 伸缩性:

注册中心为对等集群,可动态增加机器部署实例,所有客户端将自动发现新的注册中心

服务提供者无状态,可动态增加机器部署实例,注册中心将推送新的服务提供者信息给消费者

技术图片

三、dubbo应用

1、创建maven工程,创建实体类User和接口UserService。

 1 //User实体类
 2 public class User implements Serializable {
 3     private int id;
 4     private String name;
 5     private int age;
 6 
 7     public int getId() {
 8         return id;
 9     }
10 
11     public void setId(int id) {
12         this.id = id;
13     }
14 
15     public String getName() {
16         return name;
17     }
18 
19     public void setName(String name) {
20         this.name = name;
21     }
22 
23     public int getAge() {
24         return age;
25     }
26 
27     public void setAge(int age) {
28         this.age = age;
29     }
30 }
31 
32 //接口UserService
33 public interface UserService {
34     //根据id查询User
35     User getUser(int id);
36 }

2、在已有工程的基础上,创建module,命名为dubboProvider,在pom.xml文件中导入坐标

 1 <dependency>
 2             <groupId>org.springframework</groupId>
 3             <artifactId>spring-context</artifactId>
 4             <version>4.0.5.RELEASE</version>
 5         </dependency>
 6 
 7         <!--导入DubboDemo公共接口依赖-->
 8         <dependency>
 9             <groupId>com.demo.dubbo</groupId>
10             <artifactId>DubboDemo</artifactId>
11             <version>1.0-SNAPSHOT</version>
12         </dependency>
13         <!--导入dubbo依赖-->
14         <dependency>
15             <groupId>com.alibaba</groupId>
16             <artifactId>dubbo</artifactId>
17             <version>2.5.3</version>
18         </dependency>
19         <!--导入zookeeper依赖-->
20         <dependency>
21             <groupId>com.101tec</groupId>
22             <artifactId>zkclient</artifactId>
23             <version>0.10</version>
24         </dependency>

编写接口实现类UserServiceImpl.java。

 1 public class UserServiceImpl implements UserService {
 2     @Override
 3     public User getUser(int id) {
 4         User user = new User();
 5         switch (id){
 6             case 1:
 7                 user.setId(id);
 8                 user.setName("张");
 9                 user.setAge(20);
10                 break;
11             case 2:
12                 user.setId(id);
13                 user.setName("白");
14                 user.setAge(21);
15                 break;
16         }
17         return user;
18     }
19 }

接着配置dubbo-user-consumer.xml。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://code.alibabatech.com/schema/dubbo
       http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<!--服务提供者的信息如下-->
    <!-- provider‘s application name, used for tracing dependency relationship -->
    <!--服务提供者的应用名称-->
    <dubbo:application name="user-provider"/>
    <!-- use multicast registry center to export service -->
    <!--注册中心地址-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    <!-- use dubbo protocol to export service on port 20880 -->
    <!--协议及端口号-->
    <dubbo:protocol name="dubbo" port="20880"/>
    <!-- declare the service interface to be exported -->
    <!--指明提供服务的接口-->
    <dubbo:service interface="com.dubbo.service.UserService" ref="userService"/>
    <!-- service implementation, as same as regular local bean -->
    <!--服务实现类-->
    <bean id="userService" class="com.dubbo.service.impl.UserServiceImpl"/>
</beans>

在test下创建ProviderMain.java测试类。

 1 public class ProviderMain {
 2     public static void main(String[] args) throws Exception{
 3 
 4         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-user-provider.xml");
 5         //加载
 6         context.start();
 7         System.out.println("Provider started.");
 8         //让程序阻塞
 9         System.in.read(); // press any key to exit
10     }
11 }

然后启动zkServer.cmd,运行测试类,可以在控制台看到“Provider started.”,利用zookeeper工具可以看到生成的相应节点。

3、接下来创建消费者module,命名为:dubboConsumer,pom.xml需要导入的坐标和创建dubboProvider服务提供者module时导入的坐标一样,然后是配置dubbo-user-consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://code.alibabatech.com/schema/dubbo
       http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<!--消费者配置-->
    <!--消费者应用名-->
    <!-- consumer‘s application name, used for tracing dependency relationship (not a matching criterion),
    don‘t set it same as provider -->
    <dubbo:application name="user-consumer"/>
    <!-- use multicast registry center to discover service -->
    <!--注册中心地址-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    <!-- generate proxy for the remote service, then demoService can be used in the same way as the
    local regular interface -->
    <!--远程服务代理-->
    <dubbo:reference id="userService" interface="com.dubbo.service.UserService"/>
</beans>

编写ConsumerMain测试类

 1 public class ConsumerMain {
 2     public static void main(String[] args) throws Exception {
 3         //消费者调用服务提供者
 4         //获取返回数据
 5         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-user-consumer.xml");
 6         //加载
 7         context.start();
 8         //获取远程服务代理
 9         // Obtaining a remote service proxy
10         UserService userService = (UserService)context.getBean("userService");
11         // Executing remote methods
12         User user = userService.getUser(1);
13         // Display the call result
14         System.out.println(user.getName());
15     }
16 }

在服务提供者启动的前提下,运行消费者测试类,即可在控制台获取到相应的信息。

以上是关于Dubbo入门的主要内容,如果未能解决你的问题,请参考以下文章

dubbo远程调用(rpc)-->快速入门+管理控制台+整合Springboot开发

dubbo远程调用(rpc)-->快速入门+管理控制台+整合Springboot开发

dubbo 从入门到精通 监控中心搭建

推荐net开发cad入门阅读代码片段

探花交友day00—探花交友前置Dubbo

Dubbo的使用