11package com .redis .cluster ;
22
3+ import lombok .extern .slf4j .Slf4j ;
34import org .junit .Test ;
45import org .junit .runner .RunWith ;
56import org .springframework .beans .factory .annotation .Autowired ;
1314
1415import java .util .*;
1516
17+ @ Slf4j
1618@ RunWith (SpringRunner .class )
1719@ SpringBootTest
1820public class ReactiveRedisClusterTest {
@@ -30,22 +32,19 @@ public class ReactiveRedisClusterTest {
3032 public void opsValue () {
3133 ReactiveValueOperations <String , String > valueOps = reactiveRedisTemplate .opsForValue ();
3234 Set <String > cacheKeys = new HashSet <>();
33- Map <String , String > setDatas = new HashMap <>();
34- for (int i = 0 ; i < 10 ; i ++) {
35+ // async process
36+ log .info ("Step-1" );
37+ for (int i = 0 ; i < 5000 ; i ++) {
3538 String key = "value_" + i ;
3639 cacheKeys .add (key );
37- setDatas . put (key , String .valueOf (i ));
40+ valueOps . set (key , String .valueOf (i ));
3841 }
39- // previous key delete - sync process
40- redisTemplate .delete (cacheKeys );
41- 42- // async process
43- Mono <Boolean > results = valueOps .multiSet (setDatas );
44- StepVerifier .create (results ).expectNext (true ).verifyComplete ();
45- 42+ log .info ("Step-2" );
4643 Mono <List <String >> values = valueOps .multiGet (cacheKeys );
44+ log .info ("Step-3" );
4745 StepVerifier .create (values )
48- .expectNextMatches (x -> x .size () == 10 ).verifyComplete ();
46+ .expectNextMatches (x -> x .size () == 5000 ).verifyComplete ();
47+ log .info ("Step-4" );
4948 }
5049
5150 /**
0 commit comments