RPC框架（二）dubbo简介

一、dubbo简介

二、dubbo示例
2.1、准备示例工程

三、dubbo provide
3.1、项目结构

3.2、pom.xml文件配置

3.3、配置文件

3.4、服务提供

四、dubbo consumer
4.1、项目结构

4.2、pom.xml文件配置

4.3、配置文件

4.4、服务实现

4.5、服务调用

五、dubbo案例运行
5.1、运行zookeeper

5.2、运行dubbo-provide

5.2、运行dubbo-consumer

5.3、访问dubbo-consumer

在上一篇文章RPC框架（一）RPC简介中简单介绍了一下RPC，本篇会介绍一会当下比较流行的RPC框架dubbo。

一、dubbo简介

dubbo是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，是阿里巴巴SOA服务化治理方案的核心框架，每天为2,000+个服务提供3,000,000,000+次访问量支持，并被广泛应用于阿里巴巴集团的各成员站点。

——摘自dubbo官网（http://dubbo.io/）

二、dubbo示例

2.1、准备示例工程

您可以在以下站点下载后文中提到的各种组件：

DUBBO官网和用户手册：

http://dubbo.io/

http://dubbo.io/books/dubbo-user-book/

DUBBO服务治理框架V2.5.3版本：

http://dubbo.io/ 可下载最新的版本2.6.0

zookeeper官网：

http://zookeeper.apache.org/

Maven官网：

http://maven.apache.org/

Maven官方仓库：

http://mvnrepository.com/

Spring Boot官网：

https://projects.spring.io/spring-boot/

三、dubbo provide

3.1、项目结构

我用的sts（类似于Eclipse，spring官方推荐开发spring项目）创建了一个maven项目 名为dubbo-provide，项目结构如下图：

3.2、pom.xml文件配置

pom.xml配置如下：

<?xml version="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.0</modelVersion>

<groupId>com.example</groupId>
<artifactId>demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>demo</name>
<description>Demo project for Spring Boot</description>

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.0.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>

<dependencies>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>

<!-- Spring Boot Dubbo 依赖 -->
<dependency>
<groupId>io.dubbo.springboot</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.6</version>
</dependency>

<!-- mvn spring-boot:run 热部署启动 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>springloaded</artifactId>
<version>1.2.3.RELEASE</version>
</dependency>

</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

</project>

spring-boot-start-dubbo，让你可以使用spring-boot的方式开发dubbo程序。使dubbo开发变得如此简单。 https://github.com/dubbo/dubbo-spring-boot-project

3.3、配置文件

由于我们使用的是Spring-Boot 进行开发，那么我们就应该善于利用Spring-Boot 给我们带来的优势，因此我们可以直接在application.properties文件中配置Dubbo 服务。

application.properties配置如下：

## Dubbo 服务提供者配置

server.port=8081
## 服务名称
spring.dubbo.application.name=provider
## 注册中心明称
spring.dubbo.registry.protocol=zookeeper
## 注册中心地址
spring.dubbo.registry.address=192.168.2.100:2281,192.168.2.100:2282,192.168.2.100:2283
## dubbo 协议
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=20880

## 声明需要暴露的服务接口
spring.dubbo.scan=com.cn.service

zookeeper的伪集群请参考 zookeeper（三）windows zookeeper单机伪集群这篇文章，当然了单机的zookeeper也可以。

3.4、服务提供

在服务提供主要包括两部分，一个是暴露服务，一个是服务实现

暴露服务：即我们平常开发中所使用的的接口，这里我们创建一个 UserService 的接口，主要包括一个保存用户的方法。

package com.cn.service;

import com.cn.vo.User;

public interface UserService {
public User findUser(Integer userId);
}

服务实现：服务实现，与我们平常的服务一样，对接口进行实现，比较特别的是，我们这里需要使用到Dubbo 的 @Service 注解

package com.cn.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.cn.service.UserService;
import com.cn.vo.User;

@Service(version="1.0.0")
public class UserServiceImpl implements UserService {

@Override
public User findUser(Integer userId) {
User user = new User();
user.setAge("25");
user.setName("张三");
return user;
}
}

User类如下：

package com.cn.vo;

import java.io.Serializable;

public class User  implements Serializable{

/**
*
*/
private static final long serialVersionUID = 1L;

private String name;

private String age;

public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getAge() {
return age;
}
public void setAge(String age) {
this.age = age;
}
}

服务启动类如下：

package com.cn;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;

@SpringBootApplication
public class MySpringBootApplication extends SpringBootServletInitializer {
@Override
protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
return application.sources(MySpringBootApplication.class);
}

public static void main(String[] args) {
SpringApplication.run(MySpringBootApplication.class, args);
}
}

这时服务生产者项目创建完成。

四、dubbo consumer

4.1、项目结构

4.2、pom.xml文件配置

pom.xml配置如下：

<?xml version="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.0</modelVersion>

<groupId>com.example</groupId>
<artifactId>demo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>demo</name>
<description>Demo project for Spring Boot</description>

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.0.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>

<dependencies>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>

<!-- Spring Boot Dubbo 依赖 -->
<dependency>
<groupId>io.dubbo.springboot</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.6</version>
</dependency>

<!-- mvn spring-boot:run 热部署启动 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>springloaded</artifactId>
<version>1.2.3.RELEASE</version>
</dependency>

</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

</project>

4.3、配置文件

application.properties配置如下：

## 避免和 server 工程端口冲突
server.port=8082

## Dubbo 服务消费者配置
spring.dubbo.application.name=consumer
## 注册中心类型
spring.dubbo.registry.protocol=zookeeper
## 注册中心地址
spring.dubbo.registry.address=192.168.2.100:2281,192.168.2.100:2282,192.168.2.100:2283

spring.dubbo.scan=com.cn.service

4.4、服务实现

在这里，如果我们需要调用注册服务中的相关服务，则需要实现相关的接口。

package com.cn.service;

import com.cn.vo.User;

public interface UserService {
public User findUser(Integer userId);
}

例如，在这里我们需要使用到生产者中的方法，则需要创建一个接口，然后再调用时，使用 @Reference 注解进行引用：

package com.cn.service;

import org.springframework.stereotype.Component;

import com.alibaba.dubbo.config.annotation.Reference;
import com.cn.vo.User;

@Component
public class CityDubboConsumerService {

@Reference(version="1.0.0")
UserService userService;

public User findUser(Integer xx) {
User user = userService.findUser(256);
return user;
}
}

4.5、服务调用

　　最后，我们需要实现一个RESTful 接口，提供给用户调用：

　　

package com.cn.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.cn.service.CityDubboConsumerService;

@RestController
public class UserController {
@Autowired
private CityDubboConsumerService service;

@RequestMapping("/findUser")
public Object saveUser(Integer xx) {
return service.findUser(xx);
}
}

User类 和服务启动类相同。参考上面

五、dubbo案例运行

5.1、运行zookeeper

zookeeper的伪集群请参考 zookeeper（三）windows zookeeper单机伪集群这篇文章，我是按照这个搭建的伪集群。

5.2、运行dubbo-provide

5.2、运行dubbo-consumer

5.3、访问dubbo-consumer

即访问http://localhost:8082/findUser 访问后得到下图：



大功告成，恭喜你成功了！