SpringBoot整合Dubbo-6ren

SpringBoot整合Dubbo

转载作者：知者更新时间：2024-03-13 00:54:49

1.接口工程

1.pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.6.7</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.yl</groupId>
    <artifactId>boot-interface</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>boot-interface</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.yl</groupId>
            <artifactId>boot-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.实体类

package com.yl.bootinterface.model;

import java.io.Serializable;

public class Student implements Serializable {
    private Integer id;
    private String name;
    private Double score;
    private Integer sex;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Double getScore() {
        return score;
    }

    public void setScore(Double score) {
        this.score = score;
    }

    public Integer getSex() {
        return sex;
    }

    public void setSex(Integer sex) {
        this.sex = sex;
    }
}

3.接口

package com.yl.bootinterface.service;

import com.yl.bootinterface.model.Student;

public interface StudentService {

    Student getStudentById(Integer id);
}

2.提供者

1.pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.6.7</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.tl</groupId>
    <artifactId>boot-provider</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>boot-provider</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <!--dubbo依赖-->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>
        <dependency>
            <groupId>com.yl</groupId>
            <artifactId>boot-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

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

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.application.properties

server.port=8080
# 提供者名称，唯一
dubbo.application.name=boot-provider
# 配置注册中心
dubbo.registry.address=127.0.0.1:2181
dubbo.registry.protocol=zookeeper
# 配置协议以及端口
dubbo.protocol.name=dubbo
dubbo.protocol.port=20880
# 配置超时时间，默认为1000ms
dubbo.registry.timeout=5000
# 配置如果连接断开时，要重连次数，不包含第一次连接,0代表不重尝试连接
dubbo.provider.retries=3
# 配置监控中心要监控的地址，监控注册中心的地址
dubbo.monitor.address=registry

3.接口实现类

package com.tl.bootprovider.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.yl.bootinterface.model.Student;
import com.yl.bootinterface.service.StudentService;

//暴露服务,注意是com.alibaba这个包下的
@Service
public class StudentServiceImpl implements StudentService {
    @Override
    public Student getStudentById(Integer id) {
        Student student = new Student();
        student.setId(id);
        student.setName("tom");
        student.setScore(99.0);
        student.setSex(0);
        return student;
    }
}

4.主程序

package com.tl.bootprovider;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@EnableDubbo //开启基于dubbo的注解功能
@SpringBootApplication
public class BootProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(BootProviderApplication.class, args);
    }

}

3. 消费者

1.pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.6.7</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.yl</groupId>
    <artifactId>boot-consumer</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>boot-consumer</name>
    <description>Demo project for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <!--dubbo依赖-->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.yl</groupId>
            <artifactId>boot-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

2.application.properties

server.port=8081
# 消费者名称，唯一
dubbo.application.name=boot-consumer
# 配置注册中心
dubbo.registry.address=zookeeper://127.0.0.1:2181
# 配置超时时间，默认为1000ms
dubbo.registry.timeout=5000
# 配置如果连接断开时，要重连次数，不包含第一次连接，0代表不重尝试连接
dubbo.consumer.retries=3
# 配置监控中心要监控的地址
dubbo.monitor.address=registry

3.controller

package com.yl.bootconsumer.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.yl.bootinterface.model.Student;
import com.yl.bootinterface.service.StudentService;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class StudentController {

    @Reference //引用远程服务
    StudentService studentService;

    @GetMapping("/getStudentById")
    public Student getStudentById(Integer id) {
        return studentService.getStudentById(id);
    }
}

4.主程序

package com.yl.bootconsumer;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo //开启基于dubbo的注解功能
public class BootConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(BootConsumerApplication.class, args);
    }

}

4. 测试

1.启动本地的zookeeper
2.启动提供者和服务器
3.访问测试接口

创作打卡挑战赛

赢取流量/现金/CSDN周边激励大奖

文章推荐： Reactor 3 （4）: 监控与副作用 doOn 系列方法

文章推荐： Reactor 3 （10）: 数据合并concat、merge

文章推荐： Reactor 3 （13）: 数据收集 collect

文章推荐： Reactor 3 （5）: 错误处理 onError相关方法

Springboot 整合企业微信机器人助手推送消息
前言这个东西有啥用，好玩？确实，好玩归好玩，其实很有使用场景。可以自己选则一些业务节点触发这个机器人助手的消息推送；简单举例：有人给你的系统留下反馈意见了，推送到运营群去； 2.项目部署成
【JWT】JWT 整合
1. JWT 简介 JSON Web Token（JWT）是一个开放标准（RFC 7519），它定义了一种紧凑的、自包含的方式，用于作为 JSON 对象在各方之间安全地传输信息。该信息可以被验证和信
javascript - 整合 $.ajax
我的页面上有多个 ajax 调用，我想将它们合并为一个函数。目前我在几个地方都有这种类型的功能: function AjaxCallOne () { //do something $.ajax(
Android Facebook 整合
我的 Facebook 集成基本上可以在我的应用程序中运行:出现 Facebook 对话框，用户可以选择“允许”或“不允许”。但是，我不明白 API 是如何工作的!我有一个使用此代码的 Activit
android - OneDrive 整合
我必须将文件夹结构从我的应用程序共享到 OneDrive。我已经检查了一个驱动器的 sdk，但在那个 sdk 中只能共享文件而不是文件夹，并且没有在该 sdk 中创建文件夹的选项 https://g
php - CCAvenue 整合
我是支付网关集成方面的新手。我必须在我的项目 (CORE PHP) 中集成 CCAvenue 支付网关集成。但是我不知道如何为开发人员测试创建商户帐户，如何获取商户 key 等。我已经进行了研发，但是
iOS5 Facebook 整合
我正在尝试将“社交选项”集成到我的应用程序中。我有 iOS6，但我的想法是有一个适用于 iOS5 的应用程序。使用 Twitter 框架非常简单，并且可以在 r.0 版本和 6.0 版本的设备上运行
iphone - 整合 FlurryAds
我正在尝试将 flurryAds 集成到我的 iPhone 应用程序中，但我无法做到这一点。我导入名为的 .h 文件 #import "Flurry.h" #import "FlurryAds.h"
c# - Facebook 整合
我正在尝试在我的网站中实现类似 facebook 的按钮和评论，但我在 IE7 中遇到了评论框问题。 COMMENT USING 下拉框不知何故没有显示其他可用选项。这是我用来实现它的代码片段:
php - Paypal 整合
关闭。这个问题是off-topic .它目前不接受答案。想改进这个问题吗？ Update the question所以它是on-topic用于堆栈溢出。关闭 11 年前。 Improve th
Paypal 整合 - GetExpressCheckout
我正在使用 SOAP API 进行 PayPal 集成(Express Checkout)。在 DoExpressCheckout 调用后，我调用 GetExpressCheckoutDetails。
Android Paypal 整合
我正在尝试将 paypal 作为支付网关之一集成到我的应用程序中，但在我点击支付按钮后它会返回以下错误。错误 java.lang.RuntimeException:无法使用 Intent { cmp
Paypal 整合 - IPN
我目前正在尝试将 paypal 结账与我们的在线商店集成。我们正在针对 Sandbox 进行测试。除了 IPN(即时付款通知)之外的所有内容都有效。我们阅读了很多有关 Paypal 更改其安全模型的
Android Facebook 整合
我正在开发一个 android 应用程序，我想在其中集成 facebook 之类的。我正在浏览链接 http://developers.facebook.com/docs/guides/mobile/
ios - FitBit 整合
所以我正在尝试构建一个集成了 FitBit 的 iOS 应用程序 (Swift 2)。一旦用户打开“步行”页面，用户应该能够看到他每天的步数。理想情况下，我们不希望每个用户都注册到 FitBit。
c# - Dropbox 整合
我是集成投递箱的新手，但我不太确定如何生成调用以获取请求 token secret 。 https://www.dropbox.com/developers/reference/api#request
html - 整合 Paypal
我已经成功集成了 PayPal。一切正常。但我希望我的表格在成功付款后重定向到我的网站。另一个问题:如何从 PayPal 得到回应？这是我的 Paypal 表格。谢谢。 `
Android Paypal 整合
我在我的 Android 应用程序中集成了 Paypal 。我有一个主要 Activity - 和关于 Activity ，我在其中显示 Paypal 按钮。关于从主 Activity 访问的 Act
springboot 整合 seata的配置过程
前言：小编引入的图片和文字描述都是来自于尚硅谷的视频讲解，在此感谢尚硅谷的老师,同时也结合 seata文档官方文档进行整合项目地址（gitee）: https://gitee.com/qine
SpringBoot 整合 Docker的详细过程
目录 1. demo project 1.1 接口准备 1.2 配置准备 2. docker 开启远程连接

知者

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

SpringBoot整合Dubbo

1.接口工程

2.提供者

3. 消费者

4. 测试