org.jredis.bench

Class JRedisBenchmark

java.lang.Object

org.jredis.bench.JRedisBenchmark

Direct Known Subclasses:

JRedisClientBenchmark

public abstract class JRedisBenchmark
extends java.lang.Object

Runs a few benchmarks for the SocketConnection, using a concurrent set of workers, each with its own unique connection to the Redis server.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JRedisBenchmark.Benchmarker
class	JRedisBenchmark.BenchmarkWorker Abstract base class for all benchmark workers.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) byte[]	fixedbytes
static java.lang.String	password password used to AUTH with redis select -- password is: jredis
protected boolean	quitOnRunEnd
(package private) static java.util.Random	random
(package private) static java.util.List<java.lang.String>	stringList

Constructor Summary

Constructors

Constructor and Description
JRedisBenchmark()

Method Summary

Modifier and Type	Method and Description
protected abstract java.lang.Class<? extends JRedis>	getImplementationClass()
protected abstract JRedis	newConnection(java.lang.String host, int port, int db, java.lang.String password) Define this method to test a specific JRedis implementation.
JRedisBenchmark.BenchmarkWorker	newDbsizeWorker(java.lang.String host, int port, int db) does the DBSIZE
JRedisBenchmark.BenchmarkWorker	newDecrbyWorker(java.lang.String host, int port, int db) does the DECR
JRedisBenchmark.BenchmarkWorker	newDecrWorker(java.lang.String host, int port, int db) does the DECR
JRedisBenchmark.BenchmarkWorker	newGetWorker(java.lang.String host, int port, int db) does the GET
JRedisBenchmark.BenchmarkWorker	newIncrbyWorker(java.lang.String host, int port, int db) does the INCRBY
JRedisBenchmark.BenchmarkWorker	newIncrWorker(java.lang.String host, int port, int db) does the INCR
JRedisBenchmark.BenchmarkWorker	newLLenWorker(java.lang.String host, int port, int db) does the LLEN
JRedisBenchmark.BenchmarkWorker	newLPopWorker(java.lang.String host, int port, int db) does the LPOP
JRedisBenchmark.BenchmarkWorker	newLPushWorker(java.lang.String host, int port, int db) does the LPUSH
JRedisBenchmark.BenchmarkWorker	newPingWorker(java.lang.String host, int port, int db) does the PING
JRedisBenchmark.BenchmarkWorker	newRPopWorker(java.lang.String host, int port, int db) does the RPOP
JRedisBenchmark.BenchmarkWorker	newRPushWorker(java.lang.String host, int port, int db) does the RPUSH
JRedisBenchmark.BenchmarkWorker	newSaddWorker(java.lang.String host, int port, int db) does the SADD
JRedisBenchmark.BenchmarkWorker	newScardWorker(java.lang.String host, int port, int db) does the SCARD
JRedisBenchmark.BenchmarkWorker	newSetnxWorker(java.lang.String host, int port, int db) does the SETNX
JRedisBenchmark.BenchmarkWorker	newSetWorker(java.lang.String host, int port, int db) does the SET
JRedisBenchmark.BenchmarkWorker	newSmembersWorker(java.lang.String host, int port, int db) does the SMEMBERS
JRedisBenchmark.BenchmarkWorker	newSremWorker(java.lang.String host, int port, int db) does the SREM
protected void	quitOnRunEnd(boolean flag)
protected void	runBenchmarks(java.lang.String host, int port, int threadCnt, int reqCnt, int size, int db) Runs a set of command primitives test runs using concurrent clients.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

password

public static final java.lang.String password

password used to AUTH with redis select -- password is: jredis

See Also:

Constant Field Values

random

static final java.util.Random random

fixedbytes

byte[] fixedbytes

stringList

static java.util.List<java.lang.String> stringList

quitOnRunEnd

protected boolean quitOnRunEnd

Constructor Detail

JRedisBenchmark

public JRedisBenchmark()

Method Detail

quitOnRunEnd

protected void quitOnRunEnd(boolean flag)

Parameters:

b -

getImplementationClass

protected abstract java.lang.Class<? extends JRedis> getImplementationClass()

newConnection

protected abstract JRedis newConnection(java.lang.String host,
                                        int port,
                                        int db,
                                        java.lang.String password)
                                 throws ClientRuntimeException

Define this method to test a specific JRedis implementation.

Parameters:

host -

port -

Returns:

Throws:

ClientRuntimeException

runBenchmarks

protected final void runBenchmarks(java.lang.String host,
                                   int port,
                                   int threadCnt,
                                   int reqCnt,
                                   int size,
                                   int db)

Runs a set of command primitives test runs using concurrent clients. [TODO: add all commands - this is a sampling of a few.]

Be advised that this will FLUSH the db specified. Defaults to database at index 13: i.e. jredis.select(13).flushdb(). This bench will use AUTH to make sure you do not accidentally destroy important data when runnign the benchmark. (If you don't have a password on your db, it can't be that important, right?)

Further note that this will use the password jredis so either make sure the redis.conf requirepass is set appropriately or simply comment it out.

Parameters:

host -

port -

threadCnt -

reqCnt -

size -

db -

newPingWorker

public final JRedisBenchmark.BenchmarkWorker newPingWorker(java.lang.String host,
                                                           int port,
                                                           int db)

does the PING

newDbsizeWorker

public final JRedisBenchmark.BenchmarkWorker newDbsizeWorker(java.lang.String host,
                                                             int port,
                                                             int db)

does the DBSIZE

newSaddWorker

public final JRedisBenchmark.BenchmarkWorker newSaddWorker(java.lang.String host,
                                                           int port,
                                                           int db)

does the SADD

newSremWorker

public final JRedisBenchmark.BenchmarkWorker newSremWorker(java.lang.String host,
                                                           int port,
                                                           int db)

does the SREM

newScardWorker

public final JRedisBenchmark.BenchmarkWorker newScardWorker(java.lang.String host,
                                                            int port,
                                                            int db)

does the SCARD

newLLenWorker

public final JRedisBenchmark.BenchmarkWorker newLLenWorker(java.lang.String host,
                                                           int port,
                                                           int db)

does the LLEN

newLPopWorker

public final JRedisBenchmark.BenchmarkWorker newLPopWorker(java.lang.String host,
                                                           int port,
                                                           int db)

does the LPOP

newRPopWorker

public final JRedisBenchmark.BenchmarkWorker newRPopWorker(java.lang.String host,
                                                           int port,
                                                           int db)

does the RPOP

newLPushWorker

public final JRedisBenchmark.BenchmarkWorker newLPushWorker(java.lang.String host,
                                                            int port,
                                                            int db)

does the LPUSH

newRPushWorker

public final JRedisBenchmark.BenchmarkWorker newRPushWorker(java.lang.String host,
                                                            int port,
                                                            int db)

does the RPUSH

newIncrWorker

public final JRedisBenchmark.BenchmarkWorker newIncrWorker(java.lang.String host,
                                                           int port,
                                                           int db)

does the INCR

newDecrWorker

public final JRedisBenchmark.BenchmarkWorker newDecrWorker(java.lang.String host,
                                                           int port,
                                                           int db)

does the DECR

newIncrbyWorker

public final JRedisBenchmark.BenchmarkWorker newIncrbyWorker(java.lang.String host,
                                                             int port,
                                                             int db)

does the INCRBY

newDecrbyWorker

public final JRedisBenchmark.BenchmarkWorker newDecrbyWorker(java.lang.String host,
                                                             int port,
                                                             int db)

does the DECR

newSetWorker

public final JRedisBenchmark.BenchmarkWorker newSetWorker(java.lang.String host,
                                                          int port,
                                                          int db)

does the SET

newSetnxWorker

public final JRedisBenchmark.BenchmarkWorker newSetnxWorker(java.lang.String host,
                                                            int port,
                                                            int db)

does the SETNX

newGetWorker

public final JRedisBenchmark.BenchmarkWorker newGetWorker(java.lang.String host,
                                                          int port,
                                                          int db)

does the GET

newSmembersWorker

public final JRedisBenchmark.BenchmarkWorker newSmembersWorker(java.lang.String host,
                                                               int port,
                                                               int db)

does the SMEMBERS