lenmom

摘要： https://zhuanlan.zhihu.com/p/260077811 MQTT協議 概覽 杰克物聯網縫紉機的基礎網絡協議使用的是MQTT協議，所有網關、直連設備和服務器之間使用該協議進行通信。 MQTT是一個輕量的發布訂閱模式消息傳輸協議，專門針對低帶寬和不穩定網絡環境的物聯網應用設計。 M 閱讀全文

摘要： http://www.rzrgm.cn/php-linux/p/10800718.html 閱讀全文

摘要： 1. 安裝部署Java 下載需要安裝的軟件，下載地址：http://www.oracle.com/technetwork/java/javase/downloads/jre8-downloads-2133155.html 雙節安裝，并配置環境變量 使用下面的命令 驗證Java是否安裝成功 至于怎么w 閱讀全文

摘要： kafka_start_cluster.sh kafka_stop_cluster.sh 閱讀全文

摘要： http://www.rzrgm.cn/ynyhl/p/11320797.html 閱讀全文

摘要： 反壓(Back Pressure)機制主要用來解決流處理系統中，處理速度比攝入速度慢的情況。是控制流處理中批次流量過載的有效手段。 1 反壓機制原理 Spark Streaming中的反壓機制是Spark 1.5.0推出的新特性，可以根據處理效率動態調整攝入速率。 1.1 反壓定義 當批處理時間(B 閱讀全文

摘要： 1. spark submit參數介紹 你可以通過spark-submit --help或者spark-shell --help來查看這些參數。 使用格式: ./bin/spark-submit \ --class <main-class> \ --master <master-url> \ --d 閱讀全文

摘要： kafka支持配額管理，從而可以對Producer和Consumer的produce&fetch操作進行流量限制，防止個別業務壓爆服務器。本文主要介紹如何使用kafka的配額管理功能。 1 Kafka Quatas簡介 Kafka配額管理所能配置的對象（或者說粒度）有3種： user + clien 閱讀全文

摘要： 1. 客戶端認證 如果kafka客戶端是認證的，那么可以使用userId和clientId兩種認證方式。如果沒有認證只能使用clientId限流。 對clientId=clientA的客戶端添加限流設置。producer_byte_rate表示每秒最多能寫入到消息量，單位為byte/sec。cons 閱讀全文

摘要： 1. 什么是阻塞隊列？ 阻塞隊列（BlockingQueue）是一個支持兩個附加操作的隊列。這兩個附加的操作是：在隊列為空時，獲取元素的線程會等待隊列變為非空。當隊列滿時，存儲元素的線程會等待隊列可用。阻塞隊列常用于生產者和消費者的場景，生產者是往隊列里添加元素的線程，消費者是從隊列里拿元素的線程。 閱讀全文