微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦！

Nacos服务发现

分类：Dubbo作者：编程之家原文地址
 

一、项目总体结构

组件说明： API 网关 ：系统统一入口，屏蔽架构内部结构，统一安全拦截（ 该demo不实现网关 ） 。 application-1 ：应用 1 ，模拟应用，提供 http 接口服务。 service-1 ：微服务 1 ，模拟微服务，提供 dubbo 接口服务。 service-2 ：微服务 2 ，模拟微服务，提供 dubbo 接口服务。   调用流程： 所有访问系统的请求都要经过网关，网关转发 Http 请求至 application-1 ， application-1 使用 dubbo 调用 service1 完成自身业务，而后sevice1 调用 service2 完成自身业务。至此，完成所有组件贯穿。   架构中application与sevice的区别是什么？
  • service提供了基础服务功能；application组装基础服务功能，提供给用户直接可用的业务。
  • service服务粒度小、功能基础，不易发生改变；application提供上游业务功能，紧贴业务需求，容易发生改变。
  • 形成service支撑application的整体架构，增加多变的application甚至不需要变动service。

 

二、创建工程

工程整体结构如下：

1、父工程

完整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>

    <groupId>com.nacos</groupId>
    <artifactId>service</artifactId>
    <version>1.0-SNAPSHOT</version>

    <packaging>pom</packaging>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>2.1.0.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Greenwich.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>2.1.3.RELEASE</version> <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <!--在添加了该插件之后，当运行“mvn package”进行打包时，会打包成一个可以直接运行的 JAR 文件，使用“java -jar”命令就可以直接运行。这在很大程度上简化了应用的部署，只需要安装了 JRE 就可以运行。-->
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

 

2、实现application1

application1 属于应用层，提供 http 接口服务。  

2.1、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">
    <parent>
        <artifactId>service</artifactId>
        <groupId>com.nacos</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>application1</artifactId>

    <dependencies>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>

</project>

2.2、实现 application-1 功能

仅是一个测试代码

@RestController
@RequestMapping("app1")
public class ApplicationController {

    @GetMapping("/service")
    public String service(){
        return "app1-service";
    }
}

2.3、application1 配置

定义 bootstrap.yml 
server:
  port: 56020
  servlet:
    context-path: /application1
spring:
  application:
    name: application1
  main:
    allow-bean-deFinition-overriding: true # Spring Boot 2.1 需要设定
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848   #服务注册发现中心
        namespace: 9cd826a1-2bb5-4eeb-a2fb-20cb95ea65f2
        cluster‐name: DEFAULT
    config:
      group: SERVICE_GROUP
      server-addr: 127.0.0.1:8848
      file‐extension: yaml
      namespace: 9cd826a1-2bb5-4eeb-a2fb-20cb95ea65f2

 

2.4、application1 启动

当 Application1启动后，应用application1 将出现在 Nacos 控制台界面。   
@SpringBootApplication
@EnablediscoveryClient
public class Application1 {
    public static void main(String[] args) {
        SpringApplication.run(Application1.class, args);
    }
}

@EnablediscoveryClient将该应用标识为nacos服务发现客户端

可以在nacos控制台看到application1已经注册到服务中心了：

 

3、实现 Service1

3.1、定义父工程

定义 service1 父工程， 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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>service</artifactId>
        <groupId>com.nacos</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>Service1</artifactId>

    <packaging>pom</packaging>

</project>

3.2、定义service1api

为了方便其它服务调用 dubbo 服务，专门定义 api 工程，此工程将作为 jar 被其它工程依赖。 定义 service-1-api 工程， 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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>Service1</artifactId>
        <groupId>com.nacos</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>service1api</artifactId>
    
</project>
定义服务接口： 
package com.service1.api;

public interface ConsumerService {
    public String service();
}

3.3、实现service1server

添加相关 Maven 依赖： 
<?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">
    <parent>
        <artifactId>Service1</artifactId>
        <groupId>com.nacos</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.service1.server</groupId>
    <artifactId>service1server</artifactId>

    <dependencies>
        <dependency>
            <groupId>com.service1.api</groupId>
            <artifactId>service1api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>
    </dependencies>
</project>
实现 dubbo 服务 
@Service
public class ConsumerServiceImpl implements ConsumerService {
    public String service() {
        return "Consumer invoke " ;
    }
}
注意：使用 @org.apache.dubbo.confifig.annotation.Service 标记 dubbo 服务  
  配置 dubbo 服务   Service2 作为 dubbo 服务消费方配置与服务提供方类似，注意， service1 不仅是消费方，同时还是服务提供方： 
server:
  port: 56030
spring:
  application:
    name: service1
  main:
    allow-bean-deFinition-overriding: true #Spring Boot 2.1 需要设定,允许覆盖bean
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
        namespace: 9cd826a1-2bb5-4eeb-a2fb-20cb95ea65f2 #开发环境
      config:
        server-addr: 127.0.0.1:8848 #配置中心地址,和服务注册地址一样，nacos集服务管理和配置管理于一身
        file-extension: yaml
        namespace: 9cd826a1-2bb5-4eeb-a2fb-20cb95ea65f2 #开发环境
        group: SERVICE_GROUP #xx业务组
dubbo:
  scan:
    # dubbo 服务扫描基准包
    base-packages: com.nacosserver.service
  protocol:
    # dubbo 协议
    name: dubbo
    # dubbo 协议端口
    port: 20881
  registry:
    address: spring-cloud://localhost #相当于nacos的服务地址127.0.0.1:8848
  application:
    qos-enable: false #dubbo运维服务是否开启
  consumer:
    check: false #启动时是否检查依赖的服务
启动服务消费方应用   启动service1server，观察 nacos 服务列表，出现service1服务则说明成功：

 

3.4、实现 application1调用Service1

现在 service1 已暴露 dubbo 服务并注册到 nacos 中，下边实现 application1 调用 service1

 

（1）引用service1

在 application1 中引用 service1 ，在其pom.xml 中引入 service1api 的依赖   
        <dependency>
            <groupId>com.service1.api</groupId>
            <artifactId>service1api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
在 application1 中引入 spring-cloud-starter-dubbo 依赖，它会根据接口生成代理对象 
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>

（2）实现远程调用 

@RestController
@RequestMapping("app1")
public class ApplicationController {

    @org.apache.dubbo.config.annotation.Reference
    private ConsumerService consumerService;

    @GetMapping("/service")
    public String service(){
        return "app1-service" + consumerService.service();
    }
}

测试看到成功调用service1的service方法：

 

4、实现 Service2

如上面设计所示， Service2 需要暴露 dubbo 接口以供 service1 消费

 

4.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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>service</artifactId>
        <groupId>com.nacos</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <packaging>pom</packaging>
    <modules>
        <module>service2api</module>
    </modules>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>service2</artifactId>

</project>

4.2、定义service2api

定义 service2api 工程， 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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>service2</artifactId>
        <groupId>com.nacos</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>service2api</artifactId>
</project>
并定义服务接口， dubbo 服务接口是服务提供方与消费方的远程通讯契约，通常由普通的 Java 接口（ interface ）来声明，如 ProviderService 接口： 
package com.nacos.service2.api;

public interface ProviderService {
    String service();
}

4.3、实现service2server

（1）添加依赖

<?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">
    <parent>
        <artifactId>service2</artifactId>
        <groupId>com.nacos</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>service2server</artifactId>

    <dependencies>
        <dependency>
            <groupId>com.nacos</groupId>
            <artifactId>service2api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-starter-dubbo</artifactId>
        </dependency>
    </dependencies>
</project>

（2）实现 dubbo 服务

ProviderService 作为暴露的 dubbo 服务接口，服务提供方 service 2 server 需要将其实现： 
import com.nacos.service2.api.ProviderService;

@org.apache.dubbo.config.annotation.Service
public class ProviderServiceImpl implements ProviderService {
    public String service() {
        return "Provider invoke";
    }
}
其中， @org.apache.dubbo.config.annotation.Service 是 dubbo 服务注解，仅声明该 Java 服务（本地）实现为 dubbo 服务。 因此，下一步需要将其配置 dubbo 服务（远程）。     （ 3 ）配置 dubbo 服务   完整的 YAML 配置如下所示： 
server:
  port: 56040
spring:
  application:
    name: service2
  main:
    allow-bean-deFinition-overriding: true #Spring Boot 2.1 需要设定,允许覆盖bean
  cloud:
    nacos:
      discovery:
        server-addr: 127.0.0.1:8848
        namespace: 9cd826a1-2bb5-4eeb-a2fb-20cb95ea65f2 #开发环境
      config:
        server-addr: 127.0.0.1:8848 #配置中心地址,和服务注册地址一样，nacos集服务管理和配置管理于一身
        file-extension: yaml
        namespace: 9cd826a1-2bb5-4eeb-a2fb-20cb95ea65f2 #开发环境
        group: SERVICE_GROUP #xx业务组
dubbo:
  scan:
    # dubbo 服务扫描基准包
    base-packages: com.nacosserver.service
  protocol:
    # dubbo 协议
    name: dubbo
    # dubbo 协议端口
    port: 20891
  registry:
    address: spring-cloud://localhost #相当于nacos的服务地址127.0.0.1:8848
  application:
    qos-enable: false #dubbo运维服务是否开启
  consumer:
    check: false #启动时是否检查依赖的服务
（ 4 ）启动服务提供方应用   在引导 Service2Bootstrap 之前，请提前启动 Nacos 服务器。 当Service2Bootstrap启动后，应用 service2将出现在 Nacos 控制台界面。  

 

4.4、实现service1调用service2

在 service1 中添加 service2 的依赖   
        <dependency>
            <groupId>com.nacos</groupId>
            <artifactId>service2api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

4.5、实现远程调用

application1调用service1，service1调用service2 

@org.apache.dubbo.config.annotation.Service
public class ConsumerServiceImpl implements ConsumerService {

    @org.apache.dubbo.config.annotation.Reference
    ProviderService providerService;

    public String service() {
        return "Consumer invoke |"  +providerService.service(); 
    }
}

测试：

说明调用时成功的                    

 

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

dubbo九：timeout超时机制解析
在网络请求时，总会有各种异常情况出现，我们需要提前处理这种情况。在完善的rpc组件dubbo中，自然是不会少了这一层东西的。我们只需要通过一些简单的配置就可以达到超时限制的作用了。dubbo的设计理念是，客户端控制优先，服务端控制兜底。 1.超时机制的实现思路要想实
传统微服务框架如何无缝过渡到服务网格 ASM
作者：宇曾背景软件技术的发展历史，从单体的应用，逐渐演进到分布式应用，特别是微服务理念的兴起，让大规模、高并发、低延迟的分布式应用成为可能。云原生时代下，微服务框架本身也在不断地进化和迭代演进。微服务框架一般会涉及到以下几个知识点：本文我们着重探讨以下三大微服务框架：
抓到Dubbo异步调用的小BUG，再送你一个贡献开源代码的机会
hello，大家好呀，我是小楼。最近一个技术群有同学at我，问我是否熟悉Dubbo，这我熟啊~他说遇到了一个Dubbo异步调用的问题，怀疑是个BUG，提到BUG我可就不困了，说不定可以水，哦不...写一篇文章。问题复现遇到问题，尤其不是自己遇到的，必须要复现出来才好排查，截一个当时的聊天记录：他的问题
【实用】面对枯燥的源码，如何才能看得下去？
 一个软件开发人员，工作到了一定的年限（一般是3、4年左右），如果他还没学会阅读源码，那么他就会遇到瓶颈。因为到了这个时候的开发，他应该不仅仅只会做那些CURD的业务逻辑，而应该会根据公司的实际情况去写框架。而基本上没有谁能像天才一样从零写出一个框架，很多人写框架其实
Dubbo服务容错
当一个服务调用另一个远程服务出现错误时的外观Dubbo提供了多种容错方案，默认值为failover（重试）1）、FailoverCluster（默认）失败自动切换，当出现失败，重试其他服务器，通常用于读操作，但重试会带来更长延迟，可以通过属性retries来设置重试次数（不含第一次）2）、FailfastC
Dubbo中的设计模式
最近在看阿里开源RPC框架Dubbo的源码，顺带梳理了一下其中用到的设计模式。下面将逐个列举其中的设计模式，并根据自己的理解分析这样设计的原因和优劣。责任链模式责任链模式在Dubbo中发挥的作用举足轻重，就像是Dubbo框架的骨架。Dubbo的调用链组织是用责任链模式串连起来的。责任链
高并发架构系列：如何从0到1设计一个类Dubbo的RPC框架
在过去持续分享的几十期阿里Java面试题中，几乎每次都会问到Dubbo相关问题，比如：“如何从0到1设计一个Dubbo的RPC框架”，这个问题主要考察以下几个方面：你对RPC框架的底层原理掌握程度。考验你的整体RPC框架系统设计能力。具体，mike来为大家详解。RPC和RPC框架1.RPC(RemoteProcedure
Dubbo启动时检查
Dubbo在启动时会检查服务提供者所提供的服务是否可用，默认为True。（1）、单个服务关闭启动时检查（check属性置为false）1）、基于xml文件配置方式1<!--3、声明需要调用的远程服务接口，生成远程服务代理，可以和本地Bean一样使用-->2<dubbo:referenceid="userService"i
SpringBoot集成Dubbo
（1）、新建一个普通Maven项目，用于存放一些公共服务接口及公共的Bean等。项目： 公共Bean：1packagecn.coreqi.entities;23importjava.io.Serializable;45publicclassUserimplementsSerializable{6privateIntegerid;7privateStringuserName;
dubbo搭建
1.安装java:yuminstalljava2.下载Tomcat：wgethttp://mirrors.shu.edu.cn/apacheomcatomcat-9/v9.0.14/bin/apache-tomcat-9.0.14-fulldocs.tar.gz3.解压Tomcat：tar-xvfapache-tomcat-9.0.14.tar.gz-C/usr/local/cd/usr/local/mvapache-tomcat-9.0.14//usr/local
苹果市值2025年有望达4万亿美元
pythonJavaScriptjavaHTMLreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-bootreact-native