一、準備工作
Dubbo中文官網：http://dubbo.apache.org/zh-cn/docs/user/quick-start.html
Github上 Apache Dubbo 最新版本（未打包）： https://github.com/apache/dubbo-spring-boot-project
Github（已經打成stater）： https://github.com/alibaba/dubbo-spring-boot-starter
ZooKeeper下載下傳位址 http://www.apache.org/dyn/closer.cgi/zookeeper
運作環境：JDK8、Maven 3.3.9、MySql 5.5.15、IntelliJ IDEA 2019.1.1
技術棧：SpringBoot 2.1.1、Dubbo 2.7.1、ZooKeeper 3.4.14、MyBatis 2+
二、建立工程
1.建立三個工程
1.1.建立普遍的Maven Java工程(comm-api)，用于存放實體類，API：
1.1.1 UserService 接口
package org.my.dubbo.api;
import org.my.dubbo.entity.UserEntity;
import java.util.List;
public interface UserService {
/**
* 擷取所有使用者清單
* @return
*/
List<UserEntity> findAll();
/**
* 工具登入名，密碼擷取使用者
* @param u_login_id
* @param u_password
* @return
*/
UserEntity getUserById(String u_login_id, String u_password);
}
1.1.2 UserEntity 實體類
package org.my.dubbo.entity;
import java.io.Serializable;
public class UserEntity implements Serializable {
public String id;
public String u_name;
public String u_login_id;
public String u_password;
public String u_age;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getU_name() {
return u_name;
}
public void setU_name(String u_name) {
this.u_name = u_name;
}
public String getU_login_id() {
return u_login_id;
}
public void setU_login_id(String u_login_id) {
this.u_login_id = u_login_id;
}
public String getU_password() {
return u_password;
}
public void setU_password(String u_password) {
this.u_password = u_password;
}
public String getU_age() {
return u_age;
}
public void setU_age(String u_age) {
this.u_age = u_age;
}
}
1.2.建立Spring Boot Web 工程（dobbo-registry-zookeeper-provider），用于提供服務：
1.2.1 dobbo-registry-zookeeper-provider工程的pom檔案
<?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>
<version>1.0-SNAPSHOT</version>
<groupId>dubbo.registry.zookeeper.provider.sample</groupId>
<artifactId>dubbo.registry.zookeeper.provider.sample</artifactId>
<name>dubbo.registry.zookeeper.provider</name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.7</maven.compiler.source>
<maven.compiler.target>1.7</maven.compiler.target>
<spring-boot.version>2.1.1.RELEASE</spring-boot.version>
<dubbo.version>2.7.1</dubbo.version>
<mysql.connector>5.1.39</mysql.connector>
<mybatis.spring-boot>2.0.0</mybatis.spring-boot>
</properties>
<dependencyManagement>
<dependencies>
<!-- Spring Boot -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>${spring-boot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- Aapche Dubbo -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-bom</artifactId>
<version>${dubbo.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo</artifactId>
<version>${dubbo.version}</version>
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
<exclusion>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
</exclusion>
<exclusion>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
</dependencyManagement>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.4.RELEASE</version>
</parent>
<dependencies>
<!-- spring boot web -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Dubbo Spring Boot Starter-->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>${dubbo.version}</version>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo</artifactId>
</dependency>
<!-- Zookeeper dependencies -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-zookeeper</artifactId>
<version>${dubbo.version}</version>
<type>pom</type>
</dependency>
<!--暴露接口的依賴 第一個工程的包-->
<dependency>
<groupId>org.my.dubbo.api</groupId>
<artifactId>org.my.dubbo.api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!-- Spring Boot Test 依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!-- Spring Boot Mybatis 依賴 -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>${mybatis.spring-boot}</version>
</dependency>
<!-- MySQL 連接配接驅動依賴 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>${mysql.connector}</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.30</version>
</dependency>
</dependencies>
</project>
1.2.2 dobbo-registry-zookeeper-provider工程的application.properties檔案
server.port=8888
spring.application.name=dubbo-registry-provider
## 資料源配置
spring.datasource.url=jdbc:mysql://localhost:3306/spring_boot_project?useUnicode=true&characterEncoding=utf8
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
## Mybatis 配置
mybatis.typeAliasesPackage=org.my.dubbo.entity
mybatis.mapperLocations=classpath:mapper/*.xml
##dubbo 配置
spring.dubbo.application.name=provider
dubbo.scan.base-packages=com.my.dubbo.providerm.serviceimpl
#通信規則
dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
## Dubbo Registry
#dubbo.registry.address=N/A
#注冊中心 協定 和位址
dubbo.registry.protocol=zookeeper
dubbo.registry.address=127.0.0.1:2181
service.api.version=1.0.0
1.2.3 dobbo-registry-zookeeper-provider工程的啟動入口App.class
package com.my.dubbo.providerm;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.alibaba.fastjson.support.config.FastJsonConfig;
import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
import org.springframework.context.annotation.Bean;
import org.springframework.http.converter.HttpMessageConverter;
/**
* P丶少 2019/06/16
*/
@MapperScan(basePackages="com.my.dubbo.providerm.dao")//掃描映射接口包
@SpringBootApplication
//@EnableAutoConfiguration
public class App {
/**
* 配置FastJson
* @return HttpMessageConverters
*/
@Bean
public HttpMessageConverters fastJsonHttpMessageConverters() {
// 1.定義一個converters轉換消息的對象
FastJsonHttpMessageConverter fastConverter = new FastJsonHttpMessageConverter();
// 2.添加fastjson的配置資訊，比如: 是否需要格式化傳回的json資料
FastJsonConfig fastJsonConfig = new FastJsonConfig();
fastJsonConfig.setSerializerFeatures(SerializerFeature.PrettyFormat);
// 3.在converter中添加配置資訊
fastConverter.setFastJsonConfig(fastJsonConfig);
// 4.将converter指派給HttpMessageConverter
HttpMessageConverter<?> converter = fastConverter;
// 5.傳回HttpMessageConverters對象
return new HttpMessageConverters(converter);
}
public static void main( String[] args ) {
SpringApplication.run(App.class,args);
}
}
1.2.4 dobbo-registry-zookeeper-provider工程的UserController .class
package com.my.dubbo.providerm.controller;
import org.my.dubbo.api.UserService;
import org.my.dubbo.entity.UserEntity;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.List;
@RestController
@RequestMapping("user")
public class UserController {
@Resource
private UserService userService;
/**
* 擷取所有使用者清單
* @return
*/
@RequestMapping(value = "findAll", method = RequestMethod.GET,produces="application/json;charset=UTF-8")
public List<UserEntity> findAll(){
// Map map =JSON.parseObject( JSON.toJSONString(obj),Map.class);
return userService.findAll();
}
/**
* 工具登入名，密碼擷取使用者
* @param u_login_id
* @param u_password
* @return
*/
@RequestMapping(value = "getUser", method = RequestMethod.GET,produces="application/json;charset=UTF-8")
public UserEntity getUser(@RequestParam String u_login_id,@RequestParam String u_password){
UserEntity userEntity = userService.getUserById(u_login_id,u_password);
return userEntity;
}
}
1.2.5 dobbo-registry-zookeeper-provider工程的UserDao .class
package com.my.dubbo.providerm.dao;
import org.my.dubbo.entity.UserEntity;
import org.springframework.stereotype.Repository;
import java.util.List;
@Repository
public interface UserDao {
/**
* 擷取所有使用者清單
* @return
*/
List<UserEntity> findAll();
/**
* 工具登入名，密碼擷取使用者
* @param u_login_id
* @param u_password
* @return
*/
UserEntity getUserById(String u_login_id,String u_password);
}
1.2.6 dobbo-registry-zookeeper-provider工程的UserServiceImpl .class
package com.my.dubbo.providerm.serviceimpl;
import com.my.dubbo.providerm.dao.UserDao;
import org.apache.dubbo.config.annotation.Service;
import org.my.dubbo.api.UserService;
import org.my.dubbo.entity.UserEntity;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
@Service(version = "${service.api.version}")
public class UserServiceImpl implements UserService {
@Autowired
private UserDao userDao;
/**
* 擷取所有使用者清單
* @return
*/
@Override
public List<UserEntity> findAll() {
return userDao.findAll();
}
/**
* 工具登入名，密碼擷取使用者
* @param u_login_id
* @param u_password
* @return
*/
@Override
public UserEntity getUserById(String u_login_id, String u_password) {
return userDao.getUserById(u_login_id,u_password);
}
}
1.2.7 dobbo-registry-zookeeper-provider工程的UserMapper.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.my.dubbo.providerm.dao.UserDao">
<resultMap id="BaseResultMap" type="org.my.dubbo.entity.UserEntity" >
<result column="id" property="id" />
<result column="u_name" property="u_name" />
<result column="u_login_id" property="u_login_id" />
<result column="u_password" property="u_password" />
<result column="u_age" property="u_age" />
</resultMap>
<sql id="Base_Column_List">
id, u_name, u_login_id, u_password ,u_age
</sql>
<select id="findAll" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from user
</select>
<select id="getUserById" resultMap="BaseResultMap" parameterType="org.my.dubbo.entity.UserEntity">
select
<include refid="Base_Column_List" />
from user
where
u_login_id = #{u_login_id}
and u_password = #{u_password}
</select>
</mapper>
1.3.建立Spring Boot Web 工程（dobbo-registry-zookeeper-consumer），用于消費服務：
1.3.1 dobbo-registry-zookeeper-consumer工程的pom檔案
<?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">
<artifactId>dubbo.registry.zookeeper.consumer.sample</artifactId>
<groupId>dubbo.registry.zookeeper.consumer.sample</groupId>
<version>1.0-SNAPSHOT</version>
<modelVersion>4.0.0</modelVersion>
<name>dubbo.registry.zookeeper.consumer</name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.7</maven.compiler.source>
<maven.compiler.target>1.7</maven.compiler.target>
<spring-boot.version>2.1.1.RELEASE</spring-boot.version>
<dubbo.version>2.7.1</dubbo.version>
</properties>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.4.RELEASE</version>
</parent>
<dependencyManagement>
<dependencies>
<!-- Spring Boot -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-dependencies</artifactId>
<version>${spring-boot.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<!-- Aapche Dubbo -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-bom</artifactId>
<version>${dubbo.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo</artifactId>
<version>${dubbo.version}</version>
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
<exclusion>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
</exclusion>
<exclusion>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Dubbo Spring Boot Starter-->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>${dubbo.version}</version>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo</artifactId>
</dependency>
<!-- Zookeeper dependencies -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-zookeeper</artifactId>
<version>${dubbo.version}</version>
<type>pom</type>
</dependency>
<!--暴露接口的依賴-->
<dependency>
<groupId>org.my.dubbo.api</groupId>
<artifactId>org.my.dubbo.api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.30</version>
</dependency>
</dependencies>
<repositories>
<repository>
<id>apache.snapshots.https</id>
<name>Apache Development Snapshot Repository</name>
<url>https://repository.apache.org/content/repositories/snapshots</url>
<releases>
<enabled>false</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
</repositories>
</project>
1.3.2 dobbo-registry-zookeeper-consumer工程的application.properties檔案
server.port=8083
spring.application.name=dubbo-registry-consumer-1.0
#注冊中心 協定 和位址
spring.dubbo.application.name=consumer
dubbo.registry.protocol=zookeeper
dubbo.registry.address=127.0.0.1:2181
service.api.version=1.0.0
1.3.3 dobbo-registry-zookeeper-consumer工程的啟動入口App.class
package com.my.dubbo.consumer;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.alibaba.fastjson.support.config.FastJsonConfig;
import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
import org.springframework.context.annotation.Bean;
import org.springframework.http.converter.HttpMessageConverter;
/**
* P丶少 2019/06/16
*/
//@EnableAutoConfiguration
@SpringBootApplication
public class App{
private final Logger logger = LoggerFactory.getLogger(getClass());
/**
* 配置FastJson
* @return HttpMessageConverters
*/
@Bean
public HttpMessageConverters fastJsonHttpMessageConverters() {
// 1.定義一個converters轉換消息的對象
FastJsonHttpMessageConverter fastConverter = new FastJsonHttpMessageConverter();
// 2.添加fastjson的配置資訊，比如: 是否需要格式化傳回的json資料
FastJsonConfig fastJsonConfig = new FastJsonConfig();
fastJsonConfig.setSerializerFeatures(SerializerFeature.PrettyFormat);
// 3.在converter中添加配置資訊
fastConverter.setFastJsonConfig(fastJsonConfig);
// 4.将converter指派給HttpMessageConverter
HttpMessageConverter<?> converter = fastConverter;
// 5.傳回HttpMessageConverters對象
return new HttpMessageConverters(converter);
}
public static void main( String[] args ) {
SpringApplication.run(App.class,args);
}
}
1.3.4 dobbo-registry-zookeeper-consumer工程的UserController .class
package com.my.dubbo.consumer.controller;
import org.apache.dubbo.config.annotation.Reference;
import org.my.dubbo.api.UserService;
import org.my.dubbo.entity.UserEntity;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@RestController
@RequestMapping("user")
public class UserController {
@Reference(version = "${service.api.version}")
private UserService userService;
@RequestMapping(value = "findAll", method = RequestMethod.GET,produces="application/json;charset=UTF-8")
public List<UserEntity> findAll(){//Object obj
// Map map = (Map) obj;
return userService.findAll();
}
@RequestMapping(value = "getUser", method = RequestMethod.GET,produces="application/json;charset=UTF-8")
public UserEntity getUser(@RequestParam String u_login_id, @RequestParam String u_password){
UserEntity userEntity = userService.getUserById(u_login_id,u_password);
return userEntity;
}
}
三、測試效果
1、資料庫：
/*
Navicat MySQL Data Transfer
Source Server : 本地
Source Server Version : 50515
Source Host : localhost:3306
Source Database : spring_boot_project
Target Server Type : MYSQL
Target Server Version : 50515
File Encoding : 65001
Date: 2019-06-16 00:53:34
*/
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for user
-- ----------------------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
`id` varchar(70) NOT NULL COMMENT '使用者id',
`u_name` varchar(100) NOT NULL COMMENT '使用者名稱',
`u_login_id` varchar(70) NOT NULL COMMENT '登入賬戶',
`u_password` varchar(100) NOT NULL DEFAULT '123456' COMMENT '登入密碼',
`u_age` varchar(3) NOT NULL DEFAULT '0' COMMENT '年齡',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO `user` VALUES ('1', '1', '1', '123456', '1');
INSERT INTO `user` VALUES ('2', '2', '2', '123456', '2');
2、頁面測試結果
四、總結
啟動過程：
先開啟本地 zookeeper ，
再啟動dobbo-registry-zookeeper-provider ,
繼續啟動 dobbo-registry-zookeeper-consumer
消費端使用遠端調用得用@Reference（version=xxx）
提供端得用org.apache.dubbo.config.annotation.Service 的注解：格式：@Service （version=xxx）
Controller層：使用@RestController 它傳回的是方法體資訊
注意版本的使用。。。。