org.qbroker.net

Class JedisConnector

java.lang.Object

org.qbroker.net.JedisConnector

All Implemented Interfaces:

Connector

public class JedisConnector
extends java.lang.Object
implements Connector

JedisConnector connects to a Redis server and provides the following methods for Redis operations: set(), get(), zcadd, rpush, lpop, publish and list(). But it does not support synchronous subscribe.

This is NOT MT-Safe. Therefore, you need to use multiple instances to achieve your MT-Safty goal.

Author:

yannanlu@yahoo.com

Field Summary

Fields

Modifier and Type	Field and Description
static int	ACTION_COUNT
static int	ACTION_GET
static int	ACTION_KEYS
static int	ACTION_PARSE
static int	ACTION_QUERY
static int	ACTION_SET
static int	ACTION_SIZE
static int	ACTION_TIME
static int	ACTION_UPDATE
protected java.lang.String	hostname
protected boolean	isConnected
protected java.lang.String	password
protected int	port
static int	REDIS_HASH
static int	REDIS_LIST
static int	REDIS_NONE
static int	REDIS_SET
static int	REDIS_STRING
static int	REDIS_ZSET
protected redis.clients.jedis.Jedis	redisClient
protected int	timeout
static java.lang.String[]	Type
protected java.lang.String	uri
protected java.lang.String	username

Constructor Summary

Constructors

Constructor and Description
JedisConnector(java.util.Map props) Creates new JedisConnector

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	connect()
int	count(int type, java.lang.String key)
long	getSize(int id)
long	getTTL(java.lang.String key)
int	getType(java.lang.String key)
java.lang.String	getURI()
boolean	isConnected()
java.lang.String[]	list(java.lang.String keyPattern)
static void	main(java.lang.String[] args)
static java.lang.String[]	parse(java.lang.String request) parses the Redis request and returns args up to 5 of them
java.lang.Object	query(java.lang.String request)
java.lang.Object	query(java.lang.String[] args)
java.lang.String	reconnect() It reconnects and returns null or error message upon failure
java.lang.String	redisBlpop(int sec, java.lang.String key) removes the first item from the list of key and returns it or null
java.lang.String	redisBrpop(int sec, java.lang.String key) removes the last item from the list of key and returns it or null
java.lang.String	redisGet(java.lang.String key)
long	redisLpush(java.lang.String key, java.lang.String str) prefixes the string to the list of key and returns its position
long	redisPublish(java.lang.String chl, java.lang.String str) publishes the string to the channel and returns the number of subs
long	redisRpush(java.lang.String key, java.lang.String str) appends the string to the list of key and returns its position
java.lang.String	redisSet(java.lang.String key, java.lang.String value)
java.lang.Object	update(java.lang.String request)
java.lang.Object	update(java.lang.String[] args)

Methods inherited from class java.lang.Object

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

Field Detail

hostname

protected java.lang.String hostname

uri

protected java.lang.String uri

username

protected java.lang.String username

password

protected java.lang.String password

port

protected int port

timeout

protected int timeout

isConnected

protected boolean isConnected

REDIS_NONE

public static final int REDIS_NONE

See Also:

Constant Field Values

REDIS_STRING

public static final int REDIS_STRING

See Also:

Constant Field Values

REDIS_LIST

public static final int REDIS_LIST

See Also:

Constant Field Values

REDIS_HASH

public static final int REDIS_HASH

See Also:

Constant Field Values

REDIS_SET

public static final int REDIS_SET

See Also:

Constant Field Values

REDIS_ZSET

public static final int REDIS_ZSET

See Also:

Constant Field Values

ACTION_GET

public static final int ACTION_GET

See Also:

Constant Field Values

ACTION_SET

public static final int ACTION_SET

See Also:

Constant Field Values

ACTION_KEYS

public static final int ACTION_KEYS

See Also:

Constant Field Values

ACTION_COUNT

public static final int ACTION_COUNT

See Also:

Constant Field Values

ACTION_SIZE

public static final int ACTION_SIZE

See Also:

Constant Field Values

ACTION_TIME

public static final int ACTION_TIME

See Also:

Constant Field Values

ACTION_QUERY

public static final int ACTION_QUERY

See Also:

Constant Field Values

ACTION_UPDATE

public static final int ACTION_UPDATE

See Also:

Constant Field Values

ACTION_PARSE

public static final int ACTION_PARSE

See Also:

Constant Field Values

Type

public static final java.lang.String[] Type

redisClient

protected redis.clients.jedis.Jedis redisClient

Constructor Detail

JedisConnector

public JedisConnector(java.util.Map props)

Creates new JedisConnector

Method Detail

connect

protected void connect()
                throws redis.clients.jedis.exceptions.JedisException

Throws:

redis.clients.jedis.exceptions.JedisException

getURI

public java.lang.String getURI()

Specified by:

getURI in interface Connector

isConnected

public boolean isConnected()

Specified by:

isConnected in interface Connector

reconnect

public java.lang.String reconnect()

It reconnects and returns null or error message upon failure

Specified by:

reconnect in interface Connector

close

public void close()

Specified by:

close in interface Connector

redisPublish

public long redisPublish(java.lang.String chl,
                         java.lang.String str)

publishes the string to the channel and returns the number of subs

redisRpush

public long redisRpush(java.lang.String key,
                       java.lang.String str)

appends the string to the list of key and returns its position

redisLpush

public long redisLpush(java.lang.String key,
                       java.lang.String str)

prefixes the string to the list of key and returns its position

redisBrpop

public java.lang.String redisBrpop(int sec,
                                   java.lang.String key)

removes the last item from the list of key and returns it or null

redisBlpop

public java.lang.String redisBlpop(int sec,
                                   java.lang.String key)

removes the first item from the list of key and returns it or null

redisGet

public java.lang.String redisGet(java.lang.String key)

redisSet

public java.lang.String redisSet(java.lang.String key,
                                 java.lang.String value)

list

public java.lang.String[] list(java.lang.String keyPattern)

count

public int count(int type,
                 java.lang.String key)

getTTL

public long getTTL(java.lang.String key)

getType

public int getType(java.lang.String key)

getSize

public long getSize(int id)

update

public java.lang.Object update(java.lang.String request)

update

public java.lang.Object update(java.lang.String[] args)

query

public java.lang.Object query(java.lang.String request)

query

public java.lang.Object query(java.lang.String[] args)

parse

public static java.lang.String[] parse(java.lang.String request)

parses the Redis request and returns args up to 5 of them

main

public static void main(java.lang.String[] args)