脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Spring Cloud Alibaba Dubbo

Spring Cloud Alibaba和Dubbo融合实现

 更新时间：2020年04月14日 10:40:03   作者：西街青年  
这篇文章主要介绍了Spring Cloud Alibaba和Dubbo融合实现,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

服务提供者

创建一个名为 hello-dubbo-nacos-provider 的服务提供者项目

POM

<?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 http://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.1.6.RELEASE</version>
    <relativePath/> <!-- lookup parent from repository -->
  </parent>

  <groupId>com.antoniopeng</groupId>
  <artifactId>hello-dubbo-nacos-provider</artifactId>
  <packaging>pom</packaging>
  
  <modules>
    <module>hello-dubbo-nacos-provider-api</module>
    <module>hello-dubbo-nacos-provider-service</module>
  </modules>
</project>

该项目下有两个子模块，分别是 hello-dubbo-nacos-provider-api 和 hello-dubbo-nacos-provider-service，前者用于定义接口，后者用于实现接口。

服务提供者接口模块

在服务提供者项目下创建一个名为 hello-dubbo-nacos-provider-api 的模块， 该项目模块只负责 定义接口

POM

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>com.antoniopeng</groupId>
    <artifactId>hello-dubbo-nacos-provider</artifactId>
    <version>0.0.1-SNAPSHOT</version>
  </parent>

  <artifactId>hello-dubbo-nacos-provider-api</artifactId>
  <packaging>jar</packaging>
</project>

定义一个接口

public interface EchoService {
  String echo(String string);
}

服务提供者接口实现模块

创建名为 hello-dubbo-nacos-provider-service 服务提供者接口的实现模块，用于实现在接口模块中定义的接口。

引入依赖

在 pom.xml 中主要添加以下依赖

<!-- Nacos And Dubbo-->
<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo-spring-boot-starter</artifactId>
</dependency>
<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo</artifactId>
</dependency>
<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo-serialization-kryo</artifactId>
</dependency>
<dependency>
	<groupId>com.alibaba</groupId>
	<artifactId>dubbo-registry-nacos</artifactId>
</dependency>
<dependency>
	<groupId>com.alibaba.nacos</groupId>
	<artifactId>nacos-client</artifactId>
</dependency>
<dependency>
	<groupId>com.alibaba.spring</groupId>
	<artifactId>spring-context-support</artifactId>
</dependency>

<!-- 依赖接口模块，用于实现接口 -->
<dependency>
	<groupId>com.antoniopeng</groupId>
	<artifactId>hello-dubbo-nacos-provider-api</artifactId>
	<version>${project.parent.version}</version>
</dependency>

相关配置

在 application.yml 中加入相关配置

spring:
 application:
  name: dubbo-nacos-provider
 main:
  allow-bean-definition-overriding: true
dubbo:
 scan:
  # 接口扫描路径
  base-packages: com.antoniopeng.hello.dubbo.nacos.provider.service
 protocol:
  name: dubbo
  # -1 代表自动分配端口
  port: -1
  # 配置高速序列化规则
  serialization: kryo
 registry:
  # 服务注册地址，也就是 Nacos 的服务器地址
  address: nacos://192.168.127.132:8848
 provider:
  # 配置负载均衡策略（轮询）
  loadbalance: roundrobin

附：Duubo 负载均衡策略

  • random：随机
  • roundrobin：轮询
  • leastactive：最少活跃数
  • consistenthash：一致性 Hash

实现接口

通过 org.apache.dubbo.config.annotation 包下的 @Service 注解将接口暴露出去

import com.antoniopeng.hello.dubbo.nacos.provider.api.EchoService;
import org.apache.dubbo.config.annotation.Service;

@Service(version = "1.0.0")
public class EchoServiceImpl implements EchoService {

  @Override
  public String echo(String string) {
    return "Echo Hello Dubbo " + string;
  }
}

注意：@Service 注解要注明 version 属性

验证是否成功

启动项目，通过浏览器访问Nacos Server 网址 http://192.168.127.132:8848/nacos ，会发现有一个服务已经注册在服务列表中。

服务消费者

创建一个名为 hello-dubbo-nacos-consumer 的服务消费者项目

引入依赖

同样在 pom.xml中添加以下主要依赖

<!-- Nacos And Dubbo -->
<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo-spring-boot-starter</artifactId>
</dependency>
<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo-serialization-kryo</artifactId>
</dependency>
<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo-spring-boot-actuator</artifactId>
</dependency>
<dependency>
	<groupId>org.apache.dubbo</groupId>
	<artifactId>dubbo</artifactId>
</dependency>
<dependency>
	<groupId>com.alibaba</groupId>
	<artifactId>dubbo-registry-nacos</artifactId>
</dependency>
<dependency>
	<groupId>com.alibaba.nacos</groupId>
	<artifactId>nacos-client</artifactId>
</dependency>
<dependency>
	<groupId>com.alibaba.spring</groupId>
	<artifactId>spring-context-support</artifactId>
</dependency>

<!-- 依赖服务提供者接口模块，用于调用接口 -->
<dependency>
	<groupId>com.antoniopeng</groupId>
	<artifactId>hello-dubbo-nacos-provider-api</artifactId>
	<version>${project.parent.version}</version>
</dependency>

相关配置

在 application.yml 中添加以下配置

spring:
 application:
  name: dubbo-nacos-consumer
 main:
  allow-bean-definition-overriding: true

dubbo:
 scan:
  # 配置 Controller 扫描路径
  base-packages: com.antoniopeng.dubbo.nacos.consumer.controller
 protocol:
  name: dubbo
  port: -1
 registry:
  address: nacos://192.168.127.132:8848

server:
 port: 8080

# 服务监控检查
endpoints:
 dubbo:
  enabled: true
management:
 health:
  dubbo:
   status:
    defaults: memory
    extras: threadpool
 endpoints:
  web:
   exposure:
    include: "*"

Controller

通过 org.apache.dubbo.config.annotation 包下的 @Reference 注解以 RPC 通信的方式调用服务，而对外提供以 HTTP 通信的方式的 Restful API

import com.antoniopeng.dubbo.nacos.provider.api.EchoService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class EchoController {

  @Reference(version = "1.0.0")
  private EchoService echoService;

  @GetMapping(value = "/echo/{string}")
  public String echo(@PathVariable String string) {
    return echoService.echo(string);
  }
}

验证是否成功

通过浏览器访问 Nacos Server 网址 http:192.168.127.132:8848/nacos ，会发现又多了一个服务在服务列表中。

然后再访问服务消费者对外提供的 RESTful API http://localhost:8080/echo/hi，浏览器会响应以下内容：

Echo Hello Dubbo hi

到此，实现了 Nacos 与 Dubbo 的融合。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • Java7和Java8中的ConcurrentHashMap原理解析

    Java7和Java8中的ConcurrentHashMap原理解析

    这篇文章主要介绍了Java7和Java8中的ConcurrentHashMap原理解析，对ConcurrentHashMap感兴趣的读者，一定要好好看一下
    2021-04-04
  • 图解分析Javaweb进程与线程

    图解分析Javaweb进程与线程

    这篇文章主要介绍了Javaweb进程与线程的知识,本篇文章通过简要的案例,讲解了它的基础原理与使用,以下就是详细内容,需要的朋友可以参考下
    2022-03-03
  • Spring Boot 3 集成 RabbitMQ 实践指南(原理解析)

    Spring Boot 3 集成 RabbitMQ 实践指南(原理解析

    本文介绍了SpringBoot 3集成RabbitMQ的实践指南,涵盖了RabbitMQ的核心原理、核心概念、高级特性、应用场景、环境搭建、核心配置类、消息生产者、消息消费者、接口控制器、监控与运维、最佳实践以及常见问题与解决方案等内容,感兴趣的朋友一起看看吧
    2025-02-02
  • java中的过滤器 Filter应用小结

    java中的过滤器 Filter应用小结

    文章主要介绍了Java Web中的过滤器（Filter）的基本概念、生命周期、配置和应用,过滤器可以拦截请求和响应,用于执行一些预处理或后处理操作,如设置编码、校验用户身份等,感兴趣的朋友一起看看吧
    2025-03-03
  • springboot配置Jackson返回统一默认值的实现示例

    springboot配置Jackson返回统一默认值的实现示例

    在项目开发中，我们返回的数据或者对象没有的时候一般直接返回的null，那么如何返回统一默认值，感兴趣的可以了解一下
    2021-07-07
  • SpringMvc获取请求头请求体消息过程解析

    SpringMvc获取请求头请求体消息过程解析

    这篇文章主要介绍了SpringMvc获取请求头请求体消息过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-09-09
  • Flowable流程引擎API与服务

    Flowable流程引擎API与服务

    这篇文章主要介绍了Flowable流程引擎API与服务,引擎API是与Flowable交互的最常用手段,总入口点是ProcessEngine,使用ProcessEngine,可以获得各种提供工作流或BPM方法的服务,下面我们来详细了解
    2023-10-10
  • java哈夫曼树实例代码

    java哈夫曼树实例代码

    这篇文章主要为大家介绍了java哈夫曼树实例代码，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2016-08-08
  • java中@DateTimeFormat和@JsonFormat注解的使用

    java中@DateTimeFormat和@JsonFormat注解的使用

    本文主要介绍了java中@DateTimeFormat和@JsonFormat注解的使用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2022-08-08
  • Java用BigDecimal解决double类型相减时可能存在的误差

    Java用BigDecimal解决double类型相减时可能存在的误差

    这篇文章主要介绍了Java用BigDecimal解决double类型相减时可能存在的误差，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-05-05

最新评论