Springboot优雅整合Dubbo完成分布式服务注册案例

Easter79
• 阅读 1441

说明:Springboot整合Dubbo完成分布式服务注册,笔者以调用订单信息时调用查询用户地址信息为例。

开发工具 Idea

父项目:springboot-dubbo-interface

提供者:springboot-dubbo-provider

消费者:springboot-dubbo-consumer

一、父项目:springboot-dubbo-interface

1.pom依赖

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>

2.UserAddress.java 公共实体类【网络传输对象】

@Data
@AllArgsConstructor
@NoArgsConstructor
public class UserAddress implements Serializable {

    private Integer id;
    private String userAddress;
    private String userId;

}

3.UserService.java/OrderService.java 两个公共接口

public interface OrderService {
    //查询订单,调用用户地址服务,返回用户地址
    public List<UserAddress> initOrder(String userId);
}
------------------------------------------------------
    public interface UserService {

    /*查询用户所有的地址*/
    public List<UserAddress> queryAllAddress(String userId);
}

二、提供者:springboot-dubbo-provider

1.pom依赖

<dependencies>
        <!--继承父项目-->
        <dependency>
            <groupId>com.wang</groupId>
            <artifactId>springboot-dubbo-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <!--apache dubbo-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>2.7.3</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <optional>true</optional>
        </dependency>

    </dependencies>

2.application.properties

# 1. application name
dubbo.application.name=springboot-service-provider
# 2. dubbo:registry address
dubbo.registry.address=zookeeper://127.0.0.1:2181
# 3. dubbo:protocol
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880

### 说明: 可以新建一个dubbo.properties 把上面的配置复制进去也可以。

3.UserServiceImpl.java 服务提供实现类

import com.wang.springboot.domain.UserAddress;
import com.wang.springboot.service.UserService;
import org.apache.dubbo.config.annotation.Service;
import java.util.ArrayList;
import java.util.List;

/**
 * @author 王一宁
 * @date 2020/3/28 17:58
 */
@Service
public class UserServiceImpl implements UserService {
    private static List<UserAddress> address = new ArrayList<UserAddress>();
    static {
        UserAddress userAddress = new UserAddress(1, "廊坊市固安县", "whsxt");
        address.add(userAddress);
    }
    /*模拟查询数据库*/
    @Override
    public List<UserAddress> queryAllAddress(String userId) {
        return address;
    }
}

4.启动类上记得加上 @EnableDubbo //启用dubbo

三、消费者:springboot-dubbo-consumer

1.pom

<dependencies>
        <!--父项目的依赖-->
        <dependency>
            <groupId>com.wang</groupId>
            <artifactId>springboot-dubbo-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

        <!--apache dubbo-->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.3</version>
        </dependency>
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>2.7.3</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>

2.application.properties

# 1.appname
dubbo.application.name=springboot-service-consumer
# 2.address
dubbo.registry.address=zookeeper://127.0.0.1:2181

3.OrderServiceImpl.java 消费者实现类

import com.wang.springboot.domain.UserAddress;
import com.wang.springboot.service.OrderService;
import com.wang.springboot.service.UserService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author 王一宁
 * @date 2020/3/28 11:03
 */

@Service
public class OrderServiceImpl implements OrderService {

    @Reference
    private UserService userService;

    /*查询所有的订单中调用用户查询地址的api接口*/
    @Override
    public List<UserAddress> initOrder(String userId) {
        return userService.queryAllAddress(userId);
    }
}

4.OrderController.java 这个是个web项目,用来体验结果

@RestController
@RequestMapping("/order")
public class OrderController {

    @Autowired
    private OrderService orderService;

    @RequestMapping("/initOrder")
    public List<UserAddress> initOrder(String userId){
        return this.orderService.initOrder(userId);
    }
}

四、开启你的zookeeper、dubbo-admin

1.启动 生产者项目

2.启动 消费者项目

3.可以在bubbo的web查看服务状态

http://127.0.0.1:7001/

4.访问自己的服务

http://localhost:8080/order/initOrder?userId=wang

返回结果:
[{"id":1,"userAddress":"廊坊市固安县","userId":"whsxt"}]
点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
待兔 待兔
7个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
AWS国庆双重礼,仅限7天
自2021年10月1日00:00起至2021年10月7日24:00,新注册并激活(需全部完成账号注册的五个步骤,否则账号状态并未激活)AWS海外区域账户,填写页面下方表单,即可申领价值$200美元的AWS海外区域账户服务抵扣券直充到您的账户,用以抵扣服务消费,助您轻松体验多个云迁移应用场景。同时,您还可获赠AWS精美祥云纪念T恤一件。$200美元A
国庆假期玩不停,双重好礼放肆领
自2021年10月1日00:00起至2021年10月7日24:00,新注册并激活(需全部完成账号注册的五个步骤,否则账号状态并未激活)AWS海外区域账户,填写页面下方表单,即可申领价值$200美元的AWS海外区域账户服务抵扣券直充到您的账户,用以抵扣服务消费,助您轻松体验多个云迁移应用场景。同时,您还可获赠AWS精美祥云纪念T恤一件。,仅限7天AW
国庆假期玩不停双重好礼放肆领
自2021年10月1日00:00起至2021年10月7日24:00,新注册并激活(需全部完成账号注册的五个步骤,否则账号状态并未激活)AWS海外区域账户,填写页面下方表单,即可申领价值$200美元的AWS海外区域账户服务抵扣券直充到您的账户,用以抵扣服务消费,助您轻松体验多个云迁移应用场景。同时,您还可获赠AWS精美祥云纪念T恤一件。,仅限7天AW
AWS国庆双重礼,仅限7天
自2021年10月1日00:00起至2021年10月7日24:00,新注册并激活(需全部完成账号注册的五个步骤,否则账号状态并未激活)AWS海外区域账户,填写页面下方表单,即可申领价值$200美元的AWS海外区域账户服务抵扣券直充到您的账户,用以抵扣服务消费,助您轻松体验多个云迁移应用场景。同时,您还可获赠AWS精美祥云纪念T恤一件。,仅限7天$20
AWS国庆双重礼,仅限7天
自2021年10月1日00:00起至2021年10月7日24:00,新注册并激活(需全部完成账号注册的五个步骤,否则账号状态并未激活)AWS海外区域账户,填写页面下方表单,即可申领价值$200美元的AWS海外区域账户服务抵扣券直充到您的账户,用以抵扣服务消费,助您轻松体验多个云迁移应用场景。同时,您还可获赠AWS精美祥云纪念T恤一件。,仅限7天$20
AWS国庆双重礼,仅限7天
自2021年10月1日00:00起至2021年10月7日24:00,新注册并激活(需全部完成账号注册的五个步骤,否则账号状态并未激活)AWS海外区域账户,填写页面下方表单,即可申领价值$200美元的AWS海外区域账户服务抵扣券直充到您的账户,用以抵扣服务消费,助您轻松体验多个云迁移应用场景。同时,您还可获赠。国庆双重礼,仅限7天$200美元AWS服务抵
美凌格栋栋酱 美凌格栋栋酱
3星期前
Oracle 分组与拼接字符串同时使用
SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(
Easter79
Easter79
Lv1
今生可爱与温柔,每一样都不能少。
文章
2.8k
粉丝
6
获赞
1.2k