分布式框架Dubbo入门

2020 年 8 月 20 日
筆記
Dubbo

Dubbo简介

Apache Dubbo是一款高性能的Java RPC框架。其前身是阿里巴巴公司开源的一个高性能、轻量级的开源Java RPC框架，可以和Spring框架无缝集成。

dubbo官方中文文档地址

Dubbo结构介绍

快速部署

一、配置注册中心，官方推荐使用`zookeeper`

zookeeper说明文档
 下载地址

zoo.cfg配置文件介绍

// 数据存储目录，修改数据存储目录 ../data 复制的时候注意，小心空格
dataDir=/tmp/zookeeper 
//默认配置文件，修改路径如下
dataDir=../data 
// 端口
clientPort=2181

bin目录下zkEnv文件注意事项
启动zookeeper服务：zkServer

二、简单Dubbo项目部署步骤

公共接口服务

1. 创建一个公共接口工程 dubbodemo_interface

详情见maven使用链接

2. 创建一个HelloService接口

package com.atguigu.service;

/**
 * ClassName: HelloService
 * Description: 提供者服务层接口
 * date: 2020/8/20 10:44
 *
 * @author July
 * @since JDK 1.8
 */
public interface HelloService {
    String sayHello(String name);
}

服务提供者

1. 创建一个服务提供者dubbodemo_provider（maven web工程）

详情见maven使用链接

2. 导入maven坐标

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="//maven.apache.org/POM/4.0.0" xmlns:xsi="//www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="//maven.apache.org/POM/4.0.0 //maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>

  <groupId>com.gtguigu</groupId>
  <artifactId>dubbodemo_provider</artifactId>
  <version>1.0-SNAPSHOT</version>
  <packaging>war</packaging>


  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>
    <spring.version>5.0.5.RELEASE</spring.version>
  </properties>
  <dependencies>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-beans</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-jdbc</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-aspects</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-jms</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context-support</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <!-- dubbo相关 -->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.6.0</version>
    </dependency>
    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.7</version>
    </dependency>
    <dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
    </dependency>
    <dependency>
      <groupId>javassist</groupId>
      <artifactId>javassist</artifactId>
      <version>3.12.1.GA</version>
    </dependency>
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>fastjson</artifactId>
      <version>1.2.47</version>
    </dependency>

    <dependency>
      <groupId>com.atguigu</groupId>
      <artifactId>dubbodemo_interface</artifactId> //导入公共抽取接口坐标
      <version>1.0-SNAPSHOT</version>
    </dependency>

  </dependencies>
  <build>
    <plugins>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <version>2.3.2</version>
        <configuration>
          <source>1.8</source>
          <target>1.8</target>
        </configuration>
      </plugin>
      <plugin>
        <groupId>org.apache.tomcat.maven</groupId>
        <artifactId>tomcat7-maven-plugin</artifactId>
        <configuration>
          <!-- 指定端口 -->
          <port>8082</port>
          <!-- 请求路径 -->
          <path>/</path>
        </configuration>
      </plugin>
    </plugins>
  </build>
</project>

3. 创建提供者实现类

已经在提供者的pom.xml已经导入了公共接口HelloService的坐标，所以直接可以使用HelloService接口

//直接创建实现类
package com.atguigu.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.atguigu.service.HelloService;

/**
 * ClassName: HelloServiceImpl
 * Description:
 * date: 2020/8/20 10:45
 *
 * @author July
 * @since JDK 1.8
 */
//注意，使用的是com.alibaba.dubbo.config.annotation.Service;
@Service
public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

注意事项：@Service 使用的是com.alibaba.dubbo.config.annotation.Service

4. 配置web.xml

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

5. 用 Spring 配置声明暴露服务

provida.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="//www.springframework.org/schema/beans"
       xmlns:xsi="//www.w3.org/2001/XMLSchema-instance"
       xmlns:p="//www.springframework.org/schema/p"
       xmlns:context="//www.springframework.org/schema/context"
       xmlns:dubbo="//code.alibabatech.com/schema/dubbo"
       xmlns:mvc="//www.springframework.org/schema/mvc"
       xsi:schemaLocation="//www.springframework.org/schema/beans
		//www.springframework.org/schema/beans/spring-beans.xsd
         //www.springframework.org/schema/mvc
         //www.springframework.org/schema/mvc/spring-mvc.xsd
         //code.alibabatech.com/schema/dubbo
         //code.alibabatech.com/schema/dubbo/dubbo.xsd
         //www.springframework.org/schema/context
         //www.springframework.org/schema/context/spring-context.xsd">
    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="hello-world-app"  />

    <!-- 使用注册中心暴露服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />

    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />

    <!-- 扫描指定包，加入@Service注解的类会被发布为服务  -->
    <dubbo:annotation package="com.atguigu.service.impl" />
</beans>

服务消费者(参照提供者配置)

1. 创建一个服务消费者dubbodemo_consumer（maven web工程）

详情见maven使用链接

2. 导入坐标，和提供者相同，只需要把tomcat端口号修改下即可

      <plugin>
        <groupId>org.apache.tomcat.maven</groupId>
        <artifactId>tomcat7-maven-plugin</artifactId>
        <configuration>
          <!-- 指定端口 -->
          <port>8083</port>  //修改端口号，不要冲突
          <!-- 请求路径 -->
          <path>/</path>
        </configuration>
      </plugin>

3. 通过 Spring 配置引用远程服务

consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="//www.springframework.org/schema/beans"
       xmlns:xsi="//www.w3.org/2001/XMLSchema-instance"
       xmlns:p="//www.springframework.org/schema/p"
       xmlns:context="//www.springframework.org/schema/context"
       xmlns:dubbo="//code.alibabatech.com/schema/dubbo"
       xmlns:mvc="//www.springframework.org/schema/mvc"
       xsi:schemaLocation="//www.springframework.org/schema/beans
			//www.springframework.org/schema/beans/spring-beans.xsd
			//www.springframework.org/schema/mvc
			//www.springframework.org/schema/mvc/spring-mvc.xsd
			//code.alibabatech.com/schema/dubbo
			//code.alibabatech.com/schema/dubbo/dubbo.xsd
			//www.springframework.org/schema/context
			//www.springframework.org/schema/context/spring-context.xsd">

    <!-- 当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样 -->
    <dubbo:application name="dubbodemo-consumer" />
    <!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    <!-- 扫描的方式暴露接口  -->
    <dubbo:annotation package="com.atguigu.controller" />
    <!-- 运行dubbo不检查提供者是否提前开启  -->
    <!-- <dubbo:consumer check="false"></dubbo:consumer> -->
</beans>

4. 编写消费者实现类

package com.atguigu.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.atguigu.service.HelloService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

/**
 * ClassName: HelloController
 * Description:
 * date: 2020/8/20 11:09
 *
 * @author July
 * @since JDK 1.8
 */
@Controller
@RequestMapping("/demo")
public class HelloController {
    @Reference //注意使用com.alibaba.dubbo.config.annotation.Reference
    private HelloService helloService; //由于已经在maven依赖中导入了HelloService接口，所以可以直接调用

    //远程调用
    @RequestMapping("/hello")
    @ResponseBody
    public String sayHello(String name){
        String s = helloService.sayHello(name);
        System.out.println(s);
        return s;
    }
}

5. 配置web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="//xmlns.jcp.org/xml/ns/javaee"
         xmlns:xsi="//www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="//xmlns.jcp.org/xml/ns/javaee //xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"
         version="3.1">

  <servlet>
    <servlet-name>springmvc</servlet-name>
      <!-- 配置前端控制器 -->
    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    <!-- 指定加载的配置文件 ，通过参数contextConfigLocation加载 -->
    <init-param>
      <param-name>contextConfigLocation</param-name>
      <param-value>classpath:applicationContext-web.xml</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
  </servlet>
  <servlet-mapping>
    <servlet-name>springmvc</servlet-name>
    <url-pattern>/</url-pattern>
  </servlet-mapping>

</web-app>

测试访问

1. 启动zookeeper服务 `zkServer`

2. 启动tomcat服务

注意事项：需要先启动提供者服务，在启动消费者服务

3. 测试访问资源

可以看到资源访问没问题

Tags: Dubbo

分布式框架Dubbo入门

Dubbo简介

Dubbo结构介绍

快速部署

一、配置注册中心，官方推荐使用`zookeeper`

二、简单Dubbo项目部署步骤

公共接口服务

1. 创建一个公共接口工程 dubbodemo_interface

2. 创建一个HelloService接口

服务提供者

1. 创建一个服务提供者dubbodemo_provider（maven web工程）

2. 导入maven坐标

3. 创建提供者实现类

4. 配置web.xml

5. 用 Spring 配置声明暴露服务

服务消费者(参照提供者配置)

1. 创建一个服务消费者dubbodemo_consumer（maven web工程）

2. 导入坐标，和提供者相同，只需要把tomcat端口号修改下即可

3. 通过 Spring 配置引用远程服务

4. 编写消费者实现类

5. 配置web.xml

测试访问

1. 启动zookeeper服务 `zkServer`

2. 启动tomcat服务

3. 测试访问资源

VirMach 便宜 VPS

QNews

分布式框架Dubbo入门

Dubbo简介

Dubbo结构介绍

快速部署

一、配置注册中心，官方推荐使用zookeeper

二、简单Dubbo项目部署步骤

公共接口服务

1. 创建一个公共接口工程 dubbodemo_interface

2. 创建一个HelloService接口

服务提供者

1. 创建一个服务提供者dubbodemo_provider（maven web工程）

2. 导入maven坐标

3. 创建提供者实现类

4. 配置web.xml

5. 用 Spring 配置声明暴露服务

服务消费者(参照提供者配置)

1. 创建一个服务消费者dubbodemo_consumer（maven web工程）

2. 导入坐标，和提供者相同，只需要把tomcat端口号修改下即可

3. 通过 Spring 配置引用远程服务

4. 编写消费者实现类

5. 配置web.xml

测试访问

1. 启动zookeeper服务 zkServer

2. 启动tomcat服务

3. 测试访问资源

分享此文：

Related Posts

openstack 创建虚拟机失败

MindSpore函数拟合

线上摆摊走起 腾讯宣布微信小商店全量开放：0元开店

特斯拉Roadster将2021年投产：配推进器 1.9s破百

VirMach 便宜 VPS

QNews

熱門搜尋

一、配置注册中心，官方推荐使用`zookeeper`

1. 启动zookeeper服务 `zkServer`

线上摆摊走起腾讯宣布微信小商店全量开放：0元开店