Added support for Spring Session Redis

Minor refactoring
Added k8s config (WIP)

Author: NLxAROSA

deploy-on-k8s.yaml

@@ -0,0 +1,37 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: redisbank-deployment
+spec:
+  selector:
+    matchLabels:
+      app: redisbank
+  replicas: 1
+  template:
+    metadata:
+      labels:
+        app: redisbank
+    spec:
+      containers:
+      - name: redisbank
+        image: <yourimageurl>
+        imagePullPolicy: Always
+        ports:
+        - name: redisbank
+          containerPort: 8080
+        env:
+        - name: SPRING_REDIS_HOST
+          valueFrom:
+            secretKeyRef:
+              name: redb-redis-enterprise-database
+              key: service_name
+        - name: SPRING_REDIS_PORT
+          valueFrom:
+            secretKeyRef:
+              name: redb-redis-enterprise-database
+              key: port
+        - name: SPRING_REDIS_PASSWORD
+          valueFrom:
+            secretKeyRef:
+              name: redb-redis-enterprise-database
+              key: password

pom.xml

@@ -28,6 +28,10 @@
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-data-redis-reactive</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.session</groupId>
+			<artifactId>spring-session-data-redis</artifactId>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-websocket</artifactId>

src/main/java/com/redislabs/demos/redisbank/RedisTimeSeriesConfiguration.java

@@ -1,5 +1,7 @@
 package com.redislabs.demos.redisbank;
 
+import com.redislabs.demos.redisbank.timeseries.TimeSeriesCommands;
+
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -14,4 +16,9 @@ RedisCommandFactory redisCommandFactory(RedisClient redis)   {
         return new RedisCommandFactory(redis.connect());
     }
 
+    @Bean
+    TimeSeriesCommands timeSeriesCommands(RedisCommandFactory rcf)  {
+        return rcf.getCommands(TimeSeriesCommands.class);
+    }
+
 }

src/main/java/com/redislabs/demos/redisbank/transactions/BankTransactionGenerator.java

@@ -27,7 +27,6 @@
 import org.springframework.stereotype.Component;
 
 import io.lettuce.core.RedisCommandExecutionException;
-import io.lettuce.core.dynamic.RedisCommandFactory;
 
 @Component
 public class BankTransactionGenerator {
@@ -51,10 +50,10 @@ public class BankTransactionGenerator {
     private final TimeSeriesCommands tsc;
 
     public BankTransactionGenerator(StringRedisTemplate redis, StatefulRediSearchConnection<String, String> connection,
-            RedisCommandFactory rcf) throws NoSuchAlgorithmException, UnsupportedEncodingException {
+            TimeSeriesCommands tsc) throws NoSuchAlgorithmException, UnsupportedEncodingException {
         this.redis = redis;
         this.connection = connection;
-        this.tsc = rcf.getCommands(TimeSeriesCommands.class);
+        this.tsc = tsc;
         transactionSources = SerializationUtil.loadObjectList(TransactionSource.class, "/transaction_sources.csv");
         random = SecureRandom.getInstance("SHA1PRNG");
         random.setSeed("lars".getBytes("UTF-8")); // Prime the RNG so it always generates the same pseudorandom set

src/main/java/com/redislabs/demos/redisbank/transactions/TransactionOverviewController.java

@@ -6,7 +6,6 @@
 
 import com.redislabs.demos.redisbank.Config;
 import com.redislabs.demos.redisbank.Config.StompConfig;
-import com.redislabs.demos.redisbank.Utilities;
 import com.redislabs.demos.redisbank.timeseries.TimeSeriesCommands;
 import com.redislabs.lettusearch.RediSearchCommands;
 import com.redislabs.lettusearch.SearchOptions;
@@ -25,8 +24,6 @@
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
-import io.lettuce.core.dynamic.RedisCommandFactory;
-
 @RestController
 @RequestMapping(path = "/api")
 @CrossOrigin
@@ -45,10 +42,10 @@ public class TransactionOverviewController {
     private final TimeSeriesCommands tsc;
 
     public TransactionOverviewController(Config config, StatefulRediSearchConnection<String, String> srsc,
-            RedisCommandFactory rcf, StringRedisTemplate redis) {
+            TimeSeriesCommands tsc, StringRedisTemplate redis) {
         this.config = config;
         this.srsc = srsc;
-        this.tsc = rcf.getCommands(TimeSeriesCommands.class);
+        this.tsc = tsc;
         this.redis = redis;
     }
 
@@ -61,7 +58,6 @@ public StompConfig stompConfig() {
     public Balance[] balance() {
         Map<String, String> tsValues = tsc.range(BALANCE_TS, System.currentTimeMillis() - (1000 * 60 * 60 * 24 * 7),
                 System.currentTimeMillis());
-
         Balance[] balanceTs = new Balance[tsValues.size()];
         int i = 0;
 
@@ -77,9 +73,7 @@ public Balance[] balance() {
 
     @GetMapping("/biggestspenders")
     public BiggestSpenders biggestSpenders() {
-
         Set<TypedTuple<String>> range = redis.opsForZSet().rangeByScoreWithScores(SORTED_SET_KEY, 0, Double.MAX_VALUE);
-
         if (range.size() > 0) {
             BiggestSpenders biggestSpenders = new BiggestSpenders(range.size());
             int i = 0;

src/main/resources/application.properties

@@ -17,4 +17,6 @@ spring.redis.port=6379
 stomp.endpoint=/websocket
 stomp.destinationPrefix=/topic
 stomp.transactionsTopic=/topic/transactions
-management.endpoints.web.exposure.include=env
+management.endpoints.web.exposure.include=env
+spring.session.store-type=redis
+session.redis.namespace={lars:}spring:session