rabbitmq rocketmq kafka
RabbitMQ安装与使用
# 系统环境 1、JDK1.8 2、Centos7-64位 3、Erlang-OTP 23 4、RabbitMQ-3.8.5 **linux版本信息查看** `cat /proc/version` Linux version 3.10.0-1127.el7.x86_64 (mockbuild@kbu ......
docker-compose多服务器部署kafka集群
- Kafka 是一个开源的分布式事件流平台,依赖Zookeeper或者KRaft,本文基于Zookeeper。 ## 服务器IP配置 本文使用三个服务器来做集群搭建,IP如下: | nodeName | IP | | | | | node1 | 10.10.210.96 | | node2 | 1 ......
部署rabbitmq
文章目录 一、Erlang 1. Erlang下载 2. Erlang 上传并解压 3. 验证rabbitmq依赖是否安装 4. 安装rabbitmq依赖 5. Erlang 编译、安装 6. Erlang 配置环境变量 7. Erlang 验证 二、RabbitMQ 2.1. RabbitMQ 下 ......
使用RocketMQ组件对请求做削峰处理
内容 rocketMQ基本介绍 使用MQ,将购票流程一分为二。目前系统的吞吐量低,用户从购买车票到拿到票花费的时间较长。 增加排队购票功能。排队提示loading。 购票时序图 目前的时序图,用户发送购票请求,服务端校验验证码,拿令牌,拿锁,然后选座购票,结束流程才会返回。服务器执行时间太长。 增加 ......
kafka学习之三_信创CPU下单节点kafka性能测试验证
# kafka学习之三_信创CPU下单节点kafka性能测试验证 ## 背景 ``` 前面学习了 3controller+5broker 的集群部署模式. 晚上想着能够验证一下国产机器的性能. 但是国产机器上面的设备有限. 所以想着进行单节点的安装与测试. 并且记录一下简单结果 希望对以后的工作有指 ......
死信队列 - 死信交换机绑定配置【RabbitMQ】
一、逻辑图 二、死信交换机绑定配置 1 package cn.itcast.mq.config; 2 3 import org.springframework.amqp.core.*; 4 import org.springframework.context.annotation.Bean; 5 i ......
kafka的学习之一_带SASL鉴权的集群安装与启动
# kafka的学习之一_带SASL鉴权的集群安装与启动 ## 背景 ``` 想开始一段新的里程. 可能会比现在累, 可能会需要更多的学习和努力. kafka可能就是其中之一. 自己之前总是畏缩不前. 不想面对很多压力. 年龄已经很大了, 必须得向前看继续努力了. ``` ## 关于kafka `` ......
kafka的学习之二_kafka的压测与GUI管理
# kafka的学习之二_kafka的压测与GUI管理 ## 第一部分创建topic ``` cd /root/kafka_2.13-3.5.0 bin/kafka-topics.sh --create --bootstrap-server 10.110.139.184:9093 --command ......
windows环境下安装RabbitMQ(超详细)
windows环境下安装RabbitMQ(超详细) https://blog.csdn.net/qq_25919879/article/details/113055350 luckySnow-julyo 已于 2023-03-21 16:26:29 修改 66281 收藏 755分类专栏: rabb ......
Spring整合RabbitMQ详细解读
Spring整合RabbitMQ的步骤 代码示例骨架 POM.xml文件中的依赖包 生产者模块代码实现 消费者模块代码实现 运行结果 Spring整合RabbitMQ的步骤 使用Spring进行整合,可以使代码变得更加简单,逻辑更加清晰 代码示例骨架 在一个工程中创建了两个模块,一个是生产者一个是消 ......
RabbitMQ高级之消息可靠性投递
什么是可靠性投递? 生产者:作为消息发送方希望杜绝任何消息丢失或者投递失败场景。 RabbitMQ 为我们提供了两种方式用来控制消息的投递可靠性模式。 分别是: confirm 确认模式 return 退回模式 消息投递路线 如下所示是生产者到消费者的模型: RabbitMQ的整个消息投递的路径 P ......
使用 JMX-Exporter 监控 Kafka 和 Zookeeper
JVM 默认会通过 JMX 的方式暴露基础指标,很多中间件也会通过 JMX 的方式暴露业务指标,比如 Kafka、Zookeeper、ActiveMQ、Cassandra、Spark、Tomcat、Flink 等等。掌握了 JMX 监控方式,就掌握了一批程序的监控方式。本节介绍 JMX-Export ......
Kafka的文件顺序读写
# 背景说明 Kafka使用起来很方便,而且磁盘写入性能非常好,那么它是如何实现的呢。 在[Kafka的文档](https://kafka.apache.org/documentation/#persistence)说明中,有这样一段: ![](https://img2023.cnblogs.com ......
记录 Windows 下 RabbitMQ 的部署
1、软件下载 安装前需要安装 Erlang 语言环境: https://www.erlang.org/downloads Rabbit MQ 下载: https://www.rabbitmq.com/download.html 2、运行安装包,一路下一步 3、打开开始菜单,找到 RabbitMQ C ......
Kafka学习
Kafka学习 https://blog.csdn.net/Eternal_Blue/article/details/95598942 https://www.cnblogs.com/swordfall/p/10014300.html 常用命令 启停 开启zookeeper: ./zkServe ......
kafka——随笔
注:仅代表个人随笔,如有错误还请见谅kafka一认识 大数据中有两个主要挑战,第一个挑战是如何手机大量数据,第二个挑战是分析收集的数据,这就会用到消息传递系统 什么是消息系统? 消息系统负责将数据从一个应用程序传输到另一个应用程序,因此应用程序可以专注于数据,但不必担心如何共享数据。 分布式消息传递 ......
centos7-docker安装与配置kafka+zookeeper+kafkamanager
一、默认docker环境已经OK 拉镜像 docker pull wurstmeister/zookeeper docker pull wurstmeister/kafka docker pull sheepkiller/kafka-manager 删镜像 docker rmi +镜像id 查看镜像 ......
kafka常用命令
转 https://www.cnblogs.com/xgss/articles/16580433.html 1 启动zookeeper bin/zookeeper-server-start.sh config/zookeeper.properties 2 启动kafka bin/kafka-serv ......
kafka调研
Kafka 是一款分布式、支持分区、多副本,基于 Zookeeper 协调的发布/订阅消息系统,也就是常说的消息队列。目前市面上绝大多数业务系统使用消息队列的主要原因如下: 解耦:当下游系统需要当前系统数据时,无需通过 RPC 或 HTTP 接口的方式传递,直接发送 MQ,下游需要时直接从队列消费即 ......
kafka会丢消息么
1、Kafka是什么 一种高吞吐量的分布式、发布订阅消息系统,它可以处理消费者规模的,网站中的所有动作流数据,具有高性能、持久化、多副本备份、横向扩展能力…… 以时间复杂度为 O(1) 的方式提供消息持久化能力,即使对 TB 级以上数据也能保证常数时间复杂度的访问性能。 高吞吐率。即使在非常廉价的商 ......
必知必会:RocketMQ
1.优点: 应用解耦、异步处理、流量削峰。 2.消息模型: 发布-订阅模型。 一个消息可以被多个消费组消费; 一个消费组中包含多个消费者,同一个消费组的每个消费者负责一部分消息。 3.消息模式: 有两种,集群消息和广播消息,默认是集群消息。 集群消息:一个消费组共同消费一个主题的多个队列,每个队列只 ......
docker 安装rocketmq
1 启动NameServer docker pull rocketmqinc/rocketmq mkdir -p /docker/rocketmq/nameserver/logs /docker/rocketmq/nameserver/store docker run -d --restart=al ......
kafka的启动--windows版
首先下载并安装kafka 然后进入到安装目录输入cmd 然后先启动zookeerper输入下面的命令 zookeeper-server-start.bat ../../config/zookeeper.properties 再启动kafka,输入下面命令 kafka-server-start.bat ......
SpringBoot整合RocketMQ
前提是必须已经安装了RocketMQ并配置好相关的环境变量(自行百度) 第一步: 第二步: 第三步: 第四步: ......
SpringBoot整合RabbitMQ -- 直连交换机模式
前提是电脑上已经安装 RabbitMQ 第一步: 第二步: 第三步: 第四步: ......
kafka的一些工作总结
1.如果kafka一个topic下有多个partition(比如18个),如何将数据平均分配到每个partition? (1)如果能够一次性能够获取总数量,可以用数据的总数量/partition数量(18), 取平均后分配数据; (2)如果数据是逐一获取的,不能事先获取总数量,可以用获取的数据取ha ......
docker 安装kafka
docker run -d --name zookeeper --publish 2181:2181 --volume /etc/localtime:/etc/localtime zookeeper:latest docker run -d --name kafka --publish 9092:9 ......
RabbitMQ快速使用代码手册
本篇博客的内容为RabbitMQ在开发过程中的快速上手使用,侧重于代码部分,几乎没有相关概念的介绍,相关概念请参考以下csdn博客,两篇都是我找的精华帖,供大家学习。本篇博客也持续更新~~~ ......