首页 > > 程序设计 > Java技术 >

Spring Cloud Alibaba 与 Dubbo 的完美融合

2020-04-12 16:06:25来源：博客园 阅读 ()

新老客户大回馈,云服务器低至5折

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 负载均衡策略

  1. random：随机
  2. roundrobin：轮询
  3. leastactive：最少活跃数
  4. 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 的融合。

  • 文章作者：彭超
  • 本文首发于个人博客：https://antoniopeng.com/2020/02/13/springcloudalibaba/SpringCloudAlibaba%E4%B8%8EDubbo%E7%9A%84%E5%AE%8C%E7%BE%8E%E8%9E%8D%E5%90%88/
  • 版权声明：本博客所有文章除特别声明外，均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来自 彭超 | Blog！

原文链接:https://www.cnblogs.com/antoniopeng/p/12687715.html
如有疑问请与原作者联系

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有

上一篇：Java三大特性

下一篇：Spring Cloud Eureka 服务注册与发现中心

相关文章

IDC资讯： 主机资讯 注册资讯 托管资讯 vps资讯 网站建设

网站运营： 建站经验 策划盈利 搜索优化 网站推广 免费资源

网站联盟： 联盟新闻 联盟介绍 联盟点评 网赚技巧

行业资讯： 搜索引擎 网络游戏 电子商务 广告传媒

网络编程： Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它

服务器技术： Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护

软件技巧： 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷

网页制作： FrontPages Dreamweaver Javascript css photoshop fireworks Flash

程序设计： Java技术 C/C++ VB delphi

网络知识： 网络协议 网络安全 网络管理 组网方案 Cisco技术

操作系统： Win2000 WinXP Win2003 Mac OS Linux FreeBSD

热门词条
最新资讯
热门关注
热门标签