RocketMQ整理 概念 broker MQ服务节点 topic 主题 message queue 消息队列,类似于kafka中的partition producer 生产者,先去连接name server,查询到对应的broker信息,再去连接broker consumer 消费者,先去连接na ...
分类:
其他好文 时间:
2020-02-17 20:08:08
阅读次数:
85
本文源码:GitHub·点这里||GitEE·点这里一、搭建Kafka环境1、下载解压--下载wgethttp://mirror.bit.edu.cn/apache/kafka/2.2.0/kafka_2.11-2.2.0.tgz--解压tar-zxvfkafka_2.11-2.2.0.tgz--重命名mvkafka_2.11-2.2.0kafka2.112、启动Kafka服务kafka依赖Zoo
分类:
编程语言 时间:
2020-02-17 15:52:31
阅读次数:
78
起源 Kafka是由Apache软件基金会开发的一个开源流处理平台,由Scala和Java编写。该项目的目标是为处理实时数据提供一个统一、高吞吐、低延迟的平台。其持久化层本质上是一个“按照分布式事务日志架构的大规模发布/订阅消息队列”,这使它作为企业级基础设施来处理流式数据非常有价值。此外,Kafk ...
分类:
其他好文 时间:
2020-02-17 14:03:42
阅读次数:
83
Go语言介绍 为什么你应该学习Go语言? 开发环境准备 从零开始搭建Go语言开发环境 VS Code配置Go语言开发环境 Go语言基础 Go语言基础之变量和常量 Go语言基础之基本数据类型 Go语言基础之运算符 Go语言基础之流程控制 Go语言基础之数组 Go语言基础之切片 Go语言基础之map G ...
分类:
编程语言 时间:
2020-02-15 20:28:55
阅读次数:
78
消息队列的基本原理 消息队列是基于队列实现的,存储具有特定格式的消息数据。消息队列包括生产者,消息队列以及消费者。 RocketMQ的原理与工作机制 架构图 NameServer Cluster:名字服务器集群,类似于kafka中的zookeeper,提供分布式协调与管理的功能 Producer C ...
分类:
其他好文 时间:
2020-02-15 11:46:33
阅读次数:
63
对于Kafka与RabbitMQ、ActiveMQ协议,它们具体的区别如下:activemq: activemq支持主从复制、集群。但是集群功能看起来很弱,只有failover功能,即我连一个失败了,可以切换到其他的broker上。这一点貌似不太科学。假设有三个broker,其中一个上面没有cons ...
分类:
其他好文 时间:
2020-02-12 11:22:54
阅读次数:
68
一、认识RabbitMQ及用途MessageQueue(MQ)相对于一些大点的公司都会使用这个MQ,比如像kafka,rabbitmq,activeMQ,rocketMQ主要用于系统与系统之间,或者程序与程序之间进行数据的传递,那么作为消息中间件,我们可以将它作为消息代理服务器,最主要的就是作用就是系统之间的信息进行”结藕“,MQ是数据可靠性的重要保障。那么说起mq的作用之前呢,比如我们以前会遇到
分类:
其他好文 时间:
2020-02-11 09:23:18
阅读次数:
53
server.properties配置文件参数说明 必配置属性 每个kafka broker中配置文件server.properties默认必须配置的属性如下: broker.id=0 num.network.threads=2 num.io.threads=8 socket.send.buffer ...
分类:
其他好文 时间:
2020-02-10 14:09:03
阅读次数:
115
Kafka是由Apache软件基金会开发的一个高吞吐量的分布式发布订阅消息系统,由Scala和Java编写。官网地址:http://kafka.apache.org 0.基本概念 Broker:Kafka集群包含一个或多个服务器,这种服务器被称为broker。 Topic:每条发布到Kafka集群的 ...
分类:
其他好文 时间:
2020-02-10 13:37:49
阅读次数:
83
"offset" "topic" "consumer group" "consumer" "producer" "producer golang" topic 工具 "https://cwiki.apache.org/confluence/display/KAFKA/Replication+tool ...
分类:
其他好文 时间:
2020-02-09 18:42:32
阅读次数:
243