Dubbo快速入门

一、Dubbo概述

官网地址：Apache Dubbo

dubbo是一个轻量级、高性能java RPC框架，主要三大核心功能：面向接口的远程方法调用、智能容错和负载均衡、服务自动注册和发现

1、什么是RPC

RPC即为远程过程调用，如A服务器上的某个功能调用B服务器上的某个功能即为远程过程调用，

一个RPC框架两个很重要也是影响效率性能的点是

如何高效实现序列化和反序列化
如何快速建立通信

2、dubbo就是通过这一思想实现的框架，实现语言是java

3、架构

Provider:服务提供方，服务启动时向注册中心注册自己提供的服务

Consumer：服务消费者，在启动服务时向注册中心订阅自己所需的服务，从服务提供者地址列表中基于负载均衡算法选一台提供者进行调用，如果调用失败再选一台调用；consumer调用provider提供的服务使用的协议就是dubbo协议端口是20880，dubbo提供的协议有很多如http、dubbo、rmi等，

Registry：注册中心返回服务提供者地址列表给服务消费者，如果有变更，注册中心将基于长连接推送变更数据给服务消费者；这个注册中心可以不用，直接消费服务提供者提供的服务，这种消费称为直连消费

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

二、dubbo直连工程

dubbo直连消费就是没有注册中心，消费者直接消费服务提供者提供的服务

1、创建provider工程（服务提供者）

依赖


 
    <dependency>
      <groupId>com.alibabagroupId>
      <artifactId>dubboartifactId>
      <version>2.6.0version>
    dependency>
    
    <dependency>
      <groupId>org.springframeworkgroupId>
      <artifactId>spring-contextartifactId>
      <version>4.3.16.RELEASEversion>
    dependency>
    
    <dependency>
      <groupId>org.springframeworkgroupId>
      <artifactId>spring-webmvcartifactId>
      <version>4.3.16.RELEASEversion>
    dependency>

服务接口以及实现类


public interface MsgService {
    String hello(String hello);
}
 
 
 
public class MsgServiceImpl implements MsgService {
    public String hello(String hello) {
        return "hello"+hello;
    }
}

springApplicationContext.xml文件


"1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
    
    <dubbo:application name="dubbo-provider"/>
 
    
    <dubbo:protocol name="dubbo" port="20880"/>
 
    
    <dubbo:service interface="service.MsgService" ref="msgServiceImpl" registry="N/A"/>
    
    <bean id="msgServiceImpl" class="service.impl.MsgServiceImpl"/>
beans>

web.xml


"1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee
         http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"
         version="3.1">
  <context-param>
    <param-name>contextConfigLocationparam-name>
    <param-value>classpath:springApplicationContext.xmlparam-value>
  context-param>
  <listener>
    <listener-class>org.springframework.web.context.ContextLoaderListenerlistener-class>
  listener>
web-app>

2、创建consumer工程（服务消费者）

依赖


    <dependency>
      <groupId>org.examplegroupId>
      <artifactId>providerartifactId>
      <version>1.0-SNAPSHOTversion>
    dependency>
    
    <dependency>
      <groupId>com.alibabagroupId>
      <artifactId>dubboartifactId>
      <version>2.6.0version>
    dependency>
    
    <dependency>
      <groupId>org.springframeworkgroupId>
      <artifactId>spring-contextartifactId>
      <version>4.3.16.RELEASEversion>
    dependency>
    
    <dependency>
      <groupId>org.springframeworkgroupId>
      <artifactId>spring-webmvcartifactId>
      <version>4.3.16.RELEASEversion>
    dependency>

测试方法


@RestController
public class MsgController {
    @Autowired
    private MsgService msgService;
 
    @RequestMapping("hello")
    public String hello(Model model){
        String msg = msgService.hello("ni hao");
        model.addAttribute("msg",msg);
        return "index";
    }
}

springMvc.xml


"1.0" encoding="UTF-8"?>
"http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/context
       http://www.springframework.org/schema/context/spring-context.xsd
       http://www.springframework.org/schema/mvc
       http://www.springframework.org/schema/mvc/spring-mvc.xsd">
    
    package="demo.controller"/>
    
    
 
    "org.springframework.web.servlet.view.InternalResourceViewResolver">
        "prefix" value="/"/>
        "suffix" value=".jsp"/>

springApplicationContext.xml


"1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
    
    <dubbo:application name="dubbo-consumer"/>
 
    
    <dubbo:reference interface="service.MsgService"
                     id="msgService"
                     url="dubbo://localhost:20880"
                     registry="N/A"/>
beans>

web.xml


"1.0" encoding="UTF-8"?>
"http://xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee
         http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"
         version="3.1">
  
    dispatcherServlet
    org.springframework.web.servlet.DispatcherServlet
    
      contextConfigLocation
      classpath:springMvc.xml,classpath:springApplicationContext.xml
    
    1
  
  
    dispatcherServlet
    /

使用tomcat依次部署provider和consumer两个项目，浏览器访问

http://localhost:8080/hello

三、dubbo推荐的项目结构

官方推荐的dubbo项目结构包括三部分，分别是

服务消费工程：war工程服务提供方
服务提供工程：war工程服务消费方
服务接口工程：jar工程，业务接口和实体类

对上面的工程改造，创建一个interface的java工程，此工程只有一个接口类


//注意实体类要实现Serializable
public class User implements Serializable {
    private String name;
    private String sex;
 
    public String getName() {
        return name;
    }
 
    public void setName(String name) {
        this.name = name;
    }
 
    public String getSex() {
        return sex;
    }
 
    public void setSex(String sex) {
        this.sex = sex;
    }
}
 
//接口
public interface MsgService {
    String hello(String hello);
}

provider工程需要修改的地方

1、pom依赖引入接口坐标


    
      org.example
      interface
      1.0-SNAPSHOT

2、删除provider原有的接口

3、实现类实现接口工程的接口和方法

4、核心xml


"1.0" encoding="UTF-8"?>
"http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    
    "dubbo-provider"/>
    "dubbo" port="20880"/>
    
    "service.MsgService" ref="msgServiceImpl" registry="N/A"/>
    
    "msgServiceImpl" class="service.impl.MsgServiceImpl"/>

consumer工程需要修改地方

1、pom依赖删掉之前的provider坐标，增加interface工程坐标

2、springApplicationContext文件


"1.0" encoding="UTF-8"?>
"http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
    "dubbo-consumer"/>
    
    "service.MsgService"
                     id="msgService"
                     url="dubbo://localhost:20880"
                     registry="N/A"/>

3、测试


@RestController
public class MsgController {
    //接口工程接口bean
    @Autowired
    private MsgService msgService;
 
    @RequestMapping("hello")
    public String hello(Model model){
        String msg = msgService.hello("ni hao");
        model.addAttribute("msg",msg);
        return "index";
    }
}

四、dubbo结合注册中心使用

上面说的直连方式在企业项目中基本不会使用，因为随着项目系统复杂，服务的数量增加，通过注册中心可以统一的管理服务，实际管理的就是服务url地址

注册中心可以有很多种，dubbo官方推荐使用zookeeper

关于zookeeper学习参考文章 ZooKeeper_程序三两行的博客-CSDN博客_zookeeper

1、创建接口工程interface

maven创建一个java工程即可，创建服务接口类


public interface MsgService {
    String hello(String hello);
}

接口和上面直连方式一样没有什么变化

2、创建服务提供者provider

maven创建一个web工程，相较于直连方式，引入依赖有所变化


"1.0" encoding="UTF-8"?>
 
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0modelVersion>
 
  <groupId>org.examplegroupId>
  <artifactId>providerartifactId>
  <version>1.0-SNAPSHOTversion>
  <packaging>warpackaging>
 
  <dependencies>
    
    <dependency>
      <groupId>com.alibabagroupId>
      <artifactId>dubboartifactId>
      <version>2.6.2version>
    dependency>
    
    <dependency>
      <groupId>org.apache.curatorgroupId>
      <artifactId>curator-frameworkartifactId>
      <version>4.1.0version>
    dependency>
    
    <dependency>
      <groupId>org.springframeworkgroupId>
      <artifactId>spring-contextartifactId>
      <version>4.3.16.RELEASEversion>
    dependency>
    
    <dependency>
      <groupId>org.springframeworkgroupId>
      <artifactId>spring-webmvcartifactId>
      <version>4.3.16.RELEASEversion>
    dependency>
    
    <dependency>
      <groupId>org.examplegroupId>
      <artifactId>interfaceartifactId>
      <version>1.0-SNAPSHOTversion>
    dependency>
  dependencies>
project>

核心配置文件


"1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
    <dubbo:application name="dubbo-provider"/>
    <dubbo:protocol name="dubbo" port="20880"/>
    
    <dubbo:registry address="zookeeper://localhost:2181"/>
    <dubbo:service interface="service.MsgService" ref="msgServiceImpl"/>
    <bean id="msgServiceImpl" class="service.impl.MsgServiceImpl"/>
beans>

其他代码和上面直连方式一样

3、创建服务消费者consumer

依赖和provider一样

核心配置文件


"1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
    <dubbo:application name="dubbo-consumer"/>
    
    <dubbo:registry address="zookeeper://localhost:2181"/>
 
    <dubbo:reference id="msgService" interface="service.MsgService"/>
beans>

其他代码和上面直连方式一样

4、测试


@RestController
public class MsgController {
    //接口工程接口bean
    @Autowired
    private MsgService msgService;
 
    @RequestMapping("hello")
    public String hello(Model model){
        String msg = msgService.hello("ni hao");
        return msg;
    }
}

5、查看zookeeper目录

五、dubbo配置

关于dubbo相关的配置，我们一般都在服务提供者工程中进行配置，因为服务提供正更了解服务的各种参数

1、关闭检查

dubbo默认是开启检查依赖服务的，我们可以在配置文件中关闭


    
    <dubbo:registry address="zookeeper://localhost:2181" check="false"/>
 
    
    <dubbo:reference interface="service.RoleService" check="false"/>

2、重试次数

消费着访问服务提供者，如果访问失败，则切换重试访问其他服务器，但是切换会带来更长的延迟，访问时间变长，影响用户体验，通过retries="2"来设置重试次数


    <dubbo:service retries="2" interface=""/>
或
    <dubbo:reference retries="2" interface=""

这个配置一般不用设置，默认重试一次就行

3、超时时间

服务提供和访问超时时间，一般只在服务提供者设置就行

 <dubbo:service interface="service.MsgService" ref="msgServiceImpl" timeout="500"/>

4、版本号

随着项目的迭代更新，一个接口服务可能有多个实现类，区分不同的接口实现使用version

如下provider工程增加一个服务实现类MsgServiceImpl2

配置文件变化


"1.0" encoding="UTF-8"?>
"http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
    "dubbo-provider"/>
    "dubbo" port="20880"/>
 
    "zookeeper://localhost:2181"/>
 
    
    "service.MsgService" ref="msgServiceImpl" version="1.0"/>
    "service.MsgService" ref="msgServiceImpl" version="2.0"/>
 
    "msgServiceImpl" class="service.impl.MsgServiceImpl"/>

consumer配置文件


"1.0" encoding="UTF-8"?>
"http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
    "dubbo-consumer"/>
    
    "zookeeper://localhost:2181"/>
 
    
    "msgService" interface="service.MsgService" version="1.0"/>
    "msgService2" interface="service.MsgService" version="2.0"/>

测试


@RestController
public class MsgController {
    //接口工程接口bean
    @Autowired
    private MsgService msgService;
    
    @Autowired
    private MsgService msgService2;
    
 
    @RequestMapping("hello")
    public String hello(Model model){
        String msg = msgService.hello("ni hao");
        String msg2 = msgService2.hello("ni hao 2");
        return msg+"==="+msg2;
    }
}

六、监控中心

dubbo-admin可视化的dubbo服务管理，安装时候需要指定注册中心，启动时候从注册中心获取服务消费者和提供者管理

参考使用

(4条消息) dubbo-admin安装以及dubbo-admin简单使用_尤雨东的博客-CSDN博客_dubbo-admin

相关阅读:
mui tap事件，mui.confirm弹窗出现两次
 B. Kalindrome Array
手把手教你，如何利用积木易搭3D扫描仪完成文物三维建模？
数据结构01
SpringBoot 事务与AOP
JavaScript-内置对象
 【小程序】微信公众号模板消息跳转小程序发送失败：errcode=40013 , errmsg=invalid appid rid:...
Fair原理篇Fair逻辑动态化架构设计与实现
 js中dom和bom有什么区别
 如何获得jd商品分类API数据
原文地址：https://blog.csdn.net/qq_34491508/article/details/125909041