Add Redis configuration and dependencies

Author: Trinh-Tan-Dat

pom.xml

@@ -87,6 +87,18 @@
 
 
 
+		<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
+		<dependency>
+			<groupId>redis.clients</groupId>
+			<artifactId>jedis</artifactId>
+			<version>5.1.0</version>
+		</dependency>
+		<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-redis -->
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-redis</artifactId>
+			<version>3.2.4</version>
+		</dependency>
 
 
 

src/main/java/com/programming/videoService/config/RedisConfig.java

@@ -0,0 +1,44 @@
+package com.programming.videoService.config;
+
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.repository.configuration.EnableRedisRepositories;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
+import org.springframework.beans.factory.annotation.Value;
+@Configuration
+@EnableRedisRepositories
+public class RedisConfig {
+    @Value("${spring.redis.host}")
+    private String redisHost;
+
+    @Value("${spring.redis.port}")
+    private int redisPort;
+
+    @Value("${spring.redis.password}")
+    private String redisPassword;
+
+
+    @Bean
+    public RedisConnectionFactory redisConnectionFactory() {
+        RedisStandaloneConfiguration redisConfig = new RedisStandaloneConfiguration();
+        redisConfig.setHostName(redisHost);
+        redisConfig.setPort(redisPort);
+        redisConfig.setPassword(redisPassword);
+
+        return new LettuceConnectionFactory(redisConfig);
+    }
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
+        template.setConnectionFactory(connectionFactory);
+        template.setKeySerializer(new StringRedisSerializer());
+        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
+        return template;
+    }
+}

src/main/java/com/programming/videoService/service/VideoService.java

@@ -17,6 +17,7 @@
 import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.data.mongodb.gridfs.GridFsOperations;
 import org.springframework.data.mongodb.gridfs.GridFsTemplate;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
 
@@ -25,6 +26,7 @@
 import java.io.InputStream;
 import java.sql.Timestamp;
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -40,6 +42,11 @@ public class VideoService {
     @Autowired
     private MongoTemplate mongoTemplate;
 
+    @Autowired
+    private RedisTemplate<String, Object> redisTemplate;
+
+    private final String VIDEO_CACHE_PREFIX = "video_";
+
     public String addVideo(MultipartFile upload, String userID, byte[] thumbnail, Timestamp timestamp, String description, String userName, String videoName)
             throws IOException {
         DBObject videoMetadata = new BasicDBObject();
@@ -64,6 +71,17 @@ public String addVideo(MultipartFile upload, String userID, byte[] thumbnail, Ti
         template.store(new ByteArrayInputStream(thumbnail), upload.getOriginalFilename() + "_thumbnail", "image/png",
                 thumbnailMetadata);
 
+
+        // Save video information to Redis
+        Map<String, Object> videoDetails = new HashMap<>();
+        videoDetails.put("videoId", videoID.toString());
+        videoDetails.put("userID", userID);
+        videoDetails.put("title", videoName);
+        videoDetails.put("description", description);
+        videoDetails.put("views", 0);
+        redisTemplate.opsForHash().putAll(VIDEO_CACHE_PREFIX + videoID.toString(), videoDetails);
+
+
         return videoID.toString();
     }
 
@@ -149,11 +167,25 @@ public void setInputStream(InputStream inputStream) {
     }
 
     public Map<String, Object> getDetails(String videoId) {
+        // Checked data in Redis
+        Map<Object, Object> cachedVideo = redisTemplate.opsForHash().entries(VIDEO_CACHE_PREFIX + videoId);
+
+        if (!cachedVideo.isEmpty()) {
+            // Convert cachedVideo to Map<String, Object>
+            Map<String, Object> stringKeyVideoMap = new HashMap<>();
+            cachedVideo.forEach((key, value) -> stringKeyVideoMap.put(String.valueOf(key), value));
+            return stringKeyVideoMap;
+        }
+
         Query query = new Query(Criteria.where("_id").is(videoId));
         DBObject dbObject = mongoTemplate.findOne(query, DBObject.class, "fs.files");
         if (dbObject != null) {
-            return dbObject.toMap();
+            Map<String, Object> videoDetails = dbObject.toMap();
+            // Save video information to Redis
+            redisTemplate.opsForHash().putAll(VIDEO_CACHE_PREFIX + videoId, videoDetails);
+            return videoDetails;
         }
+
         return null;
     }
 

src/main/resources/application.properties

@@ -20,3 +20,10 @@ [email protected]
 spring.mail.password=vkux umrv rtkd svsy
 spring.mail.properties.mail.smtp.auth=true
 spring.mail.properties.mail.smtp.starttls.enable=true
+
+
+
+# Redis
+spring.redis.host=localhost
+spring.redis.port=6379
+spring.redis.password=