做应用即时聊天 netty-socketio github 搜索netty-socketio-demo netty-socketio 整合redis实现发布订阅 即时消息缓存到redis Redis的pub/Sub(订阅与发布) 反复尝试调用接口实现层 Spring boot使用spring ret ...
分类:
其他好文 时间:
2020-06-27 13:33:16
阅读次数:
57
let fs = require('fs'); // 发布订阅 发布和订阅没关系 中间通过数组进行关联 function Events() { this.callbacks = []; this.results = []; } // 订阅 Events.prototype.on = function ...
分类:
其他好文 时间:
2020-06-27 11:28:26
阅读次数:
48
0MQ (ZeroMQ) 是一个轻量级消息内核。它可用于C、C++、Python、.NET /Mono、Fortran 和 Java 语言。它运行在AIX ,FreeBSD的,基于HP - UX , Linux和MacOS下, OpenBSD系统, OpenVMS , QNX Neutrino,So ...
分类:
其他好文 时间:
2020-06-27 11:18:51
阅读次数:
398
点对点消息系统:生产者发送一条消息到queue,一个queue可以有很多消费者,但是一个消息只能被一个消费者接收,当没有消费者可用时,这个消息会被保存直到有一个可用的消费者,所以Queue实现了一个可靠的负载均衡。 发布订阅消息系统:发布者发送到topic的消息,只有订阅了topic的订阅者才会收到 ...
分类:
其他好文 时间:
2020-06-26 22:33:00
阅读次数:
79
kafka是什么Kafka最初由Linkedin公司开发,是一个分布式、分区的、多副本的、多订阅者,基于zookeeper协调的,发布/订阅模式的消息队列(Message Queue),Linkedin于2010年贡献给了Apache基金会并成为顶级开源项目。经过多年发展,Kafka已经由最初的日志 ...
分类:
其他好文 时间:
2020-06-25 10:16:04
阅读次数:
74
装饰模式核心内容: 观察者模式又称为发布订阅模式,定义了对象间的一对多依赖关系,当一个对象状态发生改变时,其相关依赖的其他对象都能接收到通知; 观察者模式的核心在于目标(Subject)和观察者(Observer)接口,目标有一个状态属性,观察者“订阅”这个目标,当目标的状态属性发生改变时,通知所有 ...
分类:
其他好文 时间:
2020-06-23 17:06:41
阅读次数:
50
ZooKeeper是什么? ZooKeeper是一个开源的分布式应用程序协调系统。简称ZK,ZK是一个典型的分布式数据一致性解决方案,分布式应用程序可以基于它实现数据的发布/订阅、负载均衡、名称服务、分布式协调/通知、集群管理、Master选举、分布式锁盒分布式队列等等功能。它运行在JAVA环境之中 ...
分类:
其他好文 时间:
2020-06-22 14:45:56
阅读次数:
46
Zookeeper 是一个典型的发布/订阅模式的分布式数据管理与协调框架,开发人员 可以使用它来进行分布式数据的发布和订阅。 通过对 Zookeeper 中丰富的数据节点进行交叉使用,配合 Watcher 事件通知机 制,可以非常方便的构建一系列分布式应用中年都会涉及的核心功能,如: 1、数据发布/ ...
分类:
其他好文 时间:
2020-06-20 18:56:45
阅读次数:
70
介绍 一种高吞吐量的分布式发布订阅消息系统 消息类型:主体Topic(广播)、队列Queue(一对一) 消息系统类型:同步消息系统、异步消息系统 常见消息产品:Redis、Kafka、JMS 术语 Topic:Kafka处理消息源(feeds of messages)的不同分类(不同于传统MQ) P ...
分类:
数据库 时间:
2020-06-18 21:34:03
阅读次数:
82
#介绍 ##1. 缓存产品介绍 Memcached(一般大公司会做二次开发再使用) Redis Tair(淘宝所使用的缓存产品,基于Memcache进行二次开发诞生的产品) ##2. Redis功能介绍 数据类型丰富(也就是存储结构不一样) (笔试、面试) 支持持久化 (笔试、面试) 多种内存分配及 ...
分类:
其他好文 时间:
2020-06-17 20:23:58
阅读次数:
44