Kafka概述 是基于点对点模式和发布订阅模式的分布式消息队列系统 为什么要用kafka,为什么要用消息队列 1）解耦： 2）冗余： 3）扩展性： 4）灵活性 & 峰值处理能力： 5）可恢复性： 6）顺序保证： 7）缓冲： 8）异步通信： kafka构架 1）Producer ：消息生产者，就是向k ...
分类：
其他好文 时间：
2019-11-17 20:51:01
阅读次数：
114
一、消息队列作用：解耦、削峰、缓冲（生产速度和消费速度不一致） 二、消息队列的两种模式：点对点模式（一对一）、发布订阅模式（一对多 1. 消费者主动拉取消息 2. 队列主动推消息） 三、基础架构： A、Broker kafka的一个进程（集群的一个节点） >>>Topic 主题，将数据分类 >>>P ...
分类：
其他好文 时间：
2019-11-08 19:08:51
阅读次数：
99
简介 发布-订阅模式又叫做观察者模式，他定义了一种一对多的依赖关系，即当一个对象的状态发生改变的时候，所有依赖他的对象都会得到通知。 回忆曾经 作为一名前端开发人员，给DOM节点绑定事件可是再频繁不过的事情。比如如下代码 这里我们订阅了document.body的click事件，当body被点击的时 ...
分类：
编程语言 时间：
2019-11-05 18:48:36
阅读次数：
99
第一部分： 发布订阅模式简介 发布—订阅模式又叫观察者模式，它定义对象间的一对多的依赖关系，当一个对象的状态发生改变时，所有依赖于它的对象都将得到通知。在javascript开发中，一般用事件模型来替代传统的发布—订阅模式。 发布—订阅模式可以广泛应用于异步编程中，是一种替代传递回调函数的方案。比如 ...
分类：
编程语言 时间：
2019-10-26 19:24:41
阅读次数：
139
Redis原理篇 1.发布 订阅模式 1.1列表 的局限 ? 前面我们说通过队列的 rpush 和 lpop 可以实现消息队列（队尾进队头出），但是消费者需要不停地调用 lpop 查看 List 中是否有等待处理的消息（比如写一个 while 循环）。为了减少通信的消耗，可以 sleep()一段时间 ...
分类：
其他好文 时间：
2019-10-22 20:19:05
阅读次数：
77
观察者模式 观察者模式也叫作发布-订阅模式，也就是事件监听机制。观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象，这个主题对象在状态上发生变化时，会通知所有观察者对象，使他们能够自动更新自己。 观察者模式的结构 一个软件系统常常要求在某一个对象状态发生变化时，某些其他的对 ...
分类：
其他好文 时间：
2019-10-22 13:01:09
阅读次数：
81
Kafka是一个分布式的基于发布/订阅模式的消息队列，主要应用于大数据实时处理领域。 1 快写 快读 看下面的图： 传统应用是 硬件到缓存，到应用 再socket进行传输，再进行网络传输，再到用户， 而kafka实现了零拷贝，但是其实也是拷贝一次，将数据拷贝到内存中，，同时也是将数据顺序存入磁盘，这 ...
分类：
其他好文 时间：
2019-10-16 00:14:30
阅读次数：
101
发布/订阅模式 Pub/Sub模式包含三个角色主题（Topic），发布者（Publisher），订阅者（Subscriber） 。多个发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。 Pub/Sub的特点 每个消息可以有多个消费者 发布者和订阅者之间有时间上的依赖性。针对某个主题（To ...
分类：
其他好文 时间：
2019-10-12 10:49:57
阅读次数：
98
Redis发布消息模式 生产消费模型 Redis发布消息通常有两种模式： 1：队列模式（queuing） 2：发布-订阅模式(publish-subscribe) 任务队列：顾名思义，就是“传递消息的队列”。与任务队列进行交互的实体有两类，一类是生产者（producer），另一类则是消费者（cons ...
分类：
其他好文 时间：
2019-10-02 14:33:06
阅读次数：
81
