1、pom文件依赖 2、Topology（拓扑中配置Spout，简单的配置可以不用单独的写KafkaSpout） 本打算用spring kafka的监听器去完成kafka的消费，实现KafkaSpout感觉有点绕，后面再研究，有相关经验的请告知更好的方式 3、Bolt, 负责拓扑请跟根据自己的业务 ...
分类：
其他好文 时间：
2019-04-26 16:42:10
阅读次数：
133
适合范围：storm自由开源的分布式实时计算系统，擅长处理海量数据。适合处理实时数据而不是批处理。 安装前的准备 1.安装zookeeper ①下载zookeeperhttps://zookeeper.apache.org/,点击download进入新页面之后， >download，选择一个镜像文件 ...
1、Storm与Kafka集成 我们知道storm的作用主要是进行流式计算，对于源源不断的均匀数据流流入处理是非常有效的， 而现实生活中大部分场景并不是均匀的数据流，而是时而多时而少的数据流入，这种情况下显然用批量处理是不合适的， 如果使用storm做实时计算的话可能因为数据拥堵而导致服务器挂掉，应 ...
分类：
其他好文 时间：
2019-04-26 11:28:06
阅读次数：
153
注册教程：https://blog.csdn.net/hdp134793/article/details/81530472 IntelliJ IDEA 注册码获取网站 IntelliJ IDEA 注册码获取网站 IntelliJ IDEA 注册码获取网站 ...
分类：
Web程序 时间：
2019-04-23 09:31:16
阅读次数：
383
`作者：jiangzz 电话：15652034180 微信：jiangzz_wx 微信公众账号：jiangzz_wy` 背景介绍 :将大规模流动数据在不断变化的运动过程中实现数据的实时分析，捕捉到可能有用的信息，并把结果发送到下一计算节点。 主流流计算框架 :Kafka Streaming、Apac ...
分类：
Web程序 时间：
2019-04-17 16:30:16
阅读次数：
255
Storm系列三： Storm消息可靠性保障 在上一篇 "Storm系列二： Storm拓扑设计" 中我们已经设计了一个稍微复杂一点的拓扑。 而本篇就是在上一篇的基础上再做出一定的调整。 在这里先大概提一下上一篇的业务逻辑， 我们会不断收到来自前端的消息，消息包含消息的发送时间，消息内容，结束标识， ...
分类：
其他好文 时间：
2019-04-11 23:21:45
阅读次数：
168
Storm系列二： Storm拓扑设计 在本篇中，我们就来根据一个案例，看看如何去设计一个拓扑， 如何分解问题以适应Storm架构，同时对Storm拓扑内部的并行机制会有一个基本的了解。 本章代码都在： "git@github.com:zyzdisciple/storm_study.git" 项目下 ...
分类：
其他好文 时间：
2019-04-07 22:02:50
阅读次数：
181
ionic3项目开发脚手架（基于个人练习项目） 一． 基于ionic3的生产环境搭建 安装jdk 》 安装AndroidSDK （1） 安装jdk（无须配置环境变量）（版本推荐1.8.0_162） 下载链接：https://www.oracle.com/technetwork/java/javase ...
分类：
其他好文 时间：
2019-04-06 17:16:21
阅读次数：
180
初入Storm 前言 学习Storm已经有两周左右的时间，但是认真来说学习过程确实是零零散散，遇到问题去百度一下，找到新概念再次学习，在这样的一个循环又不成体系的过程中不断学习Storm。 前人栽树，后人乘凉，也正是因为网上有这样多热心的人，分享自己的见解，才能够让开发变得更简单。也正是基于这个目的 ...
分类：
其他好文 时间：
2019-04-04 09:23:50
阅读次数：
147
最近项目中用到了storm，然后storm中用到了zookeeper，然后今天抽空整理一下zookeeper的安装使用，原来后期再慢慢学习。 本篇文档，操作部分是摘自其他博客，里边的问题分析是自己在实践过程中遇到然后特别记录的！ 开始： 一、Zookeeper原理简介 ZooKeeper是一个开放源 ...
分类：
其他好文 时间：
2019-03-30 13:36:03
阅读次数：
276
