Redis PipeLine example

Redis PipeLine example

List<Object> result = null;			

RedisConnectionFactory conFactory = stringRedisTemplate.getConnectionFactory();

RedisConnection con = RedisConnectionUtils.bindConnection(conFactory);

try {

	con.openPipeline();

	try {

		Iterator<String> it = usersId.iterator();

		while ( it.hasNext() ) {

			String userId = (String)it.next();					

			stringRedisTemplate.boundHashOps(QUEUE_NAME_USER_STATUS).get(userId);

			stringRedisTemplate.boundHashOps(QUEUE_NAME_USER_MYSTATUS).get(userId);

			stringRedisTemplate.boundHashOps(QUEUE_NAME_USER_LOGINDEVICE).get(userId);				

			stringRedisTemplate.boundHashOps(QUEUE_NAME_USER_IPLISTENSS).get(userId);

		}	

	} finally {

		result = con.closePipeline();

	}

} finally {				

    RedisConnectionUtils.unbindConnection(conFactory);

}	

//출처 :