【SpringCloud】-OpenFeign实战及源码解析、与Ribbon结合

news2024/11/20 15:31:07

一、背景介绍

二、正文

OpenFeign是什么？

OpenFeign（简称Feign）是一个声明式的Web服务客户端，用于简化服务之间的HTTP通信。与Nacos和Ribbon等组件协同，以支持在微服务体系结构中方便地进行服务间的通信； OpenFeign在默认情况下集成了Hystrix，提供了服务容错和服务降级的功能。

OpenFeign的作用是什么？

按照单一职责，也为了满足可复用、可扩展的核心我们可以对整体业务拆分成不同的服务，这样涉及到的一个问题就是某一个服务的逻辑实现需要依托另一个服务的信息，这样服务和服务之间需要通信来进行消息传递，但是服务和服务之间如果直接通信的话耦合关系变强，无法达到高复用的作用。使用了OpenFeign技术来解决这个问题，如果其中一个类需要调用另一个类的某一个方法的话，直接通过OpenFeign这个第三方转发这个调用，减少直接通信带来的耦合关系
在这里插入图片描述通过使用@FeignClien注解标识UserApiService这个客户端，对【internetbar-provider-user】这个服务远程调用。OpenFeign会根据接口自动创建一个实现类，发起HTTP请求去用Get的方式访问远程服务的【/userManage/getUserInfoById/{userId}】这个接口

Feign和OpenFeign的关系？

OpenFeign是对Feign的增强，对mvc注解的增强，那如何理解这句话呢？
共同点：Feign和OpenFeign都是用于简化服务之间HTTP通信的Web服务客户端
不同点：
所属不同：Feign是Netflix开发HTTP客户端；OpenFeign是SpringCloud对Feign的重新实现和增强，OpenFeign引入了SpringMVC的注解，例如：@GetMapping等注解可以类似于SpringMVC的一些效果
Hystrix集成：OpenFeign默认集成Hystrix，提供服务容错和服务降级的功能；Feign中需要显式地添加Hystrix的依赖并配置
在这里插入图片描述


Java还有哪些服务调用方式？

Okhttp、HttpURLConnection、RestTemplate


使用OpenFeign和不使用的区别对比？

我们先从代码形式上来看一下两者如何使用：
基于RestTemplate使用HTTP请求调用服务
在这里插入图片描述

在这里插入图片描述

基于OpenFeign调用
在这里插入图片描述
Feign可以根据接口的定义生成客户端所需要的代码，这部分代码被Feign封装到底层，并且底层同步的实现了负载均衡和服务发现、服务容错等功能，不需要我们像使用RestTemplate一样额外的手动去配置，一个简单的API接口就可以帮助我们做了很多事情。


实战

引入依赖

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

在启动类添加@EnableFeignClients注解

@EnableFeignClients(defaultConfiguration = FeignAutoConfiguration.class)

添加FeignClient接口

package cn.itcast.order.clients;

import cn.itcast.order.pojo.User;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

/**
 * @BelongsProject: cloud-demo
 * @BelongsPackage: cn.itcast.order.clients
 * @CreateTime: 2023-03-17  12:29
 * @Description: TODO
 * @Version: 1.0
 */
@FeignClient("userservice")
public interface UserClient {
    @GetMapping("/user/{id}")
    User findById(@PathVariable("id") Long id);
}

修改逻辑代码

使用RestTemplate**

package cn.itcast.order.service;

import cn.itcast.order.clients.UserClient;
import cn.itcast.order.mapper.OrderMapper;
import cn.itcast.order.pojo.Order;
import cn.itcast.order.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class OrderService {

    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private RestTemplate template;

    public Order queryOrderById(Long orderId){
        //1、根据用户id查询用户的订单信息
        Order order = orderMapper.findById(orderId);

        //2、利用RestTemplate发起http请求，查询用户信息
        String url="http://userservice/user/"+order.getUserId();
        User forObject = template.getForObject(url, User.class);

        //3、将user信息封装到Order中
        order.setUser(forObject);

        // 返回
        return order;
    }
}

使用Feign接口

package cn.itcast.order.service;

import cn.itcast.order.clients.UserClient;
import cn.itcast.order.mapper.OrderMapper;
import cn.itcast.order.pojo.Order;
import cn.itcast.order.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class OrderService {

    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private UserClient userClient;

    public Order queryOrderById(Long orderId) {
        //1、查询订单
        Order order = orderMapper.findById(orderId);
        //2、用Feign远程调用
        User user = userClient.findById(order.getUserId());
        //3、封装user到Order
        order.setUser(user);
        //4、返回
        return order;
    }
}

自定义配置

配置日志（以debug级别输出 ）

当我们进行服务调用的过程中有可能出现接口调用失败的问题，或者我们想要输出请求或响应的详细信息，我们可以配置日志

日志级别有哪些？

NONE：不记录任何日志（默认值）
BASIC：记录请求方法、URL、响应状态代码及执行时间
HEADERS：记录BASIC级别的基础上，记录请求和响应的header
FULL：记录请求和响应的header、body和元数据


方式一：配置文件

全局：所有服务生效
feign:
  client:
    config:
      default:
        loggerLevel: FULL

#某服务生效
feign:
  client:
    config:
      userservice:
        loggerLevel: FULL

方式二：配置类

添加配置类

package cn.itcast.order.config;

import feign.Logger;
import org.springframework.context.annotation.Bean;

/**
 * @BelongsProject: cloud-demo
 * @BelongsPackage: cn.itcast.order.config
 * @CreateTime: 2023-03-17  13:05
 * @Description: TODO
 * @Version: 1.0
 */
public class DefaultFeignConfiguration {

    @Bean
    public Logger.Level feignLogLevel() {
        return Logger.Level.BASIC;
    }
}

方式三：在启动类上添加注解@EnableFeignClients

全局配置：对所有生效

@EnableFeignClients(defaultConfiguration =FeignAutoConfiguration.class)

局部配置：只对userservice服务生效

@EnableFeignClients(value = “userservice”, defaultConfiguration = FeignAutoConfiguration.class)

性能优化

底层的客户端实现：
URLConnection：默认实现，不支持连接池
Apache HttpClient：支持连接池
OKHttp：支持连接池


优化包括：
使用连接池代替默认的URLConnection
日志级别，最好用basic或none

实操——Feign工程化

引入feign-httpClient依赖

 <dependency>
       <groupId>io.github.openfeign</groupId>
       <artifactId>feign-httpclient</artifactId>
</dependency>

配置文件开启httpClient功能，设置连接池参数

feign:
  client:
    config:
      default:  #default全局的配置
        loggerLevel: BASIC  #日志级别（基本的请求和响应信息）
  httpclient:
    enabled: true #开启feign对HttpClient的支持
    max-connections: 200  #最大的连接数
    max-connections-per-route: 50 #每个路径的最大连接数

目的：将公共的配置抽取出来

新建一个Maven项目，服务名叫——feign-api

引入依赖

<?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>cloud-demo</artifactId>
        <groupId>cn.itcast.demo</groupId>
        <version>1.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>feign-api</artifactId>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>

</project>

第一步、公有接口——工程化核心

在项目中创建一个Feign客户端接口，通过使用@FeignClient注解来声明要调用的服务和服务接口

package cn.itcast.feign.clients;

import cn.itcast.feign.pojo.User;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;

/**
 * @BelongsProject: cloud-demo
 * @BelongsPackage: cn.itcast.order.clients
 * @CreateTime: 2023-03-17  12:29
 * @Description: TODO
 * @Version: 1.0
 */
@FeignClient("userservice")
public interface UserClient {
    @GetMapping("/user/{id}")
    User findById(@PathVariable("id") Long id);
}

第二步、配置类—用于配置Feign客户端的一些属性，如日志级别等

package cn.itcast.feign.config;

import feign.Logger;
import org.springframework.context.annotation.Bean;

/**
 * @BelongsProject: cloud-demo
 * @BelongsPackage: cn.itcast.order.config
 * @CreateTime: 2023-03-17  13:05
 * @Description: TODO
 * @Version: 1.0
 */
public class DefaultFeignConfiguration {

    @Bean
    public Logger.Level feignLogLevel() {
        return Logger.Level.BASIC;
    }
}

实体类

package cn.itcast.feign.pojo;

import lombok.Data;

@Data
public class User {
    private Long id;
    private String username;
    private String address;
}

orderservice服务

第三步、启动类—启用Feign客户端

在Spring Boot应用程序中，通过使用@EnableFeignClients注解启用Feign客户端，并指定要扫描的Feign客户端接口所在的包。

package cn.itcast.order;

import cn.itcast.feign.clients.UserClient;
import com.netflix.loadbalancer.IRule;
import com.netflix.loadbalancer.RandomRule;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.cloud.openfeign.FeignAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@MapperScan("cn.itcast.order.mapper")
@SpringBootApplication
@EnableFeignClients(clients = UserClient.class,defaultConfiguration = FeignAutoConfiguration.class)

public class OrderApplication {

    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }

    /**
     * @Description: 将RestTemplate注册到容器中
     * @Date: 2023/3/13 11:28
     * @return: org.springframework.web.client.RestTemplate
     **/
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

    /**
     * @Description: 修改负载均衡策略方式
     * @Date: 2023/3/13 19:56
     * @return: com.netflix.loadbalancer.IRule
     **/
    @Bean
    public IRule randomRule() {
        return new RandomRule();
    }
}

实体类

package cn.itcast.order.pojo;

import cn.itcast.feign.pojo.User;
import lombok.Data;

@Data
public class Order {
    private Long id;
    private Long price;
    private String name;
    private Integer num;
    private Long userId;
    private User user;
}

Mapper类

package cn.itcast.order.mapper;

import cn.itcast.order.pojo.Order;
import org.apache.ibatis.annotations.Select;

public interface OrderMapper {

    @Select("select * from tb_order where id = #{id}")
    Order findById(Long id);
}

Controller类

package cn.itcast.order.web;

import cn.itcast.order.pojo.Order;
import cn.itcast.order.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/order")
public class OrderController {
   @Autowired
   private OrderService orderService;

    @GetMapping("/{orderId}")
    public Order queryOrderByUserId(@PathVariable("orderId") Long orderId) {
        // 根据id查询订单并返回
        return orderService.queryOrderById(orderId);
    }
}

第四步、使用Feign客户端—service类

在需要调用远程服务的地方，注入Feign客户端并使用

package cn.itcast.order.service;

import cn.itcast.feign.clients.UserClient;
import cn.itcast.feign.pojo.User;
import cn.itcast.order.mapper.OrderMapper;
import cn.itcast.order.pojo.Order;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class OrderService {

    @Autowired
    private OrderMapper orderMapper;

    @Autowired
    private UserClient userClient;

    public Order queryOrderById(Long orderId) {
        //1、查询订单
        Order order = orderMapper.findById(orderId);
        //2、用Feign远程调用
        User user = userClient.findById(order.getUserId());
        //3、封装user到Order
        order.setUser(user);
        //4、返回
        return order;
    }
}

通过上述的四个步骤（公有接口、配置类、启动类—启用Feign客户端、使用Feign客户端—service类）我们就实现了Feign的工程化，以声明式的方式定义了服务调用接口，配置了Feign客户端

基于工程化的思想，所有的服务调用被抽成公共的API，单独放在一个包中，我们只需要调用公共接口，不需要写太多重复代码，哪个服务需要调用引用对应的包就可以了，避免冗余代码，这也是设计模式思想（可复用）的体现。

集成Hystrix

我们需要先了解雪崩效应，通过OpenFeign进行多服务之间调用，如果服务提供者出现了故障将会导致服务消费者不可用。比方说login服务需要调用user服务获取登录用户的基本信息，此时user服务可能服务挂掉或者被攻击了，此时login服务可能将会处于等待过程，我们可以使用Hystrix进行熔断，当远程服务调用失败或超时时，熔断器会出发，并执行降级逻辑。
关于OpenFeign和Hystrix的集成使用请等待我之后关于Hystrix的博客详解哦~~~

源码解析

1、Spring启动时初始化-生成代理类

在服务启动时，Spring会加载配置并且初始化Spring容器、扫描并加载项目当中用到的组件，此时OpenFeign的配置也会被程序加载（包括：自定义Feign配置类、负载均衡配置、熔断器配置等），扫描带有@FeignClient注解的接口，Feign会使用动态代理生成代理类并注册到Spring容器中

2、服务发现和负载均衡

Nacos注册中心：如果项目中用到了Nacos注册中心，Feign会与Nacos集成通过服务名进行服务发现
Ribbon负载均衡：如果项目中使用了Ribbon，可以实现对服务实例的负载均衡
大家可以看下面这张图片，我们点进OpenFeign的依赖，会发现里面自动集成了Ribbon
在这里插入图片描述
那Feign和Ribbon、RestTemplate三者之间的关系是什么样的呢？
在这里插入图片描述

3、请求处理

场景：服务A调用服务B
当服务A通过OpenFeign的方式调用服务B时，实际上是通过代理类最终调用LoadBalancerFeignClient的execute方法，execute方法内部整合了Ribbon去实现负载均衡，最终会找到真实要请求的服务地址，从而发送RibbonRequest请求，返回响应内容给服务A
这也是Feign的核心代码：
在这里插入图片描述


为什么Feign第一次调用耗时很长？

这个问题是我在网上看到的一个问题，大家也可以参考参考图中说到的原因：
在这里插入图片描述


三、总结

OpenFeign帮助我们简化了服务之间的通信，同时继承了负载均衡、熔断器等功能，帮助我们更好的实现服务调用。之后我将会针对OpenFeign中集成的Hystrix做分享，大家敬请期待


如果有想要交流的内容欢迎在评论区进行留言，如果这篇文档受到了您的喜欢那就留下你点赞+收藏+评论脚印支持一下博主~

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

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

相关文章

互联科技：全域托管云赋能百行百业的数字化转型

互联科技：全域托管云赋能百行百业的数字化转型

在这个数字经济时代&#xff0c;云计算技术为企业提供了更加高效的业务管理机会&#xff0c;百行百业加速上云。对比几种云网方案&#xff0c;目前公有云方案存在可控性低、数据暴露风险、个性化需求难以满足、服务受限等问题&#xff1b;私有云方案存在建设成本高、建设周期长…
阅读更多...
TCP服务器的演变过程：IO多路复用机制select实现TCP服务器

TCP服务器的演变过程：IO多路复用机制select实现TCP服务器

IO多路复用机制select实现TCP服务器 一、前言二、新增使用API函数2.1、select()函数2.2、FD_*系列函数 三、实现步骤四、完整代码五、TCP客户端5.1、自己实现一个TCP客户端5.2、Windows下可以使用NetAssist的网络助手工具 小结 一、前言 手把手教你从0开始编写TCP服务器程序&a…
阅读更多...
文献研读｜Prompt窃取与保护综述

文献研读｜Prompt窃取与保护综述

本文介绍与「Prompt窃取与保护」相关的几篇工作。 目录 1. Prompt Stealing Attacks Against Text-to-Image Generation Models&#xff08;PromptStealer&#xff09;2. Hard Prompts Made Easy: Gradient-Based Discrete Optimization for Prompt Tuning and Discovery&#…
阅读更多...
Linux - 记录问题：怎么通过安装包的方式安装gRPC

Linux - 记录问题：怎么通过安装包的方式安装gRPC

适用场景 当docker 构建环境不能链接到github 的时候&#xff0c;就可以使用本地构建的方式 完成对应服务的构建需求。 参考案例 使用本地安装包的方式安装 gRPC 注意&#xff1a; 在Docker构建过程中&#xff0c;某些软件包可能会尝试配置时区&#xff0c;这通常需要交互式…
阅读更多...
性能优化，让用户体验更加完美（渲染层面）

性能优化，让用户体验更加完美（渲染层面）

前言 上一篇我们已经围绕“网络层面”探索页面性能优化的方案&#xff0c;接下来本篇围绕“浏览器渲染层面”继续开展探索。正文开始前&#xff0c;我们思考如下问题&#xff1a; 浏览器渲染页面会经过哪几个关键环节&#xff1f;“渲染层面”的优化从哪几方面着手&#xff1f…
阅读更多...
智能三维数据虚拟现实电子沙盘

智能三维数据虚拟现实电子沙盘

一、概述 易图讯科技&#xff08;www.3dgis.top&#xff09;以大数据、云计算、虚拟现实、物联网、AI等先进技术为支撑&#xff0c;支持高清卫星影像、DEM高程数据、矢量数据、无人机倾斜摄像、BIM模型、点云、城市白模、等高线、标高点等数据融合和切换&#xff0c;智能三维数…
阅读更多...
Git基础学习_p1

Git基础学习_p1

文章目录 一、前言二、Git手册学习2.1 Git介绍&前置知识2.2 Git教程2.2.1 导入新项目2.2.2 做更改2.2.3 Git追踪内容而非文件2.2.4 查看项目历史2.2.5 管理分支&#x1f53a;2.2.6 用Git来协同工作2.2.7 查看历史 三、结尾 一、前言 Git相信大部分从事软件工作的人都听说过…
阅读更多...
SadTalker数字人增加视频输出mp4质量精度

SadTalker数字人增加视频输出mp4质量精度

最近在用数字人简易方案&#xff0c;看到了sadtalker虽然效果差&#xff0c;但是可以作为一个快速方案&#xff0c;没有安装sd的版本&#xff0c;随便找了个一键安装包 设置如上 使用倒是非常简单&#xff0c;但是出现一个问题&#xff0c;就是输出的mp4都出马赛克了 界面上却…
阅读更多...
001、安装 Rust

001、安装 Rust

目录 1. 安装 Rust 2. 安装编译器 Visual Studio Code 3. 更新、卸载、文档命令 4. 结语 1. 安装 Rust 安装 Rust 非常简单&#xff0c;首先进入 Rust官网 &#xff0c;然后点击右上角的 Install 。 进入 Install 界面&#xff0c; 它会自动识别你当前的操作系统并给你推荐…
阅读更多...
自带AI算法的热红外相机

自带AI算法的热红外相机

Tofu AIIR 是识别跟踪与热红外成像一体化的模组&#xff0c;支持热红外视频下的多类型物体检测、识别、跟踪等功能。 产品支持视频编码、设备管理、目标检测、深度学习识别、跟踪等功能&#xff0c;提供多机版与触控版管理软件&#xff0c;为二次开发提供了丰富的SDK接口和开源…
阅读更多...
Xshell——Windows将本地文件上传到Linux服务器

Xshell——Windows将本地文件上传到Linux服务器

1、scp命令 scp是基于ssh的网络文件传输命令&#xff0c;可以将本地文件或文件夹直接上传到服务器指定位置。命令格式&#xff1a; 上传文件 scp -P port filepath usernameip:TargetPath 上传文件夹 scp -r -P port filepath usernameip:TargetPath -P port&#xff1a;用于指…
阅读更多...
Spark的生态系统概览：Spark SQL、Spark Streaming

Spark的生态系统概览：Spark SQL、Spark Streaming

Apache Spark是一个强大的分布式计算框架&#xff0c;用于大规模数据处理。Spark的生态系统包括多个组件&#xff0c;其中两个重要的组件是Spark SQL和Spark Streaming。本文将深入探讨这两个组件&#xff0c;了解它们的功能、用途以及如何在Spark生态系统中使用它们。 Spark …
阅读更多...
Redis连接报错-Could not connect to Redis at 127.0.0.1:6379: Connection refused

Redis连接报错-Could not connect to Redis at 127.0.0.1:6379: Connection refused

进入Redis所在路径&#xff0c;命令行输入redis-cli报错&#xff1a;Could not connect to Redis at 127.0.0.1:6379: Connection refused 解决方法&#xff1a; redis-server redis.conf 连接成功&#xff1a;
阅读更多...
装饰模式（单一责任）

装饰模式（单一责任）

Decorator&#xff08;装饰模式&#xff1a;单一责任模式&#xff09; 链接&#xff1a;装饰模式实例代码 解析 目的 在某些情况下我们可能会“过度地使用继承来扩展对象的功能”&#xff0c;由于继承为类型引入的静态特质&#xff0c;使得这种扩展方式缺乏灵活性&#xff…
阅读更多...
H5调用企业微信扫一扫接口

H5调用企业微信扫一扫接口

一、依赖引入 <script src"http://res.wx.qq.com/open/js/jweixin-1.2.0.js"></script><!-- <script src"https://res.wx.qq.com/wwopen/js/jsapi/jweixin-1.0.0.js"></script> --><script src"https://open.work.…
阅读更多...
ASP.NET MVC的5种AuthorizationFilter

ASP.NET MVC的5种AuthorizationFilter

一、IAuthorizationFilter 所有的AuthorizationFilter实现了接口IAuthorizationFilter。如下面的代码片断所示&#xff0c;IAuthorizationFilter定义了一个OnAuthorization方法用于实现授权的操作。作为该方法的参数filterContext是一个表示授权上下文的AuthorizationContext对…
阅读更多...
探索前端开发趋势：2023年的新兴技术与发展方向

探索前端开发趋势：2023年的新兴技术与发展方向

随着科技的不断发展&#xff0c;前端开发领域也在不断演进。本文将详细介绍2023年前端开发的新兴技术和发展趋势&#xff0c;为开发者们指明前端技术的发展方向和面临的挑战。从WebAssembly、PWA到低代码开发&#xff0c;激动人心的全新前景等你探索。 随着科技的快速发展&…
阅读更多...
华锐视点为广汽集团打造VR汽车在线展厅，打破地域限制，尽享购车乐趣

华锐视点为广汽集团打造VR汽车在线展厅，打破地域限制，尽享购车乐趣

随着科技的飞速发展&#xff0c;我们正在进入一个全新的时代——元宇宙时代。元宇宙是一个虚拟的世界&#xff0c;它不仅能够模拟现实世界&#xff0c;还能够创造出现实世界无法实现的事物。而汽车行业作为人类生活的重要组成部分&#xff0c;也在积极探索与元宇宙的融合&#…
阅读更多...
SpringBoot3 整合Kafka

SpringBoot3 整合Kafka

官网&#xff1a;https://kafka.apache.org/documentation/ 消息队列-场景 1. 异步 2. 解耦 3. 削峰 4. 缓冲 消息队列-Kafka 1. 消息模式 消息发布订阅模式&#xff0c;MessageQueue中的消息不删除&#xff0c;会记录消费者的偏移量 2. Kafka工作原理 同一个消费者组里的消…
阅读更多...
手机之变@2023：高端化之“殇”、技术革新与新生机

手机之变@2023：高端化之“殇”、技术革新与新生机

【潮汐商业评论/原创】 消费者越来越不爱换手机了。 “我的手机用3年了&#xff0c;没坏也没卡&#xff0c;使用需求基本都能满足&#xff0c;没什么可换的。现在的手机出再高的配置&#xff0c;但我的需求没那么高&#xff0c;换一次成本也不小&#xff0c;实在换不动了。”…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023