DATAREDIS-1034 - Fix visibility issues in RedisTemplate.

Previously it was possible in multi-threaded environment to:
* get a `null` from `opsFor*` methods in RedisTemplate.
* fail with a `NullPointerException` when working with a not-`null` reference returned from `RedisTemplate.opsFor*` methods.

Introduced changes initialize the fields eagerly to avoid visibility issues when accessing them and add a `final` modifier to the `AbstractOperations#template` field.

Original pull request: #479.

Author: cac03

src/main/java/org/springframework/data/redis/core/AbstractOperations.java

@@ -44,6 +44,7 @@
  * @author Christoph Strobl
  * @author David Liu
  * @author Mark Paluch
+ * @author Denis Zavedeev
  */
 abstract class AbstractOperations<K, V> {
 
@@ -64,7 +65,7 @@ public final V doInRedis(RedisConnection connection) {
 		protected abstract byte[] inRedis(byte[] rawKey, RedisConnection connection);
 	}
 
-	RedisTemplate<K, V> template;
+	final RedisTemplate<K, V> template;
 
 	AbstractOperations(RedisTemplate<K, V> template) {
 		this.template = template;

src/main/java/org/springframework/data/redis/core/RedisTemplate.java

@@ -79,6 +79,7 @@
  * @author Ninad Divadkar
  * @author Anqing Shao
  * @author Mark Paluch
+ * @author Denis Zavedeev
  * @param <K> the Redis key type against which the template works (usually a String)
  * @param <V> the Redis value type against which the template works
  * @see StringRedisTemplate
@@ -100,13 +101,13 @@ public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperation
 
 	private @Nullable ScriptExecutor<K> scriptExecutor;
 
-	// cache singleton objects (where possible)
-	private @Nullable ValueOperations<K, V> valueOps;
-	private @Nullable ListOperations<K, V> listOps;
-	private @Nullable SetOperations<K, V> setOps;
-	private @Nullable ZSetOperations<K, V> zSetOps;
-	private @Nullable GeoOperations<K, V> geoOps;
-	private @Nullable HyperLogLogOperations<K, V> hllOps;
+	private final ValueOperations<K, V> valueOps = new DefaultValueOperations<>(this);
+	private final ListOperations<K, V> listOps = new DefaultListOperations<>(this);
+	private final SetOperations<K, V> setOps = new DefaultSetOperations<>(this);
+	private final ZSetOperations<K, V> zSetOps = new DefaultZSetOperations<>(this);
+	private final GeoOperations<K, V> geoOps = new DefaultGeoOperations<>(this);
+	private final HyperLogLogOperations<K, V> hllOps = new DefaultHyperLogLogOperations<>(this);
+	private final ClusterOperations<K, V> clusterOps = new DefaultClusterOperations<>(this);
 
 	/**
 	 * Constructs a new <code>RedisTemplate</code> instance.
@@ -1200,7 +1201,7 @@ public void slaveOfNoOne() {
 	 */
 	@Override
 	public ClusterOperations<K, V> opsForCluster() {
-		return new DefaultClusterOperations<>(this);
+		return clusterOps;
 	}
 
 	/*
@@ -1209,10 +1210,6 @@ public ClusterOperations<K, V> opsForCluster() {
 	 */
 	@Override
 	public GeoOperations<K, V> opsForGeo() {
-
-		if (geoOps == null) {
-			geoOps = new DefaultGeoOperations<>(this);
-		}
 		return geoOps;
 	}
 
@@ -1249,10 +1246,6 @@ public <HK, HV> HashOperations<K, HK, HV> opsForHash() {
 	 */
 	@Override
 	public HyperLogLogOperations<K, V> opsForHyperLogLog() {
-
-		if (hllOps == null) {
-			hllOps = new DefaultHyperLogLogOperations<>(this);
-		}
 		return hllOps;
 	}
 
@@ -1262,10 +1255,6 @@ public HyperLogLogOperations<K, V> opsForHyperLogLog() {
 	 */
 	@Override
 	public ListOperations<K, V> opsForList() {
-
-		if (listOps == null) {
-			listOps = new DefaultListOperations<>(this);
-		}
 		return listOps;
 	}
 
@@ -1293,10 +1282,6 @@ public BoundSetOperations<K, V> boundSetOps(K key) {
 	 */
 	@Override
 	public SetOperations<K, V> opsForSet() {
-
-		if (setOps == null) {
-			setOps = new DefaultSetOperations<>(this);
-		}
 		return setOps;
 	}
 
@@ -1315,10 +1300,6 @@ public BoundValueOperations<K, V> boundValueOps(K key) {
 	 */
 	@Override
 	public ValueOperations<K, V> opsForValue() {
-
-		if (valueOps == null) {
-			valueOps = new DefaultValueOperations<>(this);
-		}
 		return valueOps;
 	}
 
@@ -1337,10 +1318,6 @@ public BoundZSetOperations<K, V> boundZSetOps(K key) {
 	 */
 	@Override
 	public ZSetOperations<K, V> opsForZSet() {
-
-		if (zSetOps == null) {
-			zSetOps = new DefaultZSetOperations<>(this);
-		}
 		return zSetOps;
 	}