一直没有关于dubbo的东西,准备开始写一些关于dubbo的相关知识点,老规矩先以最简单的方式接入springboot,然后开始深入研究。
项目结构如下图所示,应该不用多解释,api公共api层,一个服务提供方(provider),一个服务调用方(consumer)。
1、添加根pom的一些公共引用。curator-framework和curator-recipes是因为启动的时候报错NoClassDefFoundError,所以加上这两个引用了。
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