文档章节

SpringBoot + Dubbo 实现基本的数据访问

 天堂之光
发布于 2017/03/16 13:24
字数 1867
阅读 1451
收藏 3

代码已经分享到码云上,地址是https://gitee.com/heaven_light/dubbo-user,可以下载下来跑跑看看,建表sql和数据sql在dubbo-user-service 的src/main/resources下的sql目录下。

项目基本结构如下

基于Dubbo的微服务需要暴露api相应的jar包给客户端,而服务端需要实现api里暴露的服务逻辑,所以这里有一个父工程,里面有一个api子工程,一个Dubbo服务端子工程和一个Dubbo客户端子工程。基于Dubbo构建的微服务底层使用TCP协议进行通信,而基于SpringCloud也可以构建微服务,但是服务间通信使用的是HTTP协议,通过HTTP调用的时候可以不用暴露api相关的jar包,但是要约定好restful接口参数,就是spring一直倡导的约定优于配置。

1.这里使用的springboot 是 1.5.2.RELEASE 版本,就只列出父工程的pom文件中的parent,properties 和modules子标签里面的内容

<parent>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-parent</artifactId>

<version>1.5.2.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.7</java.version>

<commons.lang3.version>3.5</commons.lang3.version>

</properties>

<modules>

<module>dubbo-user-api</module>

<module>dubbo-user-service</module>

<module>dubbo-user-client</module>

</modules>

2.api子工程因为是需要打成jar包暴露的,所以应该尽量简洁避免依赖,其pom.xml 文件内容如下

<parent>

<groupId>com.net.lnk</groupId>

<artifactId>dubbo-user</artifactId>

<version>0.0.1-SNAPSHOT</version>

</parent>

<artifactId>dubbo-user-api</artifactId>

<name>dubbo-user-api</name>

<dependencies>

<dependency>

<groupId>org.apache.commons</groupId>

<artifactId>commons-lang3</artifactId>

</dependency>

</dependencies>

api尽量简单,只定义了接口和相关的DTO

3.下面是service子工程,其pom中parent,properties如下

<parent>

<groupId>com.net.lnk</groupId>

<artifactId>dubbo-user</artifactId>

<version>0.0.1-SNAPSHOT</version>

</parent>

<properties>

<user.api.version>0.0.1-SNAPSHOT</user.api.version>

<dubbo.starter.version>1.0.0</dubbo.starter.version>

<druid.version>1.0.27</druid.version>

</properties>

所需要的依赖如下

<dependencies>

<!-- 接口依赖 -->

<dependency>

<groupId>com.net.lnk</groupId>

<artifactId>dubbo-user-api</artifactId>

<version>${user.api.version}</version>

</dependency>

<dependency>

<groupId>org.apache.commons</groupId>

<artifactId>commons-lang3</artifactId>

</dependency>

<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>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-actuator</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-data-jpa</artifactId>

</dependency>

<dependency>

<groupId>mysql</groupId>

<artifactId>mysql-connector-java</artifactId>

<scope>runtime</scope>

</dependency>

<dependency>

<groupId>com.alibaba</groupId>

<artifactId>druid</artifactId>

<version>${druid.version}</version>

</dependency>

<!-- Spring Boot Dubbo 依赖 -->

<dependency>

<groupId>io.dubbo.springboot</groupId>

<artifactId>spring-boot-starter-dubbo</artifactId>

<version>${dubbo.starter.version}</version>

</dependency>

</dependencies>

这里使用到的主要依赖有spring-boot-starter-web,spring-boot-starter-data-jpa,spring-boot-starter-test,mysql-connector-java,druid 和 spring-boot-starter-dubbo,其中 groupId是io.dubbo.springboot的dubbo依赖包是可以在maven仓库中直接下在的,其封装是基于dubbo 2.5.3版本的

工程内部代码结构如下

entity中放实体关系映射类,dao中放jpa repository,repository上面不用加任何注解的,springboot会默认扫描启动类所在的包及其子包,将继承了repository接口的仓库,带有@Repository@Service@Controller,@RestController 注解的类注册成单例bean,findBy后面就是查询条件,多个条件可以用And连接,springboot会自动解析出现属性名称并设置查询条件值,JpaRepository继承了PagingAndSortingRepository,可以用来分页,PagingAndSortingRepository继承了CrudRepository,而CrudRepository继承了Repository接口。

UserEntity很简单,定义如下

@Entity

@Table(name = "user")

public class UserEntity {

@Id

@GeneratedValue(strategy = GenerationType.AUTO)

private long id;

@Column

private String username;

@Column

private String name;

@Column

private Integer age;

@Column

private BigDecimal balance;

省去了getter和setter方法

UserDao 更简单,定义如下

public interface UserDao extends JpaRepository<UserEntity, Long> {

}

UserService的接口实现定义如下

@Service(version = "1.0.0")

public class UserServiceImpl implements UserService {

@Autowired

private UserDao userDao;

@Override

public UserDTO getById(Long id) {

UserEntity user = userDao.findOne(id);

UserDTO userDTO = new UserDTO();

userDTO.setId(user.getId());

userDTO.setName(user.getName());

userDTO.setUsername(user.getUsername());

userDTO.setAge(user.getAge());

userDTO.setBalance(user.getBalance());

return userDTO;

}

}

这里用到了dubbo 的注解 @Service(version = "1.0.0"),并且标记了服务的版本号。springboot starter dubbo 自动装配的时候会扫描指定的包,将其中带有dubbo @Service注解的类注册成dubbo服务。

下面给出service 工程中 springboot 最核心,也是最神奇的自动装配application.properties配置部分

# IDENTITY (ContextIdApplicationContextInitializer)

spring.application.name=user

# EMBEDDED SERVER CONFIGURATION (ServerProperties)

server.port=9002

# JPA (JpaBaseConfiguration, HibernateJpaAutoConfiguration)

spring.jpa.show-sql=true

spring.jpa.generate-ddl=false

spring.jpa.hibernate.ddl-auto=none

# DATASOURCE (DataSourceAutoConfiguration & DataSourceProperties)

spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

spring.datasource.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8&autoReconnect=true&failOverReadOnly=false  

spring.datasource.username=root

spring.datasource.password=123456

spring.datasource.driverClassName=com.mysql.jdbc.Driver

spring.datasource.initialSize=10

spring.datasource.minIdle=10

spring.datasource.maxActive=20

spring.datasource.maxWait=50000

spring.datasource.timeBetweenEvictionRunsMillis=60000

spring.datasource.minEvictableIdleTimeMillis=30000

spring.datasource.validationQuery=SELECT 1 FROM

spring.datasource.testWhileIdle=true

spring.datasource.testOnBorrow=false

spring.datasource.testOnReturn=false

spring.datasource.poolPreparedStatements=true

spring.datasource.maxPoolPreparedStatementPerConnectionSize=20

spring.datasource.filters=stat,wall,log4j

spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000

# LOGGING

logging.level.root=INFO

logging.Level.org.hibernate=DEBUG

logging.Level.org.hibernate.type.descriptor.sql.BasicBinder=TRACE

logging.Level.org.hibernate.type.descriptor.sql.BasicExtractor=TRACE

# DUBBO

spring.dubbo.application.name=user

spring.dubbo.registry.address=zookeeper://127.0.0.1:2181

spring.dubbo.protocol.name=dubbo

spring.dubbo.protocol.port=20882

spring.dubbo.scan=com.net.lnk.dubbo.user.service.impl

其中有spring应用名配置,内嵌服务端口配置,JPA配置,数据源DataSource配置,日志logging配置 和 dubbo配置,这里的注册发现中心使用的是zookeeper,zookeeper是分布式一致性协调框架,可以用来做注册发现中心,其核心是master选举,也可以用来做分布式锁,数据发布订阅,负载均衡,命名服务,分布式协调通知,分布式队列,集群状态管理等,zookeeper的安装和使用比较简单,下载压缩包,解压,到bin目录下,运行zkServer脚本启动就可以了。

好了,dubbo服务工程开发完成,现在可以启动了

 

4.现在就剩Dubbo client 端开发了,调用端同样要依赖服务接口 和 spring-boot-starter-dubbo,其pom文件中依赖及其版本号情况如下

<properties>

<user.api.version>0.0.1-SNAPSHOT</user.api.version>

<dubbo.starter.version>1.0.0</dubbo.starter.version>

</properties>

<dependencies>

<!-- 接口依赖 -->

<dependency>

<groupId>com.net.lnk</groupId>

<artifactId>dubbo-user-api</artifactId>

<version>${user.api.version}</version>

</dependency>

<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>

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-actuator</artifactId>

</dependency>

<!-- Spring Boot Dubbo 依赖 -->

<dependency>

<groupId>io.dubbo.springboot</groupId>

<artifactId>spring-boot-starter-dubbo</artifactId>

<version>${dubbo.starter.version}</version>

</dependency>

</dependencies>

它的application.properties 中的配置主要是服务端口配置 和 dubbo 服务注册发现中心zookeeper 配置,内容如下

# IDENTITY (ContextIdApplicationContextInitializer)

spring.application.name=user-client

# EMBEDDED SERVER CONFIGURATION (ServerProperties)

server.port=9100

# LOGGING

logging.level.root=INFO

# DUBBO

spring.dubbo.application.name=user-client

spring.dubbo.registry.address=zookeeper://127.0.0.1:2181

spring.dubbo.scan=com.net.lnk.dubbo.user.client

先给出工程结构目录

这里定义了一个UserController的RestController类,为了方便浏览器中访问。其定义内容如下

@RestController

public class UserController {

@Reference(version = "1.0.0", loadbalance = "roundrobin")

private UserService userService;

@GetMapping("/user/{id}")

public UserDTO getUser(@PathVariable Long id) {

return userService.getById(id);

}

}

application.properties 中 配置的spring.dubbo.scan=com.net.lnk.dubbo.user.client,在dubbo自动装配的时候会扫描配置的包及其子包中的类,将带有dubbo提供的 @Reference 注解的bean标记成dubbo调用引用bean。

好了,调用端也开发完成,启动一下吧。

 

这样,dubbo服务端启动了,dubbo调用端也启动了,可以在浏览器中测试一下调用是否正常连通了。

验证运行成功!

最后提一下:

这里的dubbo service 工程启动类是DubboUserServiceApplication,dubbo client 工程启动类是DubboUserClientApplication,这两个类上面都要添加注解@SpringBootApplication。springboot 工程初始化创建可以去start.spring.io上直接定义一个,还可以选择性的添加一些需要的依赖,比较方便。

Dubbo在2012年10月发布了2.5.3以后好长时间都没有更新,令人高兴的是现在dubbo又开始维护和更新起来了,在九月,一口气发布了2.5.4和2.5.5版本,其官方网址http://dubbo.io/也又相应的说明,这都得益于开源的推动和在实际开发中对源码把控和改造的强大。

© 著作权归作者所有

粉丝 0
博文 2
码字总数 2717
作品 0
浦东
高级程序员
私信 提问
关于springboot + dubbo 部署启动方式(Windows版)

项目结构 注:项目构建通过: http://start.spring.io/ 快速构建web 项目, 具体操作可以参考《SpringBoot使用SpringDataJPA完成数据查询 -Demo》。 本次项目搭建应用的组件是springboot + du...

摘星族
01/10
0
0
SpringBoot整合Dubbo案例

使用框架: jdk 1.8 springboot-2.1.3 dubbo-2.6 spring-data-jpa-2.1.5 一、开发dubbo服务接口: 按照Dubbo官方开发建议,创建一个接口项目,该项目只定义接口和model类; 1、创建springboo...

ggod
06/09
233
0
springboot dubbox 实例

---------------------------------------------------------------------------------------------------------------- springboot 详解 (一) helloworld 下载demo springboot 详解 (二)......

curiousby
2017/01/19
0
0
最新官方版的SpringBoot 整合 Dubbo

上次的那个springboot和dubbo的整合版本中,dubbo的版本是2.5.3,它的Service注解和事务不能同时使用,会造成扫描失效,2.6.2的dubbo版本已经纠正了此不便,官方也给出了与springboot整合的q...

FantJ
2018/06/09
0
0
微服务资源springboot、springcloud、docker、dubbo项目实战等倾心分享

精彩内容 java实战练习项目教程 全网最全电子图书分享 你所需要的大数据视频教程 java学习视频教程及源码 今天又是周末,还是想给大家送一些福利,因为最近一直有小伙伴问我要springboot等微...

公众号_好好学java
2018/08/06
187
0

没有更多内容

加载失败,请刷新页面

加载更多

Mybatis Plus删除

/** @author beth @data 2019-10-17 00:30 */ @RunWith(SpringRunner.class) @SpringBootTest public class DeleteTest { @Autowired private UserInfoMapper userInfoMapper; /** 根据id删除......

一个yuanbeth
今天
4
0
总结

一、设计模式 简单工厂:一个简单而且比较杂的工厂,可以创建任何对象给你 复杂工厂:先创建一种基础类型的工厂接口,然后各自集成实现这个接口,但是每个工厂都是这个基础类的扩展分类,spr...

BobwithB
今天
5
0
java内存模型

前言 Java作为一种面向对象的,跨平台语言,其对象、内存等一直是比较难的知识点。而且很多概念的名称看起来又那么相似,很多人会傻傻分不清楚。比如本文我们要讨论的JVM内存结构、Java内存模...

ls_cherish
今天
4
0
友元函数强制转换

友元函数强制转换 p522

天王盖地虎626
昨天
5
0
js中实现页面跳转(返回前一页、后一页)

本文转载于:专业的前端网站➸js中实现页面跳转(返回前一页、后一页) 一:JS 重载页面,本地刷新,返回上一页 复制代码代码如下: <a href="javascript:history.go(-1)">返回上一页</a> <a h...

前端老手
昨天
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部