黑马程序员技术交流社区

标题: 【郑州校区】基于Apache Storm Trident实时计算开发 下 [打印本页]
作者: 我是楠楠    时间: 2020-6-18 09:13
标题: 【郑州校区】基于Apache Storm Trident实时计算开发 下
【郑州校区】基于Apache Storm Trident实时计算开发 下

2.4 入门案例 pom.xml

Topology








2.5 实时防恶意服务器攻击系统
2.5.1 需求分析这个实时系统，主要是检测在一定时间内，某个IP访问某个些页面超过了一定的访问量，就会将IP拉入到黑名单。所以，每当一个IP访问了一次页面，就会将次IP的访问次数进行累加，并检测到超过一定数量的访问IP，就加入到“监狱”中让这个IP“反省”半个小时。本项目需要用到的技术点如下：

2.5.2 架构图



2.5.3 创建topic

3、副本数量为
32.5.4 模拟发送数据到Kafka
这里使用Spring Boot整合Kafka定时生成模拟测试的日志到Kafka中
pom.xml



application.properties
KafkaDataGen.java，定期随机生产消息到Kafka





Application.java，启动类
2.5.5 测试生产Kafka消息
如果能看到控制台不断打印输出以下消息，表示日志已经生产到kafka指定的topic中



















作者: 杨雁蓉    时间: 2020-6-19 11:10
:victory::loveliness::curse:



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2