RabbitMQ中方法channel.basicAck的使用说明

通过设置multiple参数,可以实现批量确认消息的功能。如果消费者处理消息的速度很快,可以将其设置为true,一次性确认多条消息,提高处理效率。但如果消费者处理消息的速度比较慢,可能会导致消息堆积,造成内存占用过高。因此,在实际使用中需要根据实际情况来确定是否需要批量确认消息。在RabbitMQ中

【分布式链路追踪技术】sleuth+zipkin

分布式架构下,请求报错难以定位?五分钟,学会sleuth+zipkin实现分布式链路追踪。

【详解】Spark数据倾斜问题由基础到深入详解-完美理解-费元星

spark hive数据倾斜,一文从浅到深,完美理解和解决

链路追踪详解(四):分布式链路追踪的事实标准 OpenTelemetry 概述

为了解决这些问题,Google 开发了 Dapper 布式系统追踪的框架,Dapper 的思想启发了很多公司和开源项目,如 OpenTracing 和 OpenCensus,它们提供了标准化的 API 和库,以帮助开发者在他们的应用中实现分布式链路追踪和指标收集。OpenTelemetry 代表了分

Spark计算框架

Spark的诞生背景Spark 2009年诞生的一个技术,诞生的主要原因是因为Hadoop大数据解决方案存在一些弊端MR程序是基于磁盘进行运算,因此导致MR程序计算效率底下。MR程序无法计算复杂的任务,如果想要实现复杂的计算逻辑,可能编写多个MR Job,其中后续的Job依赖于前一个Job的输出,但

Kafka快速入门

简介kafka诞生于领英公司,于2011年初开源,并于2012年10月23日由apache孵化出站。kafka最初诞生是为了解决Linkedin数据管道问题。由java和scala编写的。是一种高吞吐量的分布式发布订阅消息系统,可以处理消费者在网站中的所有动作流数据。官网:http://kafka.

【rabbitMQ】rabbitMQ的下载,安装与配置

因为rabbitMQ是基于Erland,所以在安装rabbitMQ之前需要安装Erland。如果出现拒绝访问 http://localhost:15672。输入默认账号: guest 默认密码: guest。然后去服务器输入 http://localhost:15672。下载完

一文速览字节最新分布式操作系统KubeWharf

本文对Kubenetes 的基本概念和KubeWharf 的三个项目做了介绍,KubeWharf不仅仅是某一项或某几项技术,更是一种理念和引导,促进企业在上云的过程中使用相关技术来更好的发挥云计算的优势。针对大规模多租户集群的场景,进一步加强多租户支持,提供更细粒度的权限控制和更智能的资源分配。随着

Springboot:kafka运行成功,报错InvalidTopicException

官方说法:The client has attempted to perform an operation on an invalid topic. For example the topic name is too long, contains invalid characters etc. Th

RabbitMQ之ttl(过期消息)解读

TTL),也就是过期时间,RabbitMQ中可以对消息和队列设置TTL(消息的过期时间),消息在队列的生存时间一旦超过设置的TTL值,就称为dead message, 消费者将无法再收到该消息。当队列中的消息存留时间超过了配置的生存时间(TTL),则称该消息已死亡。注意,同一个消息被路由到不同的队列

面试官问我:线程锁导致的kafka客户端超时,如何解决?

今天在开发中遇到有一个环境的kafka client发送数据有部分超时的问题。

Zeus IoT : 基于 SpringBoot 的分布式开源物联网大数据平台

Zeus IoT 是一个集设备数据采集、存储、分析、观测为一体的开源物联网平台,全球首创基于 Zabbix 的物联网分布式数据采集架构,具备超百万级物联网设备的并发监控能力,真正具备工业级性能与稳定性的开源物联网大数据中台。Zeus IoT致力于让设备接入和数据处理变得开箱即用,使物联网企业得以聚焦

RabbitMQ-网页使用消息队列

RabbitMQ-网页使用消息队列

一文掌握分布式锁:Mysql/Redis/Zookeeper实现

一文掌握分布式锁:Mysql/Redis/Zookeeper实现

浅学消息中间件__RabbitMQ

中间件指处于两个系统之间的软件,消息中间件则是用于处理两个系统之间消息的软件,消息中间件拥有异步通信中间件传输应用解耦流量削峰的应用点,但是处理消息不是有RestTemplate、WebClient来处理吗,就这两个来说他们应用于同步通信、直接点对点之间通信,当请求足够庞大时,如铁路12306这两种

【RabbitMQ】- 延迟队列

延时队列,队列内部是有序的,最重要的特性就体现在它的延时属性上,延时队列中的元素是希望在指定时间到了以后或之前取出和处理,简单来说,延时队列就是用来存放需要在指定时间被处理的元素的队列。

kafka max.poll.records用法介绍

一、max.poll.records是什么 max.poll.records是Kafka consumer的一个配置参数,表示consumer一次从Kafka ...

kafka-consumer-groups.sh消费者组管理

拿到所有在线Broker列表 再给每个Broker发送。请求获取 消费者组数据。

项目实战之RabbitMQ死信队列应用

RabbitMQ项目实战之死信队列应用到此就结束啦!

前后端分离的开源分布式在线教育系统,帮助个人或者企业快速搭建一个轻量级的在线教育平台

首页功能,导航模块(自定义导航设置),广告模块(自定的轮播设置),课程模块(自定义课程设置)列表功能,分类模块(自定义分类设置),搜索模块(自定义搜索设置)课程详情页功能,课程介绍、目录的展示和购买、播放功能等个人中心,具有个人信息设置、密码修改、订单管理、学习记录等功能讲师中心,讲师信息管理、课程

登录可以使用的更多功能哦! 登录
作者榜
...
资讯小助手

资讯同步

...
内容小助手

文章同步

...
Deephub

公众号:deephub-imba

...
奕凯

公众号:奕凯的技术栈