SpringBoot整合dubbo(一)

第一次整合,使用无注册中心方式

ECO

 一、首先,项目分为三个模块,如下图,dubbo-interface(要发布的接口)、dubbo-provider(接口的具体实现,服务提供者)、dubbo-consumer(客户端,服务消费者)

pandas

jdk安装

 二、dubbo-interface模块,普通的springboot项目,只需要写接口,即需要向外提供的服务接口

如上图中的UserService。

dma

三、dubbo-provider模块,它是dubbo-interface模块中接口的具体实现,服务提供者。

全国大学生电子设计大赛

3.1、pom.xml文件

NFT

        <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>
        <!--接口模块-->
        <dependency>
            <groupId>com.xice.dubbo</groupId>
            <artifactId>dubbo-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <!--引入dubbo-->
        <dependency>
            <groupId>io.dubbo.springboot</groupId>
            <artifactId>spring-boot-starter-dubbo</artifactId>
            <version>1.0.0</version>
        </dependency>

3.2、application.properties文件,配置dubbo

QFusion

server.port=8080
spring.dubbo.application.name=dubbo-provider
# N/A表示不使用注册中心
spring.dubbo.registry.address=N/A
# dubbo协议
spring.dubbo.protocol.name=dubbo
# duboo端口号
spring.dubbo.protocol.port=20882
# 发布到dubbo的接口所在包位置
spring.dubbo.scan=com.xice.dubbo

 3.3、接口具体实现

ipfs

/**
 * @author xice
 * @date 2022-11-14
 */
@Service(version = "1.0.0")
public class UserServiceImpl implements UserService {

    SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

    @Override
    public String say(String username, String msg) {
        return username + " say: "+msg+"  --"+dateFormat.format(new Date());
    }
}

四、dubbo-consumer客户端,服务消费者。

APP开发

4.1、pom.xml文件与服务端一样,需要引入dubbo-interface模块、dubbo

dockerfile

        <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>
        <dependency>
            <groupId>com.xice.dubbo</groupId>
            <artifactId>dubbo-interface</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>io.dubbo.springboot</groupId>
            <artifactId>spring-boot-starter-dubbo</artifactId>
            <version>1.0.0</version>
        </dependency>

4.2、application.properties文件,配置dubbo,spring.dubbo.scan包可不完全一样,比如

用Python实现简单人脸识别

  • 服务端配置spring.dubbo.scan=com,客户端配置com、com.xice、com.xice.dubbo都可以
  • 服务端配置spring.dubbo.scan=com.xice.dubbo,客户端配置com、com.xice、com.xice.dubbo也都可以
  • 但是如果服务端配置spring.dubbo.scan=com.xice.dubbo,客户端配置cn、cn.xice等不行,即一级目录必须相同
# 应用名称
server.port=8099
spring.dubbo.application.name=dubbo-consumer
# N/A表示不使用注册中心
spring.dubbo.registry.address=N/A
# 发布到dubbo的接口所在包位置
spring.dubbo.scan=com.xice.dubbo

4.3、调用服务,注入UserService时不是使用SpringBoot中的@Autowired,而是使用@Reference (com.alibaba.dubbo.config.annotation.Reference),其中version为dubbo-provider服务中的版本号,url为服务提供者的ip和配置的端口号

协议

/**
 * @author xice
 * @date 2022-11-15
 */
@RestController
public class UserController {

    @Reference(version = "1.0.0",url = "dubbo://127.0.0.1:20882")
    UserService userService;

    @RequestMapping("say")
    public String say(){
        String say = userService.say("admin", "早上好");
        System.out.println(say);
        return say;
    }
}

五、先启动dubbo-provider、再启动dubbo-consumer,需要按顺序启动!如果先启动客户端就无法调用到服务。启动后访问客户端http://localhost:8099/say

qml

 

mock.js

 

压力测试

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注