redis

Class RedisProtocol

java.lang.Object

redis.RedisProtocol

public class RedisProtocol
extends java.lang.Object

Implements the Redis Universal Protocol. Send a command, receive a command, send a reply and receive a reply.

Field Summary

Fields

Modifier and Type	Field and Description
static char	CR
private java.io.BufferedInputStream	is
static char	LF
private java.io.OutputStream	os
private static char	ZERO

Constructor Summary

Constructors

Constructor and Description
RedisProtocol(java.io.BufferedInputStream is, java.io.OutputStream os) Create a new RedisProtocol using provided input and output streams.
RedisProtocol(java.net.Socket socket) Create a new RedisProtocol from a socket connection.

Method Summary

Modifier and Type	Method and Description
void	close() Close the input and output streams.
static byte[]	readBytes(java.io.InputStream is) Read fixed size field from the stream.
static long	readLong(java.io.InputStream is) Read a signed ascii integer from the input stream.
static Reply	receive(java.io.InputStream is) Read a Reply from an input stream.
Reply	receiveAsync() Wait for a reply on the input stream.
void	sendAsync(Command command) Send a command over the wire, do not wait for a reponse.
static byte[]	toBytes(java.lang.Number length)

Methods inherited from class java.lang.Object

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

Field Detail

CR

public static final char CR

See Also:

Constant Field Values

LF

public static final char LF

See Also:

Constant Field Values

ZERO

private static final char ZERO

See Also:

Constant Field Values

is

private final java.io.BufferedInputStream is

os

private final java.io.OutputStream os

Constructor Detail

RedisProtocol

public RedisProtocol(java.net.Socket socket)
              throws java.io.IOException

Create a new RedisProtocol from a socket connection.

Parameters:

socket -

Throws:

java.io.IOException

RedisProtocol

public RedisProtocol(java.io.BufferedInputStream is,
                     java.io.OutputStream os)

Create a new RedisProtocol using provided input and output streams.

Parameters:

is - a buffered input stream is required

os - a buffered input stream is required

Throws:

java.io.IOException

Method Detail

readBytes

public static byte[] readBytes(java.io.InputStream is)
                        throws java.io.IOException

Read fixed size field from the stream.

Parameters:

is -

Returns:

Throws:

java.io.IOException

readLong

public static long readLong(java.io.InputStream is)
                     throws java.io.IOException

Read a signed ascii integer from the input stream.

Parameters:

is -

Returns:

Throws:

java.io.IOException

receive

public static Reply receive(java.io.InputStream is)
                     throws java.io.IOException

Read a Reply from an input stream.

Parameters:

is -

Returns:

Throws:

java.io.IOException

toBytes

public static byte[] toBytes(java.lang.Number length)

receiveAsync

public Reply receiveAsync()
                   throws java.io.IOException

Wait for a reply on the input stream.

Returns:

Throws:

java.io.IOException

sendAsync

public void sendAsync(Command command)
               throws java.io.IOException

Send a command over the wire, do not wait for a reponse.

Parameters:

command -

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Close the input and output streams. Will also disconnect the socket.

Throws:

java.io.IOException