RabbitMQ分享

RabbitMQ遵循AMQP协议,自身采用Erlang生产者发消息,启动多个消费者实例来消费消息,每个消费者仅消费部分信息,可达到负载均衡的效果。

flink反压

flink反压过程介绍

RabbitMQ的幂等性、优先级队列和惰性队列

一、幂等性1、概念2、消息重复消费3、解决思路4、消费端的幂等性保障5、唯一 ID+指纹码机制6、Redis 原子性二、优先级队列1、使用场景2、如何添加3、实战三、惰性队列1、使用场景2、两种模式3、内存开销对比以上就是RabbitMQ的幂等性、优先级队列和惰性队列的相关知识点,希望对你有所帮助。

RabbitMQ(三):AMQP协议

因为RabbitMQ是一种遵循AMQP协议的分布式消息中间件,RabbitMQ实现的AMQP版本是0.9.1,所以在此处简单了解一下AMQP-0-9-1 协议。

.NET CORE消息队列RabbitMQ

RabbitMQ是一个开源的消息代理和队列服务器,用于在分布式系统中传递消息。它支持多种消息协议,提供可靠的消息传递、灵活的路由、集群和高可用性功能。

什么!你要学spark!

hadoop是什么 mapreduce概述 spark概述

Rabbitmq---topics模型之动态路由

一条消息会被所有订阅的队列都消费,但是在某种场景下,我们希望不同的消息被不同的队列消费。这时候就要用到direct的类型的交换机。,它的核心作用就是不同的消息可以被不同消费者消费,同时我们也可以让所有的消费者去消费这一个消息,fanout广播模型,只要生产者一发送,交换机会把所有的消息发给所有的广播

深入浅出RabbitMQ:顺序消费、死信队列和延时队列

通过//关键参数,支持发送延迟消息// 声明交换机"delay.queue", // 交换机名字"fanout", // 交换机类型true, // 是否持久化false,false,false,props, // 设置属性。

【分布式技术专题】「Zookeeper中间件」Paxos协议的原理和实际运行中的应用流程分析

Paxos算法是莱斯利·兰伯特(Leslie Lamport)1990年提出的一种基于消息传递的一致性算法。一个进程或者服务节点可能同时充当多种角色,可能既是Proposer又是Acceptor又是Learner。只要Proposer发的提案被Acceptor接受(半数以上的Acceptor同意才行

Spark---Master启动及Submit任务提交

Spark集群启动之后,首先调用$SPARK_HOME/sbin/start-all.sh,start-all.sh脚本中调用了“start-master.sh”脚本和“start-slaves.sh”脚本,在start-master.sh脚本中可以看到启动Master角色的主类:“org.apac

RabbitMQ堵塞问题复盘

记一次线上RabbitMQ的堵塞问题

RabbitMQ-交换机

RabbitMQ 中的交换机(Exchange)是消息路由的关键组件,它负责将消息路由到相应的队列。不同类型的交换机在消息路由时具有不同的规则。以下是 RabbitMQ 交换机的一些常见应用场景:1.直连交换机(Direct Exchange):2.场景: 当需要将消息直接路由到与消息的路由键完全匹

RabbitMQ的安装与使用

RabbitMQ是一个在AMQP基础上完成的,可复用的企业消息系统。他遵循Mozilla Public License开源协议。开发语言为Erlang。linux系统中安装RabbitMQ比较繁琐,这里使用的是Docker安装。死信队列就是在某种情况下,导致消息无法被正常消费(异常,过期,队列已满等

Kafka的基本介绍以及扩展

Kafka的基本命令介绍、kafka扩展

RabbitMQ鉴权设计以及相关探讨

鉴权,分别由**鉴**和**权**组成- **鉴**: 表示身份认证,认证相关用户是否存在以及相关的用户名和密码是否一致- **权**: 完成身份的**鉴**后,还需要判断用户是否有相关操作的权限。因此对于某一个用户来说,通常情况下,需要完成**鉴**和**权**才能够满足一个完整的业务场景,因此通

2.Zookeeper集成springboot操作节点,事件监听,分布式锁实现

1.Springboot项目中添加zookeeper 已经对应的客户端依赖 ,pom.xml文件如下。2.application.yml 文件中配置zookeeper连接的相关配置信息。3.java配置的方式添加zookeeper相关的配置。4.Zookeeper基础操作服务和分布式锁服务编码。5.

HADOOP完全分布式搭建(饭制版)

HADOOP完全分布式搭建

zookeeper到nacos的迁移实践

nacos作为一个比较新的开源组件,使用时必然会遇到各种各样的问题,本文重点介绍了笔者在迁移zookeeper到nacos中遇到的比较重要的坑点,希望对大家有所帮助,当然还有更多的细节限于篇幅未能罗列。

【kafka日常操作命令及分区分配】

使用zookeeper命令修改分区数发现报错,是因为kafka版本过高,该命令已经无法使用,修改为kafka-topics.sh --bootstrap-server kafka.safedog.cn:9092 --alter --topic serverBaseInfo.mysql --part

kafka可视化工具-kafkamap

kafka可视化界面

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

资讯同步

...
内容小助手

文章同步

...
Deephub

公众号:deephub-imba

...
奕凯

公众号:奕凯的技术栈