org.qbroker.net

Class RedisConnector

java.lang.Object

org.qbroker.net.RedisConnector

All Implemented Interfaces:

Connector

public class RedisConnector
extends java.lang.Object
implements Connector

RedisConnector connects to a Redis server and provides the following methods for Redis operations: rpush, lpop, blpop, publish, subscribe, unsubscribe and nextMessage.

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	CONNREFUSED
static int	CONNTIMEOUT
protected java.lang.String	host
static int	NOTCONNECTED
protected java.lang.String	password
protected int	port
static int	PROTOCOLERROR
static int	READFAILED
static int	REDIS_BLPOP
static int	REDIS_LPOP
static int	REDIS_PUBLISH
static int	REDIS_RPUSH
static int	REDIS_SUBSCRIBE
static int	REDIS_UNSUBSCRIBE
static int	REDIS_ZADD
static int	REDISERROR
static int	REDISTIMEOUT
static int	SERVERERROR
static int	SOCKERROR
protected int	timeout
protected java.lang.String	uri
protected java.lang.String	username
static int	WRITEFAILED

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
long	blpop(java.lang.String key, int sec, java.io.OutputStream bos)
void	close()
protected void	connect()
java.lang.String	getURI()
boolean	isConnected()
long	lpop(java.lang.String key, java.io.OutputStream bos)
static void	main(java.lang.String[] args)
java.lang.String	nextMessage(int sec, java.io.OutputStream bos)
long	publish(java.lang.String key, java.lang.String data)
java.lang.String	reconnect() It reconnects and returns null or error message upon failure
static byte[]	redisCommand(int id, java.lang.String key, java.lang.String data)
static byte[]	redisCommand(int id, java.lang.String key, java.lang.String data, double d)
static byte[]	redisCommand(int id, java.lang.String key, java.lang.String data, int n)
long	rpush(java.lang.String key, java.lang.String data)
int	subscribe(java.lang.String key)
int	unsubscribe(java.lang.String key)

Methods inherited from class java.lang.Object

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

Field Detail

username

protected java.lang.String username

password

protected java.lang.String password

uri

protected java.lang.String uri

host

protected java.lang.String host

port

protected int port

timeout

protected int timeout

REDISTIMEOUT

public static final int REDISTIMEOUT

See Also:

Constant Field Values

PROTOCOLERROR

public static final int PROTOCOLERROR

See Also:

Constant Field Values

NOTCONNECTED

public static final int NOTCONNECTED

See Also:

Constant Field Values

REDISERROR

public static final int REDISERROR

See Also:

Constant Field Values

SOCKERROR

public static final int SOCKERROR

See Also:

Constant Field Values

SERVERERROR

public static final int SERVERERROR

See Also:

Constant Field Values

READFAILED

public static final int READFAILED

See Also:

Constant Field Values

WRITEFAILED

public static final int WRITEFAILED

See Also:

Constant Field Values

CONNTIMEOUT

public static final int CONNTIMEOUT

See Also:

Constant Field Values

CONNREFUSED

public static final int CONNREFUSED

See Also:

Constant Field Values

REDIS_RPUSH

public static final int REDIS_RPUSH

See Also:

Constant Field Values

REDIS_PUBLISH

public static final int REDIS_PUBLISH

See Also:

Constant Field Values

REDIS_ZADD

public static final int REDIS_ZADD

See Also:

Constant Field Values

REDIS_LPOP

public static final int REDIS_LPOP

See Also:

Constant Field Values

REDIS_BLPOP

public static final int REDIS_BLPOP

See Also:

Constant Field Values

REDIS_SUBSCRIBE

public static final int REDIS_SUBSCRIBE

See Also:

Constant Field Values

REDIS_UNSUBSCRIBE

public static final int REDIS_UNSUBSCRIBE

See Also:

Constant Field Values

Constructor Detail

RedisConnector

public RedisConnector(java.util.Map props)

Creates new RedisConnector

Method Detail

lpop

public long lpop(java.lang.String key,
                 java.io.OutputStream bos)

blpop

public long blpop(java.lang.String key,
                  int sec,
                  java.io.OutputStream bos)

rpush

public long rpush(java.lang.String key,
                  java.lang.String data)

publish

public long publish(java.lang.String key,
                    java.lang.String data)

subscribe

public int subscribe(java.lang.String key)

unsubscribe

public int unsubscribe(java.lang.String key)

nextMessage

public java.lang.String nextMessage(int sec,
                                    java.io.OutputStream bos)
                             throws java.io.IOException

Throws:

java.io.IOException

redisCommand

public static byte[] redisCommand(int id,
                                  java.lang.String key,
                                  java.lang.String data,
                                  int n)

redisCommand

public static byte[] redisCommand(int id,
                                  java.lang.String key,
                                  java.lang.String data,
                                  double d)

redisCommand

public static byte[] redisCommand(int id,
                                  java.lang.String key,
                                  java.lang.String data)

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

connect

protected void connect()
                throws java.io.IOException

Throws:

java.io.IOException

close

public void close()

Specified by:

close in interface Connector

main

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