springboot集成dubbo

一直没有关于dubbo的东西，准备开始写一些关于dubbo的相关知识点，老规矩先以最简单的方式接入springboot,然后开始深入研究。

项目结构如下图所示，应该不用多解释，api公共api层，一个服务提供方(provider)，一个服务调用方(consumer)。

1、添加根pom的一些公共引用。curator-framework和curator-recipes是因为启动的时候报错NoClassDefFoundError，所以加上这两个引用了。

<groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.8</version> </dependency>

<groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>5.1.0</version> </dependency>

<groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>5.1.0</version> </dependency>

2、定义公共的api接口，也就是api module的代码，有以下两个类。

public interface UserServiceApi { UserInfo getUserInfo(); }

@Data public class UserInfo implements Serializable { private String name; private Integer age; private Boolean sex; }

3、然后开始provider的代码，首先再该module的启动类上添加注解@EnableDubbo的注解，然后附上配置文件信息，还有代码。

server.port=8081 #当前服务/应用的名字 dubbo.application.name=user-service-provider #注册中心的协议和地址 dubbo.registry.protocol=zookeeper dubbo.registry.address=127.0.0.1:2181 #通信规则（通信协议和接口） dubbo.protocol.name=dubbo dubbo.protocol.port=20880 #连接监控中心 dubbo.monitor.protocol=registry #开启包扫描，可替代 @EnableDubbo 注解

package com.uwith.provider; import com.uwith.api.UserInfo; import com.uwith.api.UserServiceApi; import org.apache.dubbo.config.annotation.Service; import org.springframework.stereotype.Component; @Service @Component public class UserInfoServiceIml implements UserServiceApi { @Override public UserInfo getUserInfo() { UserInfo userInfo = new UserInfo(); userInfo.setName("aa"); userInfo.setAge(11); userInfo.setSex(true); return userInfo; } }

4、consumer层的代码和provider层差不多，启动类上添加注解@EnableDubbo的注解，然后调用provider的接口。

server.port=8082 dubbo.application.name=order-service-consumer dubbo.registry.address=zookeeper://127.0.0.1:2181 dubbo.monitor.protocol=registry

import com.uwith.api.UserInfo; import com.uwith.api.UserServiceApi; import org.apache.dubbo.config.annotation.Reference; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; @RestController public class UserInfoService { @Reference UserServiceApi userServiceApi; @GetMapping("/getUserInfo") public void getUserInfo() { UserInfo userInfo = userServiceApi.getUserInfo(); System.out.println(userInfo); } }

然后就完事了，将zk启动起来，然后就可以直接运行了。

关于dubbo的源码和思想我觉得我可以不写了，直接参考研究大佬的把： https://segmentfault.com/blog/dubboanalysis?page=3