diff --git a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/CustomRedisCountApp.java b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/CustomRedisCountApp.java
index c3986b5..db0c9c6 100644
--- a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/CustomRedisCountApp.java
+++ b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/CustomRedisCountApp.java
@@ -12,6 +12,10 @@ import org.apache.storm.redis.common.config.JedisPoolConfig;
 import org.apache.storm.redis.common.mapper.RedisStoreMapper;
 import org.apache.storm.topology.TopologyBuilder;
 
+
+/**
+ * 利用自定义的RedisBolt实现词频统计
+ */
 public class CustomRedisCountApp {
 
     private static final String REDIS_HOST = "192.168.200.226";
diff --git a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/CountBolt.java b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/CountBolt.java
index 2884315..29974df 100644
--- a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/CountBolt.java
+++ b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/CountBolt.java
@@ -11,6 +11,9 @@ import org.apache.storm.tuple.Values;
 import java.util.HashMap;
 import java.util.Map;
 
+/**
+ * 进行词频统计
+ */
 public class CountBolt extends BaseRichBolt {
 
     private Map<String, Integer> counts = new HashMap<>();
diff --git a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/DataSourceSpout.java b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/DataSourceSpout.java
index c4a351f..541caba 100644
--- a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/DataSourceSpout.java
+++ b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/DataSourceSpout.java
@@ -11,6 +11,10 @@ import org.apache.storm.utils.Utils;
 
 import java.util.*;
 
+
+/**
+ * 产生词频样本的数据源
+ */
 public class DataSourceSpout extends BaseRichSpout {
 
     private List<String> list = Arrays.asList("Spark", "Hadoop", "HBase", "Storm", "Flink", "Hive");
diff --git a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/RedisCountStoreBolt.java b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/RedisCountStoreBolt.java
index 9a5cfd1..4dd9433 100644
--- a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/RedisCountStoreBolt.java
+++ b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/RedisCountStoreBolt.java
@@ -8,6 +8,10 @@ import org.apache.storm.topology.OutputFieldsDeclarer;
 import org.apache.storm.tuple.Tuple;
 import redis.clients.jedis.JedisCommands;
 
+
+/**
+ * 自定义RedisBolt 利用Redis的哈希数据结构的hincrby key field功能进行词频统计
+ */
 public class RedisCountStoreBolt extends AbstractRedisBolt {
 
     private final RedisStoreMapper storeMapper;
diff --git a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/SplitBolt.java b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/SplitBolt.java
index d92ca07..844f4e5 100644
--- a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/SplitBolt.java
+++ b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/SplitBolt.java
@@ -10,6 +10,9 @@ import org.apache.storm.tuple.Values;
 
 import java.util.Map;
 
+/**
+ * 将每行数据按照指定分隔符进行拆分
+ */
 public class SplitBolt extends BaseRichBolt {
 
     private OutputCollector collector;
diff --git a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/WordCountStoreMapper.java b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/WordCountStoreMapper.java
index 21e4ab3..6343e9f 100644
--- a/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/WordCountStoreMapper.java
+++ b/code/Storm/storm-redis-integration/src/main/java/com/heibaiying/component/WordCountStoreMapper.java
@@ -4,6 +4,9 @@ import org.apache.storm.redis.common.mapper.RedisDataTypeDescription;
 import org.apache.storm.redis.common.mapper.RedisStoreMapper;
 import org.apache.storm.tuple.ITuple;
 
+/**
+ * 定义流数据与Redis中数据的映射关系
+ */
 public class  WordCountStoreMapper implements RedisStoreMapper {
     private RedisDataTypeDescription description;
     private final String hashKey = "wordCount";