import subject from "nxjs/subject"; let sub = new subject(); //发布订阅 sub.subscribe(data=>{ console.log(data> }); //执行订阅的事件 sub.next(data); ...
分类:
其他好文 时间:
2020-03-15 09:59:30
阅读次数:
45
数据库无法删除,error:3724背景我们迁移一批windows服务器,因有SQLserver 复制,我们需提前测试验证一下环境,所以新建的一个testdb来验证复制配置,验证完毕之后,删除该库的发布订阅之后,发现无法删除testdb,提示error:3724,本次就记录一下处理该问题的步骤;环境... ...
分类:
数据库 时间:
2020-03-13 14:43:00
阅读次数:
78
简介 ZooKeeper 是一个开源的分布式协调服务,由雅虎创建,是 Google Chubby 的开源实现。分布式应用程序可以基于 ZooKeeper 实现诸如数据发布/订阅、负载均衡、命名服务、分布式协调/通知、集群管理、Master 选举、配置维护,名字服务、分布式同步、分布式锁和分布式队列等 ...
分类:
其他好文 时间:
2020-03-12 09:27:10
阅读次数:
63
一、概述 EventBus是一个基于观察者模式的发布/订阅事件总线框架。将事件的发送者和接收者分开,其可以简化组件之间的通讯,相对于BroadcastReceiver其更轻量级也更易用。 二、用法介绍 EventBus的用法非常的简单,大致上就四步: 1.注册事件 @Override protect ...
分类:
其他好文 时间:
2020-03-11 01:12:04
阅读次数:
120
1.kafka概述##1.1kafka简介ApacheKafka是一个快速、可扩展的、高吞吐的、可容错的分布式“发布-订阅”消息系统,使用Scala与Java语言编写,能够将消息从一个端点传递到另一个端点,较之传统的消息中间件(例如ActiveMQ、RabbitMQ),Kafka具有高吞吐量、内置分区、支持消息副本和高容错的特性,非常适合大规模消息处理应用程序。Kafka官网:http://kaf
分类:
其他好文 时间:
2020-03-09 13:12:17
阅读次数:
58
1.redis消息模式 发布消息通常有两种模式分为:队列模式(queuing)和发布订阅模式(publish-subscribe)。 队列模式中,consumers可以同时从服务端读取消息,每个消息只被其中一个consumer读到。 发布订阅模式中消息被广播到所有的consumer中,topic中的 ...
分类:
其他好文 时间:
2020-03-06 01:19:35
阅读次数:
100
1. 概述 Apache Kafka 是一个快速、可扩展的、高吞吐、可容错的分布式发布订阅消息系统。其具有高吞吐量、内置分区、支持数据副本和容错的特性,适合在大规模消息处理场景中使用。 笔者之前在物联网公司工作,其中 Kafka 作为物联网 MQ 选型的事实标准,这里优先给大家搭建 Kafka 集群 ...
分类:
其他好文 时间:
2020-03-04 21:21:23
阅读次数:
69
[TOC] 介绍 Kafka是由Apache软件基金会开发的一个开源流处理平台,由Scala和Java编写。 Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据。 安装 集群,需要把集群状态保存在 上,所以需要先安装 。 环境准备 主机名 | 系统 | I ...
分类:
其他好文 时间:
2020-03-03 20:52:02
阅读次数:
83
ZooKeeper 是一个典型的分布式数据一致性解决方案,分布式应用程序可以基于 ZooKeeper 实现诸如数据发布/订阅、负载均衡、命名服务、分布式协调/通知、集群管理、Master 选举、分布式锁和分布式队列等功能。 Zookeeper 一个最常用的使用场景就是用于担任服务生产者和服务消费者的 ...
分类:
其他好文 时间:
2020-03-01 14:37:31
阅读次数:
93
本文介绍使用发布订阅的方式进行vue组件间的通信 我认为这种方式比较自由, 不存在组件间的关系问题 1. 首先安装pubsub-js npm install --save pubsub-js 2. 订阅方组件 import PubSub from 'pubsub-js' mounted(){ // ...
分类:
Web程序 时间:
2020-03-01 00:19:11
阅读次数:
565