rabbitmq kafka
RabbitMq windwows安装方式以及避坑指南
安装教程： 1、安装erlang语言： 下载安装包，一步步点击下一步即可。 https://github.com/erlang/otp/releases/download/OTP-26.0/otp_win64_26.0.exe 2、安装rabbitmq服务： 下载安装包，同理一步步点击下一步。 ht ......
rabbitMQ windows环境重装后报错RabbitMQ service is already present - only updating service parameters
错误如下：C:\Users\Administrator>rabbitmq-service installRabbitMQ service is already present - only updating service parametersC:\Program Files\erl\erts\bi ......
kafka安装
## 下载 下载kafka二进制文件  > 源码不可用于启动，会报错，无法找到kafka.kafka类 ......
Linux 安装 RabbitMQ
一、概要 1. 环境 (1) Rocky Linux 9.1 (2) Rabbit MQ 3.11.16 2. 安装方式 针对RHEL系统，Rabbit MQ官方介绍了两种安装方式: (1) 通过Yum repositories安装，需要配置Yum repositories文件并设置Rabbit M ......
rabbitmq
### 什么是rabbitmq mq全文Message Queue，中文为消息队列，消息队列是一种搞笑的异步通信机制，消息存储在队列里，可以让应用程序进行松耦合的通信，而rabbitmq是一种流行的开源消息队列软件，支持多种语言。 rabbitmq基本组成部分包含生产者、消费者、交换机、队列；生产者 ......
RabbitMQ系列-Exchange介绍
RabbitMQ系列 RabbitMQ系列-概念及安装 1. Exchange RabbitMQ系列-概念及安装 提到AMQP 0-9-1协议默认支持四种exchange，分别是Direct Exchange，Fanout Exchange，Topic Exchange，Headers Exchan ......
RabbitMQ Exchange的理解
AMQP 简介 从 AMQP 协议可以看出，Queue、Exchange 和 Binding 构成了 AMQP 协议的核心 Producer：消息生产者，即投递消息的程序。 Broker：消息队列服务器实体。 Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。 Binding：绑定 ......
【rabbitMQ】-延迟队列-模拟控制智能家居的操作指令
这个需求为控制智能家居工作，把控制智能家居的操作指令发到队列中，比如：扫地机、洗衣机到指定时间工作 一.什么是延迟队列？ 延迟队列存储的对象是对应的延迟消息，所谓“延迟消息” 是指当消息被发送以后，并不想让消费者立刻拿到消息，而是等待特定时间后，消费者才能拿到这个消息进行消费。 二.如何设置延迟队列 ......
转：EasyNetQ 一款.NET上RabbitMQ的领先客户端API
转自：https://www.duidaima.com/Group/Topic/ASP.NET/10511 ## 背景 在现在的项目中，消息队列的使用比较的频繁，消息队列的种类也较多，如：ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ等。消息队列中间件是 ......
RabbitMQ处理消息堆积问题---惰性队列
当生产者发送消息的速度超过了消费者处理消息的速度，就会导致队列中的消息堆积，直到队列存储消息达到上限。之后发送的消息就会成为死信，可能会被丢弃，这就是消息堆积问题。 解决消息堆积的两种思路 * 增加更多消费者，提高消费速度。也就是我们之前说的work queue模式 * 扩大队列容积，提高堆积上限（ ......
RabbitMQ---死信交换机
**什么是死信交换机？** 要先解释一下什么是死信：当一个队列中的消息满足下列情况之一。就可称为死信。 * 消费者使用basic.reject或 basic.nack声明消费失败，并且消息的requeue参数设置为false * 消息是一个过期消息，超时无人消费 * 要投递的队列消息满了，无法投递 ......
windows安装RabbitMQ及出现问题处理方法
一、安装准备工具1.下载Eralng，下面链接已提供otp_win64_20.2.exe链接： https://pan.baidu.com/s/1lmvCMPVAV1Ba9UogCdQpZg提取码：x9m7 注意：有 32位版本 otp_win32_21.3.exe 根据win系统而定2.下载rab ......
查看kafka指定位置offset消息
```java package com.infinitus.cdc.test; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerReco ......
Kafka 杂谈
开始之前 首先，此篇文章会有很多地方会和 RocketMQ 比较，不太熟悉 RocketMQ 可以去看看我之前写的RocketMQ基础概念剖析&源码解析，先有个大概的印象，可能会帮助你更好的理解 Kafka。 概览 什么是 Kafka？ 这里先给出结论，我不太希望在解释概念 X 的时候，说到「为了了 ......
使用NLog通过Kafka实现日志收集
使用NLog通过Kafka实现日志收集，最终在Kibana展示 NuGet包引用 <PackageReference Include="NLog.Kafka" Version="0.2.1" /> <PackageReference Include="NLog.Web.AspNetCore" Ver ......
Kafka实时数据即席查询应用与实践
Kafka中的实时数据是以Topic的概念进行分类存储，而Topic的数据是有一定时效性的，比如保存24小时、36小时、48小时等。而在定位一些实时数据的Case时，如果没有对实时数据进行历史归档，在排查问题时，没有日志追述，会很难定位是哪个环节的问题。 ......
RabbitMQ的消息可靠性
RabbitMQ如何保证消息可靠性？ 1.开启生产者确认机制，确保生产者的消息能到达队列。 2.开启持久化功能，确保消息未消费前在队列中不会丢失。 3.开启消费者确认机制为auto，由Spring确认消息处理成功后完成ack。 4.开启消费者失败重试机制，并设置MessageRecoverer，多次 ......
kafka
broker一般指服务器资源 概念理解 topic： 逻辑概念，用于联系Producer 和 Consumer的message生产和消费。Producer 生产的消息放入一个topic中，由Consumer通过对同一个topic的订阅进行消费 broker： 物理资源，一般一个broker指底层的一 ......
RabbitMQ之消息确认机制
# RabbitMQ之消息确认机制 标签（空格分隔）： php,rabbitmq 在使用RabbitMQ的时候，我们可以通过消息持久化操作来解决因为服务器的异常奔溃导致的消息丢失，除此之外我们还会遇到一个问题，当消息的发布者在将消息发送出去之后，消息到底有没有正确到达broker代理服务器呢？如果不 ......
Rabbitmq队列监控-发送钉钉消息
function DingdingRobot(){ curl ‘https://oapi.dingtalk.com/robot/send?access_token=xxxxxx’ -H ‘Content-Type: application/json’ \ -d ‘ {“msgtype”: “text ......
面试八股文之kafka
Kafka是什么？它的主要作用是什么？ 什么是Kafka broker? 如何启动并配置它们？ Kafka中的“Topic”和“Partition”是什么？它们在Kafka中有何作用？ Kafka的消息如何被存储在磁盘上？这种存储方式有什么优缺点？ 生产者如何将消息发送到Kafka集群？何时会出现“ ......
Kafka元数据缓存(metadata cache)
经常有人问的一个问题就是：Kafka broker到底是不是无状态的？网上有这样的说法： 正常情况下consumer会在消费完一条消息后线性增加这个offset。当然，consumer也可将offset设成一个较小的值，重新消费一些消息。因为offet由consumer控制，所以Kafka brok ......
docker安装rabbitMQ
输入命令 docker pull rabbitmq:3.7.7-management 设置账号和密码 docker run -d --name rabbitmq3.7.7 -p 5672:5672 -p 15672:15672 -v `pwd`/data:/var/lib/rabbitmq --ho ......
RabbitMQ系列-概念及安装
1. 消息队列 消息队列是指利用队列这种数据结构进行消息发送、缓存、接收，使得进程间能相互通信，是点对点的通信 而消息代理是对消息队列的扩展，支持对消息的路由，是发布-订阅模式的通信，消息的发送者并不清楚消息的接收者，消息可以被多个消费者接收。 使用消息队列的作用如下 异步:对于一些用户的请求，可能 ......
kafka.php
setRebalanceCb(function (RdKafka\KafkaConsumer $kafka, $err, array $partitions = null) { switch ($err) { case RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS: // ......
java api调用kafka 广播形式
已经启用了zookeeper和kafka 单机的ip为192.168.80.128 加入maven 的pom.xml代码如下 dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> ......
RabbitMQ入门学习
由于传统的RabbitMQ使用起来较为麻烦，这里便直接使用SpringAMQP这套模板。 先创建一个名为mq-study的SpringCloud项目，该项目下有两个子模块，consumer和publisher。分别对应消息的消费者和消息的生产者。 在mq-study的pom文件中引入SpringAM ......
centos7安装erlang、rabbitmq以及php扩展
# centos7安装erlang、rabbitmq以及php扩展 标签（空格分隔）： liunx,php 安装Erlang 版本：el7 erlang-20.3.8.25 erlang-20.3.8.25-1.el7.x86_64.rpm 1. 下载 wget --content-disposit ......
消息队列中间件（RabbitMQ）
# 说明 这篇文章是自己 Rabbitmq 的入门学习的记录。 # 预备知识 > **栈**（Stack） 是只允许在一端进行插入或删除的[线性表](https://so.csdn.net/so/search?q=线性表&spm=1001.2101.3001.7020)。栈又称为**后进先出**（L ......
【Azure 事件中心】使用Kafka的性能测试工具(kafka-producer-perf-test)测试生产者发送消息到Azure Event Hub的性能
问题描述 Azure Event Hub支持 kafka，所以为了测试消息生产者所在环境与Azure Event Hub之间发送消息的性能如何，特别使用 kafka 官方测试生产者，消费者的性能工具 ： kafka-producer-perf-test.bat kafka-consumer-perf ......