什么是RabbitMQ简介(优点)基于ErLang语言开发有高可用高并发的优点,适合集群。开源、稳定、易用、跨平台、支持多种语言、文档齐全。有消息确认机制和持久化机制,可靠性高。概念生产者和消费者Producer:消息的生产者Consumer:消息的消费者Queue消息队列提供了FIFO的处理机制,具有缓存消息的能力。在RabbitMQ中,队列消息可以设置为持久化,临时或者自动删除。如果是持久化的
分类:
其他好文 时间:
2020-07-19 11:25:40
阅读次数:
75
课程内容: 1. 简单的操作一下集群 2. 简单的介绍几个工具(企业) 3. Producer的原理(核心,重点) 4. 简单kafka的代码 5. 介绍里面的核心参数(重点) 消费者原理 --replica-factor 2 --partitions 2我们一般设置分区数,建议是节点的倍数 Pro ...
分类:
其他好文 时间:
2020-07-15 01:03:51
阅读次数:
81
内容: 1. kafka的核心概念 Topic:主题 Partition:分区 分区具体在服务器上面表现为其实就是一个目录 一个主题下面,有多个分区,这些分区会存储到不同的kafka的服务器上面 或者我们可以这样说:其实就是在不同的主机上面建了不同目录 Producer:生产者 Consumer:消 ...
分类:
其他好文 时间:
2020-07-13 23:09:51
阅读次数:
98
1. 基本概念 局域网 覆盖范围小 自己花钱买设备 带宽固定 自己维护 100米 带宽:10M 100M 1000M 广域网 距离比较远 花钱买服务 花钱买带宽 Internet ISP :电信运营商internet service producer 自己的机房 对网民提供访问Internet连接 ...
分类:
其他好文 时间:
2020-07-11 22:59:52
阅读次数:
80
topic相关 创建一个名为TEST的topic,分为10部分,每部分副本数量为3 /app/kafka_2.13-2.5.0/bin/kafka-topics.sh --zookeeper 1.1.1.3:2181 --create --topic TEST --partitions 10 --r ...
分类:
其他好文 时间:
2020-07-11 13:12:27
阅读次数:
37
Kafka的架构 包括Kafka的基本组成,Kafka的拓扑结构以及Kafka的内部通信协议。Kafka内部的通信协议是建立在Kafka的拓扑结构之上,而Kafka的拓扑结构是由Kafka的基本模块所组成的。 AK RELEASE 2.5.0 APRIL 15, 2020 Kafka的基本组成 Ka ...
分类:
其他好文 时间:
2020-07-10 15:36:48
阅读次数:
51
一.消息发送端 pom.xml <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> application.y ...
分类:
编程语言 时间:
2020-07-03 21:42:43
阅读次数:
76
消息丢失的场景 如果Kafka Producer使用“发后即忘”的方式发送消息,即调用producer.send(msg)方法来发送消息,方法会立即返回,但此时并不能说明消息已经发送成功。消息发送方式详见初次邂逅Kafka生产者。 如果在消息过程中发生了网络抖动,那么消息就会丢失;或发送的消息本身不 ...
分类:
其他好文 时间:
2020-07-03 19:33:54
阅读次数:
55
1. AMQP 1.1. 相关概念介绍 AMQP 一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。 AMQP是一个二进制协议,拥有一些现代化特点:多信道、协商式,异步,安全,扩平台,中立,高效。 RabbitMQ是AMQP协议的Erlang的实现 ...
分类:
其他好文 时间:
2020-07-03 15:31:57
阅读次数:
44
基础概念 正所谓工欲善其事,必先利其器。我们先来了解一下kafka的基础构成。 producer 消息生产者,发布消息到kafka集群的终端或服务。 broker kafaka集群中包含的服务器 topic 每条发布到kafka集群的消息属于的类别,即kafka是面向topic的。 partitio ...
分类:
其他好文 时间:
2020-07-01 14:24:04
阅读次数:
73