Nacos的搭建及服务调用

news2024/9/25 9:34:24

文章目录

  • 一、搭建Nacos服务
    • 1、Nacos
    • 2、安装Nacos
    • 3、Docker安装Nacos
  • 二、OpenFeign和Dubbo远程调用Nacos的服务
    • 1、搭建SpringCloudAlibaba的开发环境
      • 1.1 构建微服务聚合父工程
      • 1.2 创建子模块cloud-provider-payment8001
      • 1.3 创建子模块cloud-consumer-order80
    • 2、远程服务调用OpenFeign
      • 2.1 Dubbo和OpenFeign的区别
      • 2.2 创建子模块cloud-consumer-openfeign-order80
      • 2.3 OpenFeign实现服务降级
    • 3、远程服务调用Dubbo
      • 3.1 创建接口服务工程cloud-service-api
      • 3.2 创建支付生产者工程cloud-dubbo-provider-payment8001
      • 3.3创建消费者cloud-dubbo-consumer-order80
      • 3.4 Dubbo实现服务降级
  • 总结

一、搭建Nacos服务

1、Nacos

  1. Nacos是阿里巴巴开源的服务注册中心以及配置中心，致力于给开发者提供一款便捷、简单上手的开源框架。
    Nacos包含了SpringCloud的注册中心Eureka、服务配置Config、服务总线Bus。
  2. Nacos提供四大功能，分别是服务发现和服务健康监测、动态配置服务、动态DNS服务、服务及其元数据管理。
    1）服务发现和服务健康监测
    Nacos使服务更容易注册，并通过DNS或HTTP接口发现其他服务，Nacos还提供服务的实时健康检查，以防止向不健康的主机或服务实例发送请求。
    2）动态配置服务
    动态配置服务允许在所有环境中以集中和动态的方式管理所有服务的配置。Nacos消除了在更新配置时重新部署应用程序，这使得配置的更改更加高效和灵活。
    3）动态DNS服务
    Nacos提供基于DNS协议的服务发现能力，旨在支持异构语言的服务发现，支持将注册在Nacos上的服务以域名的方式暴露端点，让第三方应用方便查阅及发现。
    4）服务及其元数据管理
    Nacos能让你从微服务平台建设的视觉去管理数据中心的所有服务及元数据，包括管理服务的描述、生命周期、服务的静态依赖分析、服务的健康状态、服务的流量管理、路由及安全策略。

2、安装Nacos

  1. 在官网下载Linux的Nacos安装包：https://github.com/alibaba/nacos/releases
  2. 通过mobax将安装包上传到虚拟机的/opt目录下
  3. 解压到/usr/local目录下：tar -zxvf nacos-server-2.2.3.tar.gz -C /usr/local
  4. 需要在虚拟机上配置JDK8以上的环境：https://blog.csdn.net/weixin_49076273/article/details/126636650
  5. 进入到nacos的bin目录下，启动单机模式的nacos服务器：sh startup.sh -m standalone
  6. 在浏览器访问：http://192.168.126.32:8848/nacos/
    在这里插入图片描述

3、Docker安装Nacos

  1. 安装Docker：https://blog.csdn.net/weixin_49076273/article/details/126532188

  2. 使用Docker拉取镜像：docker pull nacos/nacos-server:v2.2.0

  3. 单机版部署：docker run --name nacos -d -p 8848:8848 -p 9848:9848 -p 9849:9849 -e MODE=standalone -e NACOS_SERVER_IP=192.168.126.32 nacos/nacos-server:v2.2.0

  4. 在浏览器访问：http://192.168.126.32:8848/nacos/
    在这里插入图片描述帐号密码都是nacos

    使用docker容器搭建nacos，如果是nacos2.x需要把9848,9849这两个端口开放出来即可，这样就可以使用IDEA连接上Nacos。如果是1.x则直接使用8848端口即可

二、OpenFeign和Dubbo远程调用Nacos的服务

1、搭建SpringCloudAlibaba的开发环境

1.1 构建微服务聚合父工程

  1. 创建父工程springcloudalibaba
    在这里插入图片描述

  2. 配置注解生效激活
    在这里插入图片描述

  3. Java编译版本选择
    在这里插入图片描述

  4. 父工程的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.zzx</groupId>
    <artifactId>springcloudalibaba</artifactId>
    <version>1.0-SNAPSHOT</version>


    <!-- 统一管理jar包版本 -->
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <spring-cloud.version>2021.0.0</spring-cloud.version>
        <spring-boot.version>2.6.3</spring-boot.version>
    </properties>

    <!-- 子模块继承之后，提供作用：锁定版本+子modlue不用写groupId和version  -->
    <dependencyManagement>
        <dependencies>
            <!--spring boot 2.6.3-->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-parent</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <!--spring cloud 2021.0.0-->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

</project>

  5. IDEA开启Dashboard
    1）修改配置文件.idea/workspace.xml
    2）添加如下配置

     <component name="RunDashboard">
 <option name="ruleStates">
  <list>
   <RuleState>
    <option name="name" value="ConfigurationTypeDashboardGroupingRule" />
   </RuleState>
   <RuleState>
    <option name="name" value="StatusDashboardGroupingRule" />
   </RuleState>
  </list>
 </option>
 <option name="configurationTypes">
 <set>
  <option value="SpringBootApplicationConfigurationType" />
 </set>
</option>
</component>

  6. 删除src目录

1.2 创建子模块cloud-provider-payment8001

  1. 在父工程下，右键创建子模块cloud-provider-payment8001
    在这里插入图片描述

  2. 在cloud-provider-payment8001的POM文件中添加如下依赖

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

  3. 创建cloud-provider-payment8001的主启动类

    package com.zzx;

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * 主启动类
 */

// 注解开启注册发现服务功能
@EnableDiscoveryClient
@SpringBootApplication
@Slf4j
public class PaymentMain8001 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentMain8001.class,args);
        log.info("******  PaymentMain8001 启动成功   ******");
    }
}

  4. 在cloud-provider-payment8001的com.zzx.controller包下，创建PaymentController

    package com.zzx.controller;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 支付控制层
 */
@RestController
@RequestMapping("payment")
public class PaymentController {
    @GetMapping("index")
    public String index(){
        return "payment success";
    }
}

  5. 在cloud-provider-payment8001的resources中，创建application.yml文件

    server:
  port: 8001
spring:
  application:
    name: payment-provider
  cloud:
    nacos:
      discovery:
        # Nacos服务的地址
        server-addr: 192.168.126.32:8848

  6. 启动payment8001项目后，在Nacos中的服务管理的服务列表中会出现该服务
    在这里插入图片描述

1.3 创建子模块cloud-consumer-order80

  1. 在父工程下，右键创建子模块cloud-consumer-order80
    在这里插入图片描述

  2. 在cloud-consumer-order80的POM文件中添加如下依赖

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

  3. 创建cloud-consumer-order80的主启动类

    package com.zzx;

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * 主启动类
 */

// 注解开启注册发现服务功能
@EnableDiscoveryClient
@SpringBootApplication
@Slf4j
public class OrderMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderMain80.class,args);
        log.info("******  OrderMain80 启动成功   ******");
    }
}

  4. 在cloud-consumer-order80的resources中，创建application.yml文件

    server:
  port: 80
spring:
  application:
    name: order-consumer
  cloud:
    nacos:
      discovery:
        # Nacos服务的地址
        server-addr: 192.168.126.32:8848

  5. 启动order80项目后，在Nacos中的服务管理的服务列表中会出现该服务
    在这里插入图片描述

2、远程服务调用OpenFeign

2.1 Dubbo和OpenFeign的区别

  1. Apache Dubbo是一款微服务开发框架，他提供了RPC通信与微服务治理两大关键能力。这意味着使用Dubbo开发的微服务，将具备相互之间的远程发现和通信能力，同时利用Dubbo提供的丰富服务治理能力，可以实现诸如服务发现、负载均衡、流量调控等服务治理诉求。
  2. SpringCloud的通信采用OpenFeign组件。Feign基于Http传输协议，底层实现是Rest。从OSI7层模型上来看Rest属于应用层。
    OpenFeign在高并发场景下性能不够理想，成为性能瓶颈。
    使用场景：并发不高，性能要求也不高
  3. Dubbo框架的通信协议采用RPC协议，属于传输层协议，性能上自然比rest高。提升了交互的性能，保持了长连接，高性能。
    Dubbo性能更好，比如支持异步调用、Netty性能更好。
    使用场景：数据小，并发高

2.2 创建子模块cloud-consumer-openfeign-order80

  1. 在父工程下，右键创建子模块cloud-consumer-openfeign-order80
    在这里插入图片描述

  2. 在cloud-consumer-openfeign-order80的POM文件中添加如下依赖

    <dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>
    <!-- 引入openfeign依赖包 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>
    <!-- 引入负载均衡器依赖包 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-loadbalancer</artifactId>
    </dependency>
</dependencies>

  3. 创建cloud-consumer-openfeign-order80的主启动类

    package com.zzx;

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * 主启动类
 */

// 注解开启注册发现服务功能
@EnableDiscoveryClient
// 开启feign扫描
@EnableFeignClients
@SpringBootApplication
@Slf4j
public class OrderOpenFeignMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderOpenFeignMain80.class,args);
        log.info("******  OrderOpenFeignMain80 启动成功   ******");
    }
}

  4. 在cloud-consumer-openfeign-order80的com.zzx.service包中，创建IPaymentFeignService接口

    package com.zzx.service;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.GetMapping;

/**
 * OpenFeign远程调用
 */
@Service
@FeignClient(value = "payment-provider")
public interface IPaymentFeignService {
    @GetMapping("/payment/index")
    String index();
}

  5. 在cloud-consumer-openfeign-order80的com.zzx.controller包中，创建OrderController

    package com.zzx.controller;

import com.zzx.service.IPaymentFeignService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 订单微服务
 */
@RestController
@RequestMapping("order")
public class OrderController {
    @Autowired
    private IPaymentFeignService iPaymentFeignService;
    /**
     * 测试OpenFeign
     * @return
     */
    @GetMapping("index")
    public String index(){
        return iPaymentFeignService.index();
    }
}

  6. 在cloud-consumer-openfeign-order80的resources中，创建application.yml文件

    server:
  port: 80
spring:
  application:
    name: order-consumer-openfeign
  cloud:
    nacos:
      discovery:
        # Nacos服务的地址
        server-addr: 192.168.126.32:8848

  7. 启动openfeign-order80项目后，在Nacos中的服务管理的服务列表中会出现该服务
    在这里插入图片描述

  8. 在浏览器上测试使用OpenFeign进行远程服务调用，输入：http://localhost/order/index
    此时返回payment success即调用成功

2.3 OpenFeign实现服务降级

  1. 在cloud-consumer-openfeign-order80的POM文件中，引入服务降级的依赖

    <!-- 引入服务降级依赖包 -->
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>

  2. 在cloud-consumer-openfeign-order80的resources下的application.yml文件中，添加如下配置开启openfeign对sentinel的支持

    feign:
  sentinel:
    enabled: true

  3. 在cloud-provider-payment8001的PaymentController中添加如下超时方法

    @GetMapping("timeout")
public String timeout(){
    try {
        TimeUnit.SECONDS.sleep(3);
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    }
    return "payment success";
}

  4. 在cloud-consumer-openfeign-order80的OrderController中添加如下超时方法

    @GetMapping("timeout")
public String timeout(){
    return iPaymentFeignService.timeout();
}

  5. 在cloud-consumer-openfeign-order80的IPaymentFeignService中添加如下超时方法

    @GetMapping("/payment/timeout")
String timeout();

  6. 在浏览器上测试使用OpenFeign进行远程服务调用，输入：http://localhost/order/timeout
    此时返回报500错误，控制台显示读取超时
    在这里插入图片描述

  7. 实现服务降级的回调方法

  1. 需要在cloud-consumer-openfeign-order80的IPaymentFeignService接口中指定服务降级回调类

    @FeignClient(value = "payment-provider",fallback = PaymentServiceFallback.class)

    2）在cloud-consumer-openfeign-order80的com.zzx.fallback包下，创建PaymentServiceFallback服务降级回调类

    package com.zzx.fallback;

import com.zzx.service.IPaymentFeignService;
import org.springframework.stereotype.Component;

@Component
public class PaymentServiceFallback implements IPaymentFeignService {
    @Override
    public String index() {
        return null;
    }

    /**
     * 服务降级方法
     * @return
     */
    @Override
    public String timeout() {
        return "系统繁忙，请稍后再试";
    }
}
  1. 在浏览器访问：http://localhost/order/timeout
    此时会进行服务降级，回调服务降级类对应的方法
    在这里插入图片描述

3、远程服务调用Dubbo

3.1 创建接口服务工程cloud-service-api

  1. 在父工程下，右键创建子模块cloud-service-api
    在这里插入图片描述

  2. 创建一个公共支付接口

    package com.zzx.service;

/**
 * 支付接口
 */
public interface IPaymentService {
    String index();
}

3.2 创建支付生产者工程cloud-dubbo-provider-payment8001

  1. 在父工程下，右键创建子模块cloud-dubbo-provider-payment8001
    在这里插入图片描述

  2. 在cloud-dubbo-provider-payment8001的POM文件中，添加如下依赖

    <dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>
    <dependency>
        <groupId>com.zzx</groupId>
        <artifactId>cloud-service-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </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>
        <version>2021.0.1.0</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-lang3</artifactId>
        <version>3.12.0</version>
    </dependency>
</dependencies>

  3. 在cloud-dubbo-provider-payment8001中创建主启动类PaymentDubboMain8001

    package com.zzx;

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

/**
 * 主启动类
 */
@SpringBootApplication
@Slf4j
@EnableDiscoveryClient
public class PaymentDubboMain8001 {
    public static void main(String[] args) {
        SpringApplication.run(PaymentDubboMain8001.class,args);
        log.info("********** PaymentDubboMain8001 启动成功  ***********");
    }
}

  4. 在cloud-dubbo-provider-payment8001的resources中，创建application.yml，添加如下配置

    server:
  port: 8001
spring:
  main:
    allow-bean-definition-overriding: true
    allow-circular-references: true
  application:
    # 应用名
    name: payment-provider-dubbo
  cloud:
    nacos:
      discovery:
        # Nacos服务地址
        server-addr: 192.168.126.32:8848
# dubbo配置
dubbo:
  # dubbo 服务实现类扫描包
  scan:
    base-packages: com.zzx.service
  registry:
    # 注册地址
    address: nacos://192.168.126.32:8848
    timeout: 10000
  # Dubbo服务暴露协议的配置
  protocol:
    name: dubbo
    # port为协议端口，（-1表示自增端口，从20880开始）
    port: -1

  5. 在cloud-dubbo-provider-payment8001中，创建支付业务层PaymentServiceImpl

    package com.zzx.service.impl;

import com.zzx.service.IPaymentService;
import org.apache.dubbo.config.annotation.DubboService;
import org.apache.dubbo.config.annotation.Method;

/**
 * 支付业务层
 */
//以下是只将index方法注册到dubbo中
@DubboService(timeout = 5000,methods = {@Method(name="index",retries = 2)})
public class PaymentServiceImpl implements IPaymentService {
    @Override
    public String index() {
        return "dubbo payment";
    }
}

  6. 启动该服务后，查看该服务是否在Nacos中注册
    在这里插入图片描述

3.3创建消费者cloud-dubbo-consumer-order80

  1. 在父工程下，右键创建子模块cloud-dubbo-consumer-order80在这里插入图片描述

  2. 在cloud-dubbo-consumer-order80的POM文件中，添加如下依赖

    <dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>
    <dependency>
        <groupId>com.zzx</groupId>
        <artifactId>cloud-service-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </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>
        <version>2021.0.1.0</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
    <dependency>
        <groupId>org.apache.commons</groupId>
        <artifactId>commons-lang3</artifactId>
        <version>3.12.0</version>
    </dependency>

</dependencies>

  3. 创建cloud-dubbo-consumer-order80的主启动类

    package com.zzx;

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@SpringBootApplication
@Slf4j
@EnableDiscoveryClient
public class OrderDubboMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderDubboMain80.class,args);
        log.info("*******  OrderDubboMain80 启动成功  ******");
    }
}

  4. 在cloud-dubbo-consumer-order80的resources中，创建application.yml配置文件，添加如下配置

    server:
  port: 80
spring:
  main:
    allow-circular-references: true
    #在 Spring Boot 2.1 以及更高的版本增加该设定，因为 Spring Boot 默认调整了 Bean 定义覆盖行为。
    allow-bean-definition-overriding: true
  application:
    #应用名字
    name: order-consumer-dubbo
  cloud:
    nacos:
      discovery:
        #Nacos地址
        server-addr: 192.168.126.32:8848


#dubbo配置
dubbo:
  cloud:
    #dubbo.cloud.subscribed-services：表示要订阅服务的服务名，可以配置'*'，代表订阅所有服务，不推荐使用。若需订阅多应用，使用 "," 分割。
    subscribed-services: "*"
  registry:
    # 注册至Nacos
    address: nacos://192.168.126.32:8848
    # 超时时间
    timeout: 10000
  protocol:
    # 协议Dubbo
    name: dubbo
    # 端口号
    port: -1
  consumer:
    check: false

  5. 在cloud-dubbo-consumer-order80中创建订单业务层OrderService

    package com.zzx.service;

import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.stereotype.Service;

/**
 * 订单业务层
 */
@Service
public class OrderService {
    //支付服务远程调用
    @DubboReference
    private IPaymentService iPaymentService;

    public String index(){
        return iPaymentService.index();
    }
}

  6. 在cloud-dubbo-consumer-order80中创建订单控制层OrderController

    package com.zzx.controller;

import com.zzx.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * 订单控制层
 */
@RestController
@RequestMapping("/order")
public class OrderController {
    @Autowired
    private OrderService orderService;

    /**
     * 测试Dubbo远程调用服务
     * @return
     */
    @GetMapping("/index")
    public String index(){
        return orderService.index();
    }
}

  7. 启动该服务后，在浏览器访问：http://localhost/order/index
    在这里插入图片描述

3.4 Dubbo实现服务降级

  1. 在cloud-dubbo-provider-payment8001的PaymentServiceImpl实现类中，设置服务生产者集群容错模式cluster

    @DubboService(timeout = 5000,methods = {@Method(name="index",retries = 2)},cluster = "failfast")

    1）Failfast Cluster模式：这种模式称为快速失败模式，调用只执行一次，失败则立即报错。
    2）Failsafe Cluster模式：失败安全模式，如果调用失败， 则直接忽略失败的调用，而是要记录下失败的调用到日志文件。
    3）Failback Cluster模式：失败自动恢复，后台记录失败请求，定时重发。通常用于消息通知操作。
    4）Forking Cluster模式：并行调用多个服务器，只要一个成功即返回。通常用于实时性要求较高的读操作，但需要浪费更多服务资源。
    5）Broadcast Cluster模式：配置值为broadcast。广播调用所有提供者，逐个调用，任意一台报错则报错（2.1.0开始支持）。通常用于通知所有提供者更新缓存或日志等本地资源信息。

  2. 在cloud-dubbo-consumer-order80中，创建服务降级的回调类PaymentServiceFallback

    package com.zzx.service.fallback;

import com.zzx.service.IPaymentService;

/**
 * 支付服务降级处理
 */
public class PaymentServiceFallback implements IPaymentService {
    @Override
    public String index() {
        return "服务繁忙，请稍后再试！";
    }
}

  3. 在cloud-dubbo-consumer-order80的OrderService中，在DubboReference注解中添加一个mock指定回调类

    @DubboReference(mock = "com.zzx.service.fallback.PaymentServiceFallback")

  4. 先将dubbo的生产者跟消费者启动，然后关闭生产者，再访问：http://localhost/order/index
    在这里插入图片描述
    即配置了访问服务生产者失败后，立刻调用服务降级类的对应方法。

总结

  1. 在高并发场景下使用Dubbo，因为Dubbo长连接，如果不是高并发会浪费资源；低并发或者性能要求不高使用OpenFeign，因为OpenFeign不是长连接并且便于使用。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/810085.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

CORDIC算法理论详解

CORDIC算法理论详解

一、前言 要理解cordic算法&#xff0c;我们先证明一道中学的数学题。 已知&#xff0c;OA逆时针旋转θ角度后得到OB&#xff0c;线段OAOB&#xff0c;∠AOBθ&#xff0c;A 点坐标&#xff08;x1,y1&#xff09;,B 点坐标&#xff08;x2,y2&#xff09;。 求证&#xff1a;…
阅读更多...
Linux学习之系统函数库

Linux学习之系统函数库

cat /etc/redhat-release看到操作系统的版本是CentOS Linux release 7.6.1810 (Core)&#xff0c;uname -r可以看到内核版本是3.10.0-957.21.3.el7.x86_64&#xff0c;bash --version可以bash的版本是4.2.46。 在/etc/init.d/functions有许多系统定义好的函数&#xff0c;比如…
阅读更多...
数据结构基础：3.单链表的实现。

数据结构基础：3.单链表的实现。

单链表的介绍和实现 一.基本概念1.基本结构2.结构体节点的定义&#xff1a; 二.功能接口的实现0.第一个节点&#xff1a;plist1打印链表2创建一个节点3.头插4.头删5.尾插6.尾删7.查找8.在pos之前插入x9.在pos之后插入x10.删除pos位置11.删除pos的后一个位置12.链表释放 三.整体…
阅读更多...
缩略所写的代码

缩略所写的代码

有一长串的代码需要进行缩略 可以在要缩略的代码的前一行加上注释。并在其中写上 #region。 在最后一行的下一行加上注释&#xff0c;并在其中写上 #endregion。 最终结果&#xff1a;
阅读更多...
“华为杯”研究生数学建模竞赛2019年-【华为杯】D题：汽车行驶工况构建

“华为杯”研究生数学建模竞赛2019年-【华为杯】D题：汽车行驶工况构建

目录 摘 要&#xff1a; 1.问题背景与问题重述 1.1 问题背景 1.2 问题重述 2.模型假设 3.符号说明 4.问题一的求解 4.1 问题分析 4.2 异常数据的处理 4.2.1 明显错误数据的处理 4.2.2 加减速异常数据的处理 4.3 缺失数据的处理 4.3.1 数据插补处理 4.3.2 视为长期停车处理 4.3.…
阅读更多...
springboot编写mp4视频播放接口

springboot编写mp4视频播放接口

简单粗暴方式 直接读取指定文件&#xff0c;用文件流读取视频文件&#xff0c;输出到响应中 GetMapping("/display1/{fileName}")public void displayMp41(HttpServletRequest request, HttpServletResponse response,PathVariable("fileName") String fi…
阅读更多...
数学分析：流形1

数学分析：流形1

光滑道路是一个映射&#xff0c;但我们通过光滑道路的这个名词&#xff0c;可以想象成一个曲线。然后这个曲线上就会有一个速度的概念&#xff0c;这个速度在不同道路上&#xff08;但都经过同一个点x_0&#xff09;会有不同的方向&#xff0c;他们组成的空间就是切空间。速度就…
阅读更多...
The user specified as a definer (‘mysql.infoschema‘@‘localhost‘) does not exist

The user specified as a definer (‘mysql.infoschema‘@‘localhost‘) does not exist

连接上报无法刷新浏览器 use mysql; show tables; ERROR 1449 (HY000): The user specified as a definer (mysql.infoschemalocalhost) does not existselect user,host from user; 删除 drop user ‘mysql.infoschema’‘127.0.0.1’; 重现创建 create user ‘mysql.infosc…
阅读更多...
《视觉SLAM十四讲》笔记（4-6）

《视觉SLAM十四讲》笔记（4-6）

文章目录 4 李群与李代数4.1 李群与李代数基础4.1.1 群4.1.2 李代数的引出4.1.3 李代数的定义 4.2 指数与对数映射4.3 李代数求导与扰动模型 5 相机与图像5.1 相机模型5.1.1 针孔相机模型5.1.2 畸变5.1.3 双目相机5.1.4 RGB-D相机 6 非线性优化 4 李群与李代数 为了解决什么样…
阅读更多...
Redis学习路线（6）—— Redis的分布式锁

Redis学习路线（6）—— Redis的分布式锁

一、分布式锁的模型 &#xff08;一&#xff09;悲观锁&#xff1a; 认为线程安全问题一定会发生&#xff0c;因此在操作数据之前先获取锁&#xff0c;确保线程串行执行。例如Synchronized、Lock都属于悲观锁。 优点&#xff1a; 简单粗暴缺点&#xff1a; 性能略低 &#x…
阅读更多...
KWP2000协议和OBD-K线

KWP2000协议和OBD-K线

KWP2000最初是基于K线的诊断协议&#xff0c; 但是由于后来无法满足越来越复杂的需求&#xff0c;以及自身的局限性&#xff0c;厂商又将这套应用层协议移植到CAN上面&#xff0c;所以有KWP2000-K和KWP2000-CAN两个版本。 这篇文章主要讲基于K线的早期版本协议&#xff0c;认…
阅读更多...
【数据结构】无头+单向+非循环链表（SList）（增、删、查、改）详解

【数据结构】无头+单向+非循环链表（SList）（增、删、查、改）详解

一、链表的概念及结构 1、链表的概念 之前学习的顺序表是用一段物理地址连续的存储单元依次存储数据元素的线性结构&#xff0c;而链表是一种物理存储结构上非连续、非顺序的存储结构&#xff0c;数据元素的逻辑顺序是通过链表中的指针链接次序实现的&#xff0c;可以实现更加…
阅读更多...
Element UI如何自定义样式

Element UI如何自定义样式

简介 Element UI是一套非常完善的前端组件库&#xff0c;但是如何个性化定制其中的组件样式呢&#xff1f;今天我们就来聊一聊这个 举例 就拿最常见的按钮el-button来举例&#xff0c;一般来说默认是蓝底白字。效果图如下 可是我们想个性化定制&#xff0c;让他成为粉底红字应…
阅读更多...
在windows上安装minio

在windows上安装minio

1、下载windows版的minio&#xff1a; https://dl.min.io/server/minio/release/windows-amd64/minio.exe 2、在指定位置创建一个名为minio文件夹&#xff0c;然后再把下载好的文件丢进去&#xff1a; 3、右键打开命令行窗口&#xff0c;然后执行如下命令&#xff1a;(在minio.…
阅读更多...
【数据结构】栈（Stack）的实现 -- 详解

【数据结构】栈（Stack）的实现 -- 详解

一、栈的概念及结构 1、概念 栈&#xff1a;一种特殊的线性表&#xff0c;其只允许在表尾进行插入和删除元素操作。进行数据插入和删除操作的一端称为栈顶&#xff0c;另一端称为栈底。栈中的数据元素遵守后进先出 LIFO&#xff08;Last In First Out&#xff09;的原则。 压栈…
阅读更多...
Android Glide预处理preload原始图片到成品resource 预加载RecyclerViewPreloader，Kotlin

Android Glide预处理preload原始图片到成品resource 预加载RecyclerViewPreloader，Kotlin

Android Glide预处理preload原始图片到成品resource & 预加载RecyclerViewPreloader&#xff0c;Kotlin <uses-permission android:name"android.permission.READ_EXTERNAL_STORAGE" /><uses-permission android:name"android.permission.READ_MED…
阅读更多...
集合的概述

集合的概述

基本的集合有六种&#xff0c;分别是Vector、ArrayList、LinkedList、TreeSet、HashSet、LinkedHashSet 其中Vector、ArrayList、LinkedList实现了List接口&#xff0c;LinkedHashSet实现了HashSet接口&#xff0c;TreeSet、HashSet实现了Set接口 List和Set又实现了Collectio…
阅读更多...
Anaconda原理解析及使用

Anaconda原理解析及使用

anaconda想必大家都不陌生&#xff0c;属于使用python的重要工具&#xff0c;更是学习机器学习、深度学习的必备工具。在搭建环境过程中&#xff0c;感觉出现的许多问题根源在于对于anaconda的基本原理理解不到位&#xff0c;导致许多无效操作。为此&#xff0c;我重温了一遍an…
阅读更多...
TypeScript实战篇 - TS实战：花田APP的架构

TypeScript实战篇 - TS实战：花田APP的架构

目录 TS实现花田APP的聊天Node端 整体架构 项目拆分 项目的特点 模型层 所有系统都是模型的外设 模型层的优势 TS实现花田APP的聊天Node端 整体架构 项目拆分 代号&#xff1a;huatian 5个独立的npm包 huatian/ui 花田的主项目huatian/component 花田组件库huatian/…
阅读更多...
❤️创意网页：高考加油倒计时网页文字加多版 - 增加祝福语句和下雪背景效果

❤️创意网页：高考加油倒计时网页文字加多版 - 增加祝福语句和下雪背景效果

✨博主&#xff1a;命运之光 &#x1f338;专栏&#xff1a;Python星辰秘典 &#x1f433;专栏&#xff1a;web开发&#xff08;简单好用又好看&#xff09; ❤️专栏&#xff1a;Java经典程序设计 ☀️博主的其他文章&#xff1a;点击进入博主的主页 前言&#xff1a;欢迎踏入…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023