Dubbo——初识Dubbo框架使用直连方式实现Dubbo

Posted 张起灵-小哥

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Dubbo——初识Dubbo框架使用直连方式实现Dubbo相关的知识,希望对你有一定的参考价值。

文章目录:

1.Dubbo概述

1.1基本架构

1.2 dubbo支持的协议

2.直连方式实现dubbo

2.1 服务提供者的创建

2.2 服务消费者的创建

2.3 启动测试!!!


1.Dubbo概述

Apache Dubbo (incubating) |ˈdʌbəʊ| 是一款高性能、轻量级的开源 Java RPC 框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。

Dubbo 是一个分布式服务框架,致力于提供高性能和透明化的 RPC 远程服务调用方案、 服务治理方案。

官网:https://dubbo.apache.org/zh/

1.1基本架构

  1. 服务提供者( (Provider) ):暴露服务的服务提供方,服务提供者在启动时,向注册中心注册自己提供的服务。
  2. 服务消费者( (Consumer ): 调用远程服务的服务消费方,服务消费者在启动时,向注册中心订阅自己所需的服务,服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。
  3. 注册中心( (Registry) ):注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。
  4. 监控中心( (Monitor) ):服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。
  • 服务容器负责启动,加载,运行服务提供者。
  • 服务提供者在启动时,向注册中心注册自己提供的服务。
  • 服务消费者在启动时,向注册中心订阅自己所需的服务。
  • 注册中心返回服务提供者地址列表给消费者,如果有变更,注册中心将基于长连接推送变更数据给消费者。
  • 服务消费者,从提供者地址列表中,基于软负载均衡算法,选一台提供者进行调用,如果调用失败,再选另一台调用。
  • 服务消费者和提供者,在内存中累计调用次数和调用时间,定时每分钟发送一次统计数据到监控中心。

1.2 dubbo支持的协议

支持多种协议:dubbo , hessian , rmi , http, webservice , thrift , memcached , redis。

dubbo 官方推荐使用 dubbo 协议。dubbo 协议默认端口 20880

使用 dubbo 协议,spring 配置文件加入:<dubbo:protocol name="dubbo" port="20880" />


2.直连方式实现dubbo

点对点的直连项目:消费者直接访问服务提供者,没有注册中心。消费者必须指定服务提供者的访问地址(url)。

消费者直接通过 url 地址访问固定的服务提供者。这个 url 地址是不变的。

 

2.1 服务提供者的创建

1.创建一个maven web工程:服务的提供者,添加需要的依赖
2.创建一个实体bean查询的结果(必须实现序列化)
3.提供一个服务接口:xxxx
4.实现这个服务接口:xxxxImpl
5.配置dubbo服务提供者的核心配置文件
   a.声明dubbo服务提供者的名称:保证唯一
   b.声明dubbo使用的协议和端口号
   c.暴露服务,使用直连方式
6.添加监听器,读取配置文件信息

代码如下:👇👇👇(代码顺序对应上面的序号)

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context</artifactId>
      <version>5.2.5.RELEASE</version>
    </dependency>

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>5.2.5.RELEASE</version>
    </dependency>

    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.6.2</version>
    </dependency>
package com.szh.dubbo.model;

import java.io.Serializable;

/**
 *
 */
public class User implements Serializable {

    private Integer id;
    private String name;
    private Integer age;

    //getter and setter
}
package com.szh.dubbo.service;

import com.szh.dubbo.model.User;

/**
 *
 */
public interface UserService {

    User queryUserById(Integer id);
}
package com.szh.dubbo.service.impl;

import com.szh.dubbo.model.User;
import com.szh.dubbo.service.UserService;

/**
 *
 */
public class UserServiceImpl implements UserService {
    @Override
    public User queryUserById(Integer id) {

        User user=new User();
        user.setId(id);
        user.setName("张起灵");
        user.setAge(21);

        return user;
    }
}
<?xml version="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://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <!-- 声明dubbo服务提供者的名称:保证唯一性 -->
    <dubbo:application name="001-link-userservice-provider"/>

    <!-- 设置dubbo使用的协议和端口号 -->
    <dubbo:protocol name="dubbo" port="20880"/>

    <!-- 暴露服务接口 -->
    <dubbo:service interface="com.szh.dubbo.service.UserService" ref="a" registry="N/A"/>

    <!-- 将业务接口的实现类加载到Spring容器中 -->
    <bean id="a" class="com.szh.dubbo.service.impl.UserServiceImpl"/>

</beans>
<?xml version="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_4_0.xsd"
         version="4.0">

    <!-- 读取dubbo配置文件信息 -->
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:dubbo-userservice-provider.xml</param-value>
    </context-param>
    <!-- 配置Spring的监听器 -->
    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>
</web-app>

2.2 服务消费者的创建

1.创建一个maven web工程:服务的消费者
2.配置pom文件:添加需要的依赖(spring,dubbo)
3.编写controller
4.设置dubbo的核心配置文件()
5.配置中央调度器(就是一个servlet:DispatcherServlet)

代码如下:(代码顺序对应上面的序号)

服务提供者接口中的方法要给消费者使用,消费者项目需要知道接口名称和接口中的方法名称、参数等。这些信息服务提供者才知道。需要把服务提供者接口对应工程的 class 文件打包为 jar 。

服务接口项目的类文件打包为 jar, 安装到 maven 仓库,仓库中的提供者 jar 可以被消费者使用。

使用 idea 的 maven 生命周期中的 install 命令进行打包(打包的时候将pom文件中的 <packaging>war</packaging> 内容注释掉,因为在服务消费者的pom文件中进行依赖项的导入是一个jar包)。也就是下面pom文件中的最后一个依赖项。

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context</artifactId>
      <version>5.2.5.RELEASE</version>
    </dependency>

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>5.2.5.RELEASE</version>
    </dependency>

    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.6.2</version>
    </dependency>

    <dependency>
      <groupId>com.szh.dubbo</groupId>
      <artifactId>001-link-userservice-provider</artifactId>
      <version>1.0.0</version>
    </dependency>
package com.szh.dubbo.controller;

import com.szh.dubbo.model.User;
import com.szh.dubbo.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;

/**
 *
 */
@Controller
public class UserController {

    @Autowired
    private UserService userService;

    @RequestMapping(value = "/user")
    public String userDetail(Integer id, Model model) {
        User user=userService.queryUserById(id);
        model.addAttribute("user",user);
        return "userDetail";
    }
}
<?xml version="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://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <!-- 声明服务消费者名称:保证唯一性 -->
    <dubbo:application name="002-link-consumer"/>

    <!-- 引用远程接口服务 -->
    <dubbo:reference interface="com.szh.dubbo.service.UserService"
                     id="userService"
                     url="dubbo://localhost:20880"
                     registry="N/A"/>

</beans>
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="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 https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/mvc https://www.springframework.org/schema/mvc/spring-mvc.xsd">

    <!-- 组件扫描器,扫描controller包下的注解 -->
    <context:component-scan base-package="com.szh.dubbo.controller"/>

    <!-- 开启SpringMVC注解驱动 -->
    <mvc:annotation-driven/>

    <!-- 配置视图解析器 -->
    <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="prefix" value="/"/>
        <property name="suffix" value=".jsp"/>
    </bean>

</beans>
<?xml version="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_4_0.xsd"
         version="4.0">

    <!-- 配置SpringMVC的中央调度器,读取Spring、Dubbo配置文件信息 -->
    <servlet>
        <servlet-name>DispatcherServlet</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>classpath:applicationContext.xml,classpath:dubbo-consumer.xml</param-value>
        </init-param>
    </servlet>
    <servlet-mapping>
        <servlet-name>DispatcherServlet</servlet-name>
        <url-pattern>/</url-pattern>
    </servlet-mapping>

</web-app>
<%@ page contentType="text/html;charset=utf-8" language="java" %>
<html>
<head>
    <title>$</title>
</head>
<body>
    <h1>用户详情</h1>
    <div>用户编号:${user.id}</div>
    <div>用户姓名:${user.name}</div>
</body>
</html>

2.3 启动测试!!!

上面两步,我们已经创建好了服务提供者和服务消费者,下面分别为这两个maven web工程配置各自的tomcat服务器。

配置信息如下:👇👇👇(均不设置上下文根)

配置好Tomcat之后,我们就可以启动测试了,这里需要注意的是:一定要先启动第一个maven web工程(服务提供者)的tomcat服务器;启动成功后,再启动第二个maven web工程的(服务消费者)tomcat服务器。因为顾名思义:肯定是先有提供,才能进行消费啊。

下面是测试结果:👇👇👇(访问控制层中的请求路径,可以正确的拿到数据,这就说明我们使用直连方式实现了dubbo)

 

以上是关于Dubbo——初识Dubbo框架使用直连方式实现Dubbo的主要内容,如果未能解决你的问题,请参考以下文章

初识Dubbo 系列之5-Dubbo 成熟度

dubbo初识Dubbo架构设计详解

初识dubbo

dubbo可通过指定Url方式绕过注册中心直连指定的服务地址

dubbo-本地直连

Dubbo -- 系统学习 笔记 -- 示例 -- 直连提供者