springboot集成dubbo

原创
02/18 15:11
阅读数 504

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

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

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

<!-- https://mvnrepository.com/artifact/org.apache.dubbo/dubbo-spring-boot-starter -->
<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>2.7.8</version>
</dependency>

<!-- https://mvnrepository.com/artifact/org.apache.curator/curator-framework -->
<dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>5.1.0</version>
</dependency>

<!-- https://mvnrepository.com/artifact/org.apache.curator/curator-recipes -->
<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

 

展开阅读全文
打赏
1
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
1
分享
返回顶部
顶部