概述
使用 SpringBoot 整合 Dubbo 时,我们需要有一个服务的注册中心,这里的注册中心我们选用Zookeeper,然后要编写服务的提供者、服务的消费者。在提供者工程中使用@Service
注解暴露服务,在消费者工程中使用@Reference
引用服务。
由于我们使用 Zookeeper 作为注册中心,所以需要操作 Zookeeper 。Dubbo 2.6以前的版本引入zkclient操作 Zookeeper ,Dubbo 2.6及以后的版本引入curator操作 Zookeeper。
项目的整体结构:
-
user-parent:父工程、打包方式为pom,Maven形式。
-
user-provider:服务提供者工程,SpringBoot的Web工程。
-
user-consumer:服务的消费者工程,SpringBoot的Web工程。
-
user-model:模型层工程,用于封装实体类等,Maven的Jar工程。
-
user-mapper:数据访问层工程,用于操作数据库,Maven的Jar工程。
-
user-interface:公共接口工程,用于将provider和consumer的公共接口抽取。Maven的Jar工程。
我们可以只有两个子工程,在provider中编写entity、mapper、service的代码,将服务暴露,在consumer中编写controller,引用服务。
编写代码
导入依赖
- 父工程就是一个Maven项目,没有具体的代码,相当于一个目录,将子工程放在一起,可以用来管理Jar包的依赖。注意在pom文件中将打包方式改为pom即可。其它的子项目都相当于它的一个个模块。
<packaging>pom</packaging>
-
模型层工程:正常编写数据库对应的实体类即可。
-
数据访问层在pom文件中需要引用Mybayis相关的依赖,还要将模型层工程引入pom文件中。将mapper.xml文件存放在resources目录下。
<dependency>
<groupId>com.coydone</groupId>
<artifactId>user-model</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
- 公共接口本质是将service的接口抽取出来,在这里需要引入模型层依赖。
<dependency>
<groupId>com.coydone</groupId>
<artifactId>user-model</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
服务提供者
1、在pom文件中需要引入接口,Dubbo相关依赖、Zookeeper相关依赖、我们在这里配置数据库相关信息,需要引入数据库相关依赖。
<?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">
<parent>
<artifactId>user-parent</artifactId>
<groupId>com.coydone</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>user-provider</artifactId>
<dependencies>
<dependency>
<groupId>com.coydone</groupId>
<artifactId>user-interface</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.coydone</groupId>
<artifactId>user-mapper</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
</dependency>
<!--这是一个springboot项目-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!--这是一个springboot-jdbc项目-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<!--dubbo相关的-->
<!-- Dubbo Spring Boot Starter -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
</dependency>
<!-- 使用zk 做注册中心,Dubbo 需要的依赖 -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-zookeeper</artifactId>
<type>pom</type>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
</dependencies>
<build>
<!-- 当项目编译时,会把其它所有依赖的包全部打入jar包-->
<finalName>user-provider</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
2、在配置文件中配置数据库、Zookeeper、Dubbo相关配置。
#数据源的配置
spring:
datasource:
driver-class-name: com.mysql.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3306/user?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
username: root
password: root123
#注入数据源的类型 默认的为HikariDataSource
type: com.alibaba.druid.pool.DruidDataSource
druid:
max-active: 20
min-idle: 5
validation-query: select x
initial-size: 3
max-wait: 5000
stat-view-servlet:
# login-username: root
# login-password: 123456
allow:
deny:
url-pattern: /api/druid/*
enabled: true #启用数据源监控
#mybatisplus的配置
mybatis-plus:
configuration:
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
mapper-locations: classpath:mapper/*Mapper.xml
global-config:
db-config:
id-type: auto
dubbo:
#声明注册到zk的名字 应该程序的名称
application:
name: bills-service-provider
#声明注册中心的地址和方式
registry:
address: zookeeper://127.0.0.1:2181
#使用dubbo协议,将服务暴露在20880端口
protocol:
name: dubbo
port: 20880
#提供者全局配置
provider:
timeout: 4000
retries: 2
loadbalance: random
3、编写接口的实现类,在实现类中暴露服务。
package com.coydone.service.impl;
import org.apache.dubbo.config.annotation.Service;
@Service //暴露服务
public class BillsServiceImpl implements BillsService {
@Autowired
private UserMapper userMapper;
@Override
public int addUser(User user) {
return userMapper.insert(user);
}
}
4、修改启动类
@SpringBootApplication
@EnableDubbo//开启注解的dubbo功能
@MapperScan(basePackages = {"com.coydone.mapper"})
public class UserProvider {
public static void main(String[] args) {
SpringApplication.run(UserProvider.class,args);
System.out.println("服务提供者启动成功");
}
}
服务消费者
1、在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">
<parent>
<artifactId>user-parent</artifactId>
<groupId>com.coydone</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>bills-consumer</artifactId>
<dependencies>
<!--这是一个springboot-web项目-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.coydone</groupId>
<artifactId>user-model</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.coydone</groupId>
<artifactId>user-interface</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!--dubbo相关的-->
<!-- Dubbo Spring Boot Starter -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
</dependency>
<!-- 使用zk 做注册中心,Dubbo 需要的依赖 -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-zookeeper</artifactId>
<type>pom</type>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
</dependencies>
<build>
<!-- 当项目编译时,会把其它所有依赖的包全部打入jar包-->
<finalName>user-consumer</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
2、配置Dubbo相关。
#端口
server:
port: 8080
#spring的配置
#数据源的配置
spring:
mvc:
format:
date-time: yyyy-MM-dd HH:mm:ss
jackson:
date-format: yyyy-MM-dd HH:mm:ss
time-zone: GMT+8
dubbo:
#声明注册到zk的名字 应该程序的名称
application:
name: user-consumer
#声明注册中心的地址和方式
registry:
address: zookeeper://127.0.0.1:2181
3、编写控制器,消费服务。
package com.coydone.contrller;
@RestController
@RequestMapping("/api")
public class UserController {
@Reference
public UserService userService;
@RequestMapping("user/addUser")
public int addBills(User user){
return this.userService.addUser(user);
}
}
4、启动类开启Dubbo。
package com.coydone;
@SpringBootApplication
@EnableDubbo
public class UserConsumer {
public static void main(String[] args) {
SpringApplication.run(UserConsumer.class,args);
System.out.println("消费者启动成功");
}
}
评论区