BAEL-951 Self-Healing Services with Spring Cloud - C2

spring-cloud/spring-cloud-bootstrap/application-config/rating-service.properties

@@ -16,8 +16,5 @@ logging.level.org.springframework.security=debug
 spring.redis.host=localhost
 spring.redis.port=6379
 
-cache.redis.hostName=localhost
-cache.redis.port=6379
-
 spring.sleuth.sampler.percentage=1.0
 spring.sleuth.web.skipPattern=(^cleanup.*)

spring-cloud/spring-cloud-bootstrap/svc-rating/src/main/java/com/baeldung/spring/cloud/bootstrap/svcrating/CacheConfig.java

@@ -2,13 +2,9 @@ package com.baeldung.spring.cloud.bootstrap.svcrating;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
 import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
 
-@Configuration
-@EnableConfigurationProperties({CacheProperties.class})
 public class CacheConfig {
 
     @Autowired
@@ -17,8 +13,6 @@ public class CacheConfig {
     @Bean(name="cacheConnectionFactory")
     @Qualifier("cacheJedisConnectionFactory")
     JedisConnectionFactory cacheConnectionFactory() {
-        System.out.println(">>>>>>>>>>>>>>>>>>>>>Qualified Jedis Conn.Name.."+cacheProperties.hostName);
-        System.out.println(">>>>>>>>>>>>>>>>>>>>>Qualified Jedis Conn.Port.."+cacheProperties.port);
         JedisConnectionFactory factory = new JedisConnectionFactory();
         factory.setHostName(cacheProperties.hostName);
         factory.setPort(cacheProperties.port);

spring-cloud/spring-cloud-bootstrap/svc-rating/src/main/java/com/baeldung/spring/cloud/bootstrap/svcrating/CacheProperties.java

@@ -1,8 +1,5 @@
 package com.baeldung.spring.cloud.bootstrap.svcrating;
 
-import org.springframework.boot.context.properties.ConfigurationProperties;
-
-@ConfigurationProperties(prefix="cache.redis")
 public class CacheProperties {
 public String hostName;
 public int port;

spring-cloud/spring-cloud-bootstrap/svc-rating/src/main/java/com/baeldung/spring/cloud/bootstrap/svcrating/RatingServiceApplication.java

@@ -10,16 +10,23 @@ import org.springframework.cloud.sleuth.metric.SpanMetricReporter;
 import org.springframework.cloud.sleuth.zipkin.HttpZipkinSpanReporter;
 import org.springframework.cloud.sleuth.zipkin.ZipkinProperties;
 import org.springframework.cloud.sleuth.zipkin.ZipkinSpanReporter;
+import org.springframework.context.annotation.AdviceMode;
 import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Primary;
+import org.springframework.core.Ordered;
+import org.springframework.core.annotation.Order;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
 
 import com.netflix.appinfo.InstanceInfo;
 import com.netflix.discovery.EurekaClient;
+import com.netflix.hystrix.contrib.javanica.aop.aspectj.HystrixCommandAspect;
 
 import zipkin.Span;
 
 @SpringBootApplication
 @EnableEurekaClient
 @EnableHystrix
+@EnableTransactionManagement(order=Ordered.LOWEST_PRECEDENCE, mode=AdviceMode.ASPECTJ)
 public class RatingServiceApplication {
     @Autowired
     private EurekaClient eurekaClient;
@@ -52,4 +59,11 @@ public class RatingServiceApplication {
             }
         };
     }
+    
+    @Bean
+    @Primary
+    @Order(value=Ordered.HIGHEST_PRECEDENCE)
+    public HystrixCommandAspect hystrixAspect() {
+      return new HystrixCommandAspect();
+    }
 }

spring-cloud/spring-cloud-bootstrap/svc-rating/src/main/java/com/baeldung/spring/cloud/bootstrap/svcrating/SecurityConfig.java

@@ -24,11 +24,10 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter {
         .authorizeRequests()
             .regexMatchers("^/ratings\\?bookId.*$").authenticated()
             .antMatchers(HttpMethod.POST,"/ratings").authenticated()
-            .antMatchers(HttpMethod.GET,"/ratings/**").authenticated()
             .antMatchers(HttpMethod.PATCH,"/ratings/*").hasRole("ADMIN")
             .antMatchers(HttpMethod.DELETE,"/ratings/*").hasRole("ADMIN")
             .antMatchers(HttpMethod.GET,"/ratings").hasRole("ADMIN")
-            .antMatchers(HttpMethod.GET,"/hystrix*").permitAll()
+            .antMatchers(HttpMethod.GET,"/hystrix").authenticated()
             .anyRequest().authenticated()
             .and()
          .httpBasic().and()   

spring-cloud/spring-cloud-bootstrap/svc-rating/src/main/java/com/baeldung/spring/cloud/bootstrap/svcrating/rating/Rating.java

@@ -83,23 +83,4 @@ public class Rating  implements Serializable{
         this.cachedTS = cachedTS;
     }
 
-    @Override
-    public String toString() {
-        return "Rating [" + id + "," + bookId + "," + stars + "," + cachedTS + "]";
-    }
-    
-    public static Rating fromString(String ratingAsStr){
-        
-        if(ratingAsStr == null || ratingAsStr.isEmpty())
-            return null;
-        String[] attributeVals=ratingAsStr.substring(8,ratingAsStr.length()-1).split("[,]");
-        
-        Rating rating=new Rating();
-        rating.setId(Long.valueOf(attributeVals[0]));
-        rating.setBookId(Long.valueOf(attributeVals[1]));
-        rating.setStars(Integer.valueOf(attributeVals[2]));
-        rating.setCachedTS(Long.valueOf(attributeVals[3]));
-        
-        return rating;
-    }
 }

spring-cloud/spring-cloud-bootstrap/svc-rating/src/main/java/com/baeldung/spring/cloud/bootstrap/svcrating/rating/RatingCacheRepositoryImpl.java

@@ -1,68 +1,109 @@
 package com.baeldung.spring.cloud.bootstrap.svcrating.rating;
 
+import java.io.IOException;
 import java.util.List;
 import java.util.stream.Collectors;
 
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
 import org.springframework.data.redis.core.SetOperations;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.data.redis.core.ValueOperations;
 import org.springframework.stereotype.Repository;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
 @Repository
 public class RatingCacheRepositoryImpl implements InitializingBean, RatingCacheRepository {
 
-   
     @Autowired
-    @Qualifier("cacheJedisConnectionFactory")
     private JedisConnectionFactory cacheConnectionFactory;
 
     private StringRedisTemplate redisTemplate;
     private ValueOperations<String, String> valueOps;
     private SetOperations<String, String> setOps;
 
+    private ObjectMapper jsonMapper;
 
     public List<Rating> findCachedRatingsByBookId(Long bookId) {
         return setOps.members("book-" + bookId)
             .stream()
-            .map(rtId -> Rating.fromString(valueOps.get(rtId)))
+            .map(rtId -> {
-            .map(rt -> {
+                try {
+                    Rating rt = jsonMapper.readValue(valueOps.get(rtId), Rating.class);
                     rt.setFromCache(true);
                     return rt;
+                } catch (IOException ex) {
+                    return null;
+                }
             })
             .collect(Collectors.toList());
     }
 
     public Rating findCachedRatingById(Long ratingId) {
-        return Rating.fromString(valueOps.get("rating-" + ratingId));
+
+        try {
+            return jsonMapper.readValue(valueOps.get("rating-" + ratingId), Rating.class);
+        } catch (IOException e) {
+            return null;
+        }
+
     }
 
     public List<Rating> findAllCachedRatings() {
-        return redisTemplate.keys("rating*")
+        List<Rating> ratings = null;
+
+        ratings = redisTemplate.keys("rating*")
             .stream()
-            .map(rtId -> Rating.fromString(valueOps.get(rtId)))
+            .map(rtId -> {
+                try {
+
+                    return jsonMapper.readValue(valueOps.get(rtId), Rating.class);
+
+                } catch (IOException e) {
+                    return null;
+                }
+            })
             .collect(Collectors.toList());
+
+        return ratings;
     }
 
     public boolean createRating(Rating persisted) {
-        valueOps.set("rating-"+persisted.getId(), persisted.toString());
+        try {
+            valueOps.set("rating-" + persisted.getId(), jsonMapper.writeValueAsString(persisted));
             setOps.add("book-" + persisted.getBookId(), "rating-" + persisted.getId());
             return true;
+        } catch (JsonProcessingException ex) {
+            return false;
+        }
     }
 
     public boolean updateRating(Rating persisted) {
-        valueOps.set("rating-"+persisted.getId(), persisted.toString());
+        try {
+            valueOps.set("rating-" + persisted.getId(), jsonMapper.writeValueAsString(persisted));
             return true;
+        } catch (JsonProcessingException e) {
+            e.printStackTrace();
+        }
+        return false;
     }
 
     public boolean deleteRating(Long ratingId) {
-        Rating toDel=Rating.fromString(valueOps.get("rating-"+ratingId));
+        Rating toDel;
+        try {
+
+            toDel = jsonMapper.readValue(valueOps.get("rating-" + ratingId), Rating.class);
             setOps.remove("book-" + toDel.getBookId(), "rating-" + ratingId);
             redisTemplate.delete("rating-" + ratingId);
             return true;
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return false;
     }
 
     @Override
@@ -73,5 +114,7 @@ public class RatingCacheRepositoryImpl implements InitializingBean, RatingCacheR
         this.valueOps = redisTemplate.opsForValue();
         this.setOps = redisTemplate.opsForSet();
 
+        jsonMapper = new ObjectMapper();
+        jsonMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
     }
 }

spring-cloud/spring-cloud-bootstrap/svc-rating/src/main/java/com/baeldung/spring/cloud/bootstrap/svcrating/rating/RatingService.java

@@ -1,6 +1,5 @@
 package com.baeldung.spring.cloud.bootstrap.svcrating.rating;
 
-import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
@@ -23,25 +22,15 @@ public class RatingService{
     @Autowired
     private RatingCacheRepository cacheRepository;
 
-
     @HystrixCommand(commandKey = "ratingsByBookIdFromDB", fallbackMethod = "findCachedRatingsByBookId")
     public List<Rating> findRatingsByBookId(Long bookId) {
-        if(bookId==2)
-            throw new IllegalArgumentException("BookID 2 redirects to cache");
-
         return ratingRepository.findRatingsByBookId(bookId);
     }
 
-    @HystrixCommand(commandKey="ratingsByBookIdFromCache",fallbackMethod="defaultRatingsByBookId")
     public List<Rating> findCachedRatingsByBookId(Long bookId) {
         return cacheRepository.findCachedRatingsByBookId(bookId);
     }
 
-    public List<Rating>  defaultRatingsByBookId(Long bookId){
-        return Collections.emptyList();
-    }
-
-
     @HystrixCommand(commandKey = "ratingsFromDB", fallbackMethod = "findAllCachedRatings")
     public List<Rating> findAllRatings() {
         return ratingRepository.findAll();