MQ产品常用的三种协议： 1:JMS rocketMQ，activeMQ 2.AMQP RabbitMq 3.MQTT activeMQ RabbitMQ是AMQP的一种实现。 AMQP是什么？ 基本概念 broker：消息代理 producer: 消息的生产者 consumer: 消息的消费者 e ...
分类：
其他好文 时间：
2020-01-16 22:25:32
阅读次数：
93
路由发现：缓存中的路由信息什么时候更新呢？ 由QueueData转topicPublishInfo的List<QueueMessage>： 选择消息队列： sendLatencyFaultEnable=false，默认不启动Broker故障延迟机制， sendLatenFaultEnable=tru ...
分类：
其他好文 时间：
2020-01-16 00:50:47
阅读次数：
93
kafka 相关的知识进入 /usr/local/kafka 目录下查看端口 vim zookeeper.properties #文件中dataDir=/tmp/zookeeper代表zookeeper数据存储路径，clientPort=2182代表zookeeper的端口号为：2182，消费者需要 ...
分类：
其他好文 时间：
2020-01-13 20:22:45
阅读次数：
124
ack应答机制 有三个值： 0：producer不需要确认消息，直接发送消息给leader，有没有收到消息，producer不管； 上图中去掉5、6步；速度块，安全性最低（当broker故障，会 丢失数据 ）。 1：producer发送消息，确保leader写入成功，followers不管；上图中， ...
分类：
其他好文 时间：
2020-01-13 12:54:21
阅读次数：
496
本文记录一下kafka多机多Broker（集群）的基本配置，在上篇的基础上进行，上篇配置在192.168.7.151上，本篇在152上。 一、在服务器192.168.7.152上配置两个Broker 1、将151上的kafka远程拷贝到152上 [root@localhost local]# scp ...
分类：
其他好文 时间：
2020-01-12 16:42:11
阅读次数：
102
1.消息发送机制 Kafka的ack机制。 当producer向leader发送数据时，可以通过request.required.acks参数来设置数据可靠性的级别： 1（默认）：这意味着producer在ISR中的leader已成功收到的数据并得到确认后发送下一条message。如果leader宕 ...
分类：
其他好文 时间：
2020-01-11 20:15:43
阅读次数：
92
Celery架构 Celery的架构由三部分组成，消息中间件（message broker）、任务执行单元（worker）和 任务执行结果存储（task result store）组成。 消息中间件 Celery本身不提供消息服务，但是可以方便的和第三方提供的消息中间件集成。包括，RabbitMQ, ...
分类：
其他好文 时间：
2020-01-11 20:06:41
阅读次数：
97
IntroductionRabbitMQ is a message broker: it accepts and forwards messages. You can think about it as a post office: when you put the mail that you wa... ...
分类：
其他好文 时间：
2020-01-11 18:48:55
阅读次数：
94
RabbitMQ介绍以下内容搬运自RabbitMQ官网RabbitMQ is the most widely deployed open source message broker.RabbitMQ是使用最广泛的开源的消息中转器With tens of thousands of users, Rab... ...
分类：
其他好文 时间：
2020-01-11 11:35:30
阅读次数：
98
一、概念 相当于一个ActiveMQ服务实例 Broker其实就是实现了用代码的形式启动了ActiveMQ将MQ嵌入到java代码中，以便随时用随时启动，在用的时候再去启动这样能节约资源，也保证了可靠性。 二、按照不同配置文件启动ActiveMQ 1、 先将ActiveMQ根目录下conf文件夹中的 ...
分类：
其他好文 时间：
2020-01-10 22:19:39
阅读次数：
123
