【郑州校区】基于Apache Storm Trident实时计算开发 下

2.4 入门案例 pom.xml

Topology








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

• Kafka
• Redis
• Apache Storm Trident
• Spring BootSpring
• Data Redis
  
  

2.5.2 架构图



2.5.3 创建topic

• 启动Kafka集群
• 创建名字为visit_url的topic
• 指定partititon数量为
  

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



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





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

【郑州校区】基于Apache Storm Trident实时计算开发 下

2.4 入门案例 pom.xml

Topology








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

• Kafka
• Redis
• Apache Storm Trident
• Spring BootSpring
• Data Redis
  
  

2.5.2 架构图



2.5.3 创建topic

• 启动Kafka集群
• 创建名字为visit_url的topic
• 指定partititon数量为
  

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



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





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