Kafka 简介

一、kafka拓扑结构: 二、Kafka架构图: 三、Kafka的特点 1、同时为分布和订阅提供高吞吐量。 2、可进行持久化操作,将消息持久化到到磁盘,以日志的形式存储,因此可用于批量消费,例如ETL,以及实时应用程序。 通过将数据持久化到硬盘以及replication防止数据丢失。 3、分布式系统,易于向外拓展。所有的Producer、broker和consumer都会有多个,均为分布式。无需停

Windows下部署 Kafka(单机)

1、安装 JDK 并配置Java环境 2、安装ZooKeeper         Kafka的运行依赖于ZooKeeper,所以在运行Kafka之前我们需要先安装并运行ZooKeeper。         Kafka使用ZooKeeper作

ElasticSearch 配置文件介绍

##################### Elasticsearch Configuration Example ##################### # This file contains an overview of various configuration settings, # targeted at operations staff. Application develope

Windows下部署 ElasticSearch(集群)

先看单机ElasticSearch部署:Windows下部署 ElasticSearch、Head插件、Kibana(单机) 1、把 ElasticSearch 解压、复制到三个文件夹中 2、修改三个文件夹中 config 下的 elasticsearch.yml     详细配置可参考:elasticsearch.yml 的配置属性官方解释,Elastic

Python实现MQTT客户端

1、安装 paho-mqtt包命令 pip install paho-mqtt 2、接收端代码: import paho.mqtt.client as mqtt def on_connect(client, userdata, flags, rc):     print(\"Connected with result code \" + str(rc))    

Windows下搭建MQTT服务器(Apollo)

1、安装JDK,配置Java环境(省略) 2、下载 Apache 的 Apollo,可直接下载:apache-apollo-1.7.1-windows-distro(服务端).zip(MQTT服务软件挺多的,比如:EMQ、Mosquitto) MQTT服务软件列表,下图来源:https://github.com/mqtt/mqtt.github.io/wiki/server-support 3、解

MQTT 协议简介、与Websocket的区别

MQTT是一个基于客户端-服务器的消息发布/订阅传输协议。MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛。在很多情况下,包括受限的环境中,如:机器与机器(M2M)通信和物联网(IoT)。其在,通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。 MQTT协议原理: 简单来说就是客户端与服务端通过心跳包来保持连接,客户接收端向服务端订阅消息,

对象属性赋初始值写法

1、原始写法,也是最麻烦的一种写法: private string _text = null; public string text { get { return _text; } set { _text = (_text == null ? \"文本\" : value); } } 接下来所说的所有写法,都算是语法糖,经过反编译之后,还是写成第一种写法。 2、属性允许赋初始值(C#6.0新特性) p