These are classes used by Appgree to encapsulate and improve a Jedis client adding pipelining functionality, master-slave control, and a local in-memory cache to reduce the need for different threads to repeat reads. The classes can be used independently or nested.
The software stands under Apache 2 License and comes with NO WARRANTY
- RedisManager: singleton for Redis access.
- RedisRemotePipelinedProvider: Send commands in a pipeline (independent thread pool) drastically improving throughput.
- RedisCachedProvider: Store queried results in local cache so common access are already locally stored and need not be fetched.
- RedisSentinelPool: Redis sentinel for high availability
- Not all Jedis methods are implemented but classes can be easily extended
All providers require a RedisRemoteBaseProvider or RedisRemotePipelinedProvider inside that contains a Jedis client or JedisPool.
JedisPoolConfig config = new JedisPoolConfig();
// set pool configuration...
Set<String> sentinels = new HashSet<String>();
// add sentinels. Each sentinel is defined as "<host>:<port>", you can have as many as configured
// Check sentinels configuration
RedisSentinelPool sentinelPool = null;
if (sentinels != null && sentinels.size() > 0) {
sentinelPool = new RedisSentinelPool(config, sentinels, poolTimeout);
}
// Initializes Redis Pipelines
RedisPipelinedManager.staticInit(maxNPipelineChunk, maxNPipelinePerConn, pipelineMaxSyncTime, cachedErrorRetryDelay,
maxWaitTimeout, nThreadsCallback, maxBlockingPipelineTotal, traceDelay);
// create the RedisRemoteProvider, in this case, all are RedisRemotePipelinedProvider
RedisRemotePipelinedProvider pipelinedProvider = new RedisRemotePipelinedProvider();
RedisRemoteProvider noCachedProvider = new RedisRemoteProvider(cachedErrorRetryDelay);
// Lets initialize jedis pool
if (sentinelPool != null) {
sentinelPool.init(host, pipelinedProvider);
sentinelPool.init(host, noCachedProvider);
} else {
// Initializes independent providers
JedisPool pool = new JedisPool(config, host, port, poolTimeout);
pipelinedProvider.poolChanged(pool);
noCachedProvider.poolChanged(pool);
}
// init inner provider
((RedisPipelinedManager)RedisPipelinedManager.getInstance()).init(pipelinedProvider, 0);
// Initializes Redis Manager
RedisProvider cachedProvider = new RedisCachedProvider(RedisPipelinedManager.getInstance(), maxTtl, maxElements);
RedisManager.staticInit(cachedProvider);
CacheKey.staticInit(defaultTtl);via Maven
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent