dubbo新版本（3.0以上）在相对于 dubbo 旧版本（2.5、2.6、2.7），有很多的不相同的地方。
官方文档也说了新版本的特性：
https://dubbo.apache.org/zh/docs/v3.0/new-in-dubbo3
本文就来使用dubbo3.0新版本 搭建一个dubbo+SpringBoot 项目，项目结构：
源码已上传到github：https://github.com/DogerRain/dubbo-samples-test
（项目名字是带springCloud的，因为本来还想整合SpringCloud的，还没来得及整合…先不改了）
下面是十分详细的过程。
环境要求：
- jdk1.8
- zookeeper
项目会创建三个modul：
dubbo-samples-springcloud-api dubbo-samples-springcloud-consumer dubbo-samples-springcloud-provider
先来创建一个父项目，定义好一些 依赖包和项目结构：
dubbo-samples-springcloud-api dubbo-samples-springcloud-consumer dubbo-samples-springcloud-provider 1.8 1.8 1.8 true 2.4.1 Dalston.SR4 4.12 3.0.2.1 org.springframework.boot spring-boot-dependencies ${spring-boot-dependencies.version} pom import org.apache.dubbo dubbo-bom ${dubbo.version} pom import org.apache.dubbo dubbo-spring-boot-starter ${dubbo.version} junit junit ${junit.version} test
项目的依赖结构为：
dubbo-samples-springcloud-consumer --dubbo-samples-springcloud-api dubbo-samples-springcloud-provider --dubbo-samples-springcloud-api dubbo-samples-springcloud-api
但如果是旧项目不想改动了，可能会不需要API项目那么你的依赖结构就是这样的：
dubbo-samples-springcloud-consumer --dubbo-samples-springcloud-provider dubbo-samples-springcloud-provider1、创建 API 项目——dubbo-samples-springcloud-api
创建一个 dubbo-samples-springcloud-api 项目，创建该项目是为了解耦，这样 provider定义好接口，打成一个SDK，丢给消费者引入就行了。
1.1、pom文件：1.2、定义接口com.dubbo dubbo-samples-springcloud 0.0.1-SNAPSHOT ../pom.xml dubbo-samples-springcloud-api 0.0.1-SNAPSHOT dubbo-samples-springcloud-api dubbo stress test - api org.projectlombok lombok 1.18.12
废话少说，先来定义一个接口：
UserService.java 接口：
public interface UserService {
User getUserInfo(long userId);
}
User.java 实体类：
@Data
@NoArgsConstructor
@AllArgsConstructor
public class User implements Serializable {
private static final long serialVersionUID = -4294369157631410325L;
Long userId;
String userName;
String responseInfo;
}
2、创建provider——dubbo-samples-springcloud-provider
创建一个dubbo-samples-springcloud-provider 项目
2.1、配置pom文件：com.dubbo dubbo-samples-springcloud 0.0.1-SNAPSHOT ../pom.xml 4.0.0 dubbo-samples-springcloud-provider com.dubbo dubbo-samples-springcloud-api 0.0.1-SNAPSHOT compile org.apache.dubbo dubbo-spring-boot-starter org.springframework.boot spring-boot-starter org.springframework.boot spring-boot-starter-web org.apache.dubbo dubbo-registry-zookeeper
使用了 dubbo-spring-boot-starter 就不需要 原来的 dubbo 依赖了，但是还是需要 dubbo-registry-zookeeper ，因为要连接zk。
2.2、yaml文件配置server:
port: 8090
spring:
application:
name: dubbo-samples-privider-springCloud
dubbo:
application:
name: ${spring.application.name}
registry:
address: zookeeper://127.0.0.1:2181
timeout: 2000
protocol:
name: dubbo
port: 20890
# 扫描 @DubboService 注解
scan:
base-packages: com.dubbo.service
dubbo.application.name 可以不写，默认是 spring.application.name 的名字。
2.3、实现 UserService 接口@DubboService
@Component
@Slf4j
public class UserServiceImpl implements UserService {
@Override
public User getUserInfo(long userId) {
log.info("request from consumer: {}", RpcContext.getContext().getRemoteAddress());
log.info("response from provider: {}" , RpcContext.getContext().getLocalAddress());
return new User(userId, "userName" + userId , " --->>>>response from remote RPC provider:" + RpcContext.getContext().getLocalAddress());
}
}
@DubboService 表示这是一个暴露出去的接口。
旧版本可能是 使用 @Service ，与 spring的 @Service 容易让人误解，不推荐使用
@Component 表示这是一个bean，方便其他地方引用
2.4、添加一个Controller我这里用写一个Controller，方便测试。
@RestController
@RequestMapping("/provider")
public class ProviderUserController {
@Resource
UserServiceImpl userService;
@RequestMapping("/user/{id}")
User getUserInfo(@PathVariable("id") Long id ){
return userService.getUserInfo(id);
}
}
2.5、启动类
@SpringBootApplication
@EnableDubbo
public class ConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);
System.out.println("dubbo client started..........");
}
}
@EnableDubbo 表示自动扫描声明 @DubboService 的类，也可以使用dubbo.scan.base-packages 指定扫描路径，两者选择其中一个即可。
3、创建consumer——dubbo-samples-springcloud-consumer 3.1、配置pom文件3.2、yaml配置com.dubbo dubbo-samples-springcloud 0.0.1-SNAPSHOT ../pom.xml dubbo-samples-springcloud-consumer jar The demo consumer module of dubbo project true com.dubbo dubbo-samples-springcloud-api 0.0.1-SNAPSHOT org.apache.dubbo dubbo-spring-boot-starter org.springframework.boot spring-boot-starter org.springframework.boot spring-boot-starter-web org.apache.dubbo dubbo-registry-zookeeper
server:
port: 8091
spring:
application:
name: dubbo-samples-consumer-springCloud
dubbo:
registry:
address: zookeeper://127.0.0.1:2181
timeout: 2000
protocol:
name: dubbo
3.3、调用 provider
这一步我添加一个Controller 用来调用provider
@RestController
@RequestMapping("/consumer")
@Slf4j
public class ConsumerUserController {
@DubboReference(version = "*", protocol = "dubbo", loadbalance = "random")
private UserService userService;
@RequestMapping("/user/{id}")
public User getUser(@PathVariable("id") Long id) {
User user = userService.getUserInfo(id);
log.info("response from provider: {}", user);
return user;
}
}
@DubboReference 表示使用RPC（这里使用dubbo协议）进行远程调用。
3.4、启动类@SpringBootApplication
@EnableDubbo
public class ConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);
System.out.println("dubbo client started..........");
}
}
4、测试
4.1、启动 provider
运行 ProviderApplication.java
端口是 8090
4.2、启动 consumer运行 ConsumerApplication.java
端口是 8091
4.3 登入 dubboAdmin看看dubboAdmin 是一个后台可视化项目，可以看到 关于dubbo服务方、消费者相关的信息。
这里就不阐述怎么搭建了，可以参考其他文章。
4.4、调用 consumer 的接口浏览器输入：http://localhost:8091/consumer/user/2
看下provider日志：
2021-11-19 15:05:40.206 INFO 25932 --- [20890-thread-11] com.dubbo.service.UserServiceImpl: request from consumer: /172.16.44.48:50513 2021-11-19 15:05:40.206 INFO 25932 --- [20890-thread-11] com.dubbo.service.UserServiceImpl: response from provider: 172.16.44.48:20890
consumer日志：
2021-11-19 15:05:40.207 INFO 33120 --- [nio-8091-exec-4] c.d.controller.ConsumerUserController: response from provider: User(userId=2, userName=userName2, responseInfo= --->>>>response from remote RPC provider:172.16.44.48:20890)
你会看到 consumer 启动了一个 50513 的端口和provider进行通讯。
到这里，dubbo+SpringBoot 的整合就完成了。
·
如果你直接调用provider的Controller。
浏览器输入：http://localhost:8090/provider/user/2
它显示是这样的：
它就很普通的调用一样了。
所以在这里你对比一下，RPC也就是这样的一个过程。
5、总结和踩坑 5.1、版本管理建议使用dubbo的统一版本管理，也就是 dubbo-bom
5.2、jar依赖如果你使用的是 dubbo-spring-boot-starter ，就不需要 dubbo 这个jar了
5.3、关联正常情况下， 这三个项目不是在一起的。
比如说公司两个部门，一个是用户中心，一个是订单，用户中心要RPC调用订单服务。
那么只需要订单服务只需要新建一个API项目，定义一些接口。
然后打成jar 给到用户中心接入，用户中心使用Dubbo就可以直接调用了。
所以好处就是：
- 不需要使用Http直接调用了（当然Dubbo也支持http协议）
- 不需要整个jar打包，可以解耦，把api项目暴露即可
项目的地址已经上传到github：https://github.com/DogerRain/dubbo-samples-test
接下来还有两个TODO：
- 整合SpringCloud
- 使用jmeter压测dubbo、rest、hessian协议 传输大包的性能
