require 'socket'
-require File.join(File.dirname(__FILE__),'better_timeout')
require 'set'
+require File.join(File.dirname(__FILE__),'server')
+
class RedisError < StandardError
end
-
+class RedisRenameError < StandardError
+end
class Redis
- OK = "+OK".freeze
- ERRCODE = "-".freeze
- NIL = 'nil'.freeze
- CTRLF = "\r\n".freeze
+ ERR = "-".freeze
+ OK = 'OK'.freeze
+ SINGLE = '+'.freeze
+ BULK = '$'.freeze
+ MULTI = '*'.freeze
+ INT = ':'.freeze
+
+ attr_reader :server
+
+
+ def initialize(opts={})
+ @opts = {:host => 'localhost', :port => '6379', :db => 0}.merge(opts)
+ $debug = @opts[:debug]
+ @db = @opts[:db]
+ @server = Server.new(@opts[:host], @opts[:port])
+ end
def to_s
"#{host}:#{port}"
@opts[:host]
end
- def initialize(opts={})
- @opts = {:host => 'localhost', :port => '6379'}.merge(opts)
+ def with_socket_management(server, &block)
+ begin
+ block.call(server.socket)
+ #Timeout or server down
+ rescue Errno::ECONNRESET, Errno::EPIPE, Errno::ECONNREFUSED => e
+ server.close
+ puts "Client (#{server.inspect}) disconnected from server: #{e.inspect}\n" if $debug
+ retry
+ #Server down
+ rescue NoMethodError => e
+ puts "Client (#{server.inspect}) tryin server that is down: #{e.inspect}\n Dying!" if $debug
+ raise Errno::ECONNREFUSED
+ #exit
+ end
+ end
+
+ def monitor
+ with_socket_management(@server) do |socket|
+ trap("INT") { puts "\nGot ^C! Dying!"; exit }
+ write "MONITOR\r\n"
+ puts "Now Monitoring..."
+ socket.read(12)
+ loop do
+ x = socket.gets
+ puts x unless x.nil?
+ end
+ end
+ end
+
+ def quit
+ write "QUIT\r\n"
end
- # SET key value
- # Time complexity: O(1)
- # Set the string value as value of the key. The string can't be longer
- # than 1073741824 bytes (1 GB).
- #
- # Return value: status code reply
- def []=(key, val)
- val = redis_marshal(val)
- timeout_retry(3, 3){
- write "SET #{key} #{val.to_s.size}\r\n#{val}\r\n"
- status_code_reply
- }
+ def select_db(index)
+ @db = index
+ write "SELECT #{index}\r\n"
+ get_response
end
- # SETNX key value
- #
- # Time complexity: O(1)
- # SETNX works exactly like SET with the only difference that if the key
- # already exists no operation is performed. SETNX actually means "SET if Not eXists".
- #
- # *Return value: integer reply, specifically:
- #
- # 1 if the key was set 0 if the key was not set
- def set_unless_exists(key, val)
- val = redis_marshal(val)
- timeout_retry(3, 3){
- write "SETNX #{key} #{val.to_s.size}\r\n#{val}\r\n"
- integer_reply == 1
- }
+ def flush_db
+ write "FLUSHDB\r\n"
+ get_response == OK
+ end
+
+ def flush_all
+ ensure_retry do
+ puts "Warning!\nFlushing *ALL* databases!\n5 Seconds to Hit ^C!"
+ trap('INT') {quit; return false}
+ sleep 5
+ write "FLUSHALL\r\n"
+ get_response == OK
+ end
+ end
+
+ def last_save
+ write "LASTSAVE\r\n"
+ get_response.to_i
end
- # GET key
- # Time complexity: O(1)
- # Get the value of the specified key. If the key does not exist the special value
- # 'nil' is returned. If the value stored at key is not a string an error is
- # returned because GET can only handle string values.
- #
- # Return value: bulk reply
- def [](key)
- timeout_retry(3, 3){
- write "GET #{key}\r\n"
- redis_unmarshal(bulk_reply)
- }
+ def bgsave
+ write "BGSAVE\r\n"
+ get_response == OK
+ end
+
+ def info
+ info = {}
+ write("INFO\r\n")
+ x = get_response
+ x.each do |kv|
+ k,v = kv.split(':', 2)
+ k,v = k.chomp, v = v.chomp
+ info[k.to_sym] = v
+ end
+ info
end
- # INCR key
- # INCRBY key value
- # Time complexity: O(1)
- # Increment the number stored at key by one. If the key does not exist or contains
- # a value of a wrong type, set the key to the value of "1" (like if the previous
- # value was zero).
- #
- # INCRBY works just like INCR but instead to increment by 1 the increment is value.
- #
- # Return value: integer reply
- def incr(key, increment=nil)
- timeout_retry(3, 3){
- if increment
- write "INCRBY #{key} #{increment}\r\n"
- else
- write "INCR #{key}\r\n"
- end
- integer_reply
- }
+
+ def bulk_reply
+ begin
+ x = read.chomp
+ puts "bulk_reply read value is #{x.inspect}" if $debug
+ return x
+ rescue => e
+ puts "error in bulk_reply #{e}" if $debug
+ nil
+ end
end
-
- # DECR key
- #
- # DECRBY key value
- #
- # Time complexity: O(1) Like INCR/INCRBY but decrementing instead of incrementing.
- def decr(key, increment=nil)
- timeout_retry(3, 3){
- if increment
- write "DECRBY #{key} #{increment}\r\n"
- else
- write "DECR #{key}\r\n"
- end
- integer_reply
- }
+ def write(data)
+ with_socket_management(@server) do |socket|
+ puts "writing: #{data}" if $debug
+ socket.write(data)
+ end
end
- # RANDOMKEY
- # Time complexity: O(1)
- # Returns a random key from the currently seleted DB.
- #
- # Return value: single line reply
- def randkey
- timeout_retry(3, 3){
- write "RANDOMKEY\r\n"
- single_line_reply
- }
+ def fetch(len)
+ with_socket_management(@server) do |socket|
+ len = [0, len.to_i].max
+ res = socket.read(len + 2)
+ res = res.chomp if res
+ res
+ end
+ end
+
+ def read(length = read_proto)
+ with_socket_management(@server) do |socket|
+ res = socket.read(length)
+ puts "read is #{res.inspect}" if $debug
+ res
+ end
end
- # RENAME oldkey newkey
- #
- # Atomically renames the key oldkey to newkey. If the source and destination
- # name are the same an error is returned. If newkey already exists it is
- # overwritten.
- #
- # Return value: status code reply
- def rename!(oldkey, newkey)
- timeout_retry(3, 3){
- write "RENAME #{oldkey} #{newkey}\r\n"
- status_code_reply
- }
+ def keys(glob)
+ write "KEYS #{glob}\r\n"
+ get_response.split(' ')
end
+
+ def rename!(oldkey, newkey)
+ write "RENAME #{oldkey} #{newkey}\r\n"
+ get_response
+ end
- # RENAMENX oldkey newkey
- # Just like RENAME but fails if the destination key newkey already exists.
- #
- # *Return value: integer reply, specifically:
- #
- # 1 if the key was renamed 0 if the target key already exist -1 if the
- # source key does not exist -3 if source and destination keys are the same
def rename(oldkey, newkey)
- timeout_retry(3, 3){
- write "RENAMENX #{oldkey} #{newkey}\r\n"
- case integer_reply
- when -1
- raise RedisError, "source key: #{oldkey} does not exist"
- when 0
- raise RedisError, "target key: #{oldkey} already exists"
- when -3
- raise RedisError, "source and destination keys are the same"
- when 1
- true
- end
- }
- end
+ write "RENAMENX #{oldkey} #{newkey}\r\n"
+ case get_response
+ when -1
+ raise RedisRenameError, "source key: #{oldkey} does not exist"
+ when 0
+ raise RedisRenameError, "target key: #{oldkey} already exists"
+ when -3
+ raise RedisRenameError, "source and destination keys are the same"
+ when 1
+ true
+ end
+ end
- # EXISTS key
- # Time complexity: O(1)
- # Test if the specified key exists. The command returns "0" if the key
- # exists, otherwise "1" is returned. Note that even keys set with an empty
- # string as value will return "1".
- #
- # *Return value: integer reply, specifically:
- #
- # 1 if the key exists 0 if the key does not exist
def key?(key)
- timeout_retry(3, 3){
- write "EXISTS #{key}\r\n"
- integer_reply == 1
- }
- end
+ write "EXISTS #{key}\r\n"
+ get_response == 1
+ end
- # DEL key
- # Time complexity: O(1)
- # Remove the specified key. If the key does not exist no operation is
- # performed. The command always returns success.
- #
- # *Return value: integer reply, specifically:
- #
- # 1 if the key was removed 0 if the key does not exist
def delete(key)
- timeout_retry(3, 3){
- write "DEL #{key}\r\n"
- integer_reply == 1
- }
+ write "DEL #{key}\r\n"
+ get_response == 1
+ end
+
+ def [](key)
+ get(key)
+ end
+
+ def get(key)
+ write "GET #{key}\r\n"
+ get_response
end
- # KEYS pattern
- # Time complexity: O(n) (with n being the number of keys in the DB)
- # Returns all the keys matching the glob-style pattern as space separated strings.
- # For example if you have in the database the keys "foo" and "foobar" the command
- # "KEYS foo*" will return "foo foobar".
- #
- # Note that while the time complexity for this operation is O(n) the constant times
- # are pretty low. For example Redis running on an entry level laptop can scan a 1
- # million keys database in 40 milliseconds. Still it's better to consider this one
- # of the slow commands that may ruin the DB performance if not used with care.
- #
- # Return value: bulk reply
- def keys(glob)
- timeout_retry(3, 3){
- write "KEYS #{glob}\r\n"
- bulk_reply.split(' ')
- }
+ def mget(*keys)
+ write "MGET #{keys.join(' ')}\r\n"
+ get_response
+ end
+
+ def incr(key, increment=nil)
+ if increment
+ write "INCRBY #{key} #{increment}\r\n"
+ else
+ write "INCR #{key}\r\n"
+ end
+ get_response
+ end
+
+ def decr(key, decrement=nil)
+ if decrement
+ write "DECRBY #{key} #{decrement}\r\n"
+ else
+ write "DECR #{key}\r\n"
+ end
+ get_response
end
- # TYPE key
- #
- # Time complexity: O(1) Return the type of the value stored at key in form of
- # a string. The type can be one of "none", "string", "list", "set". "none" is
- # returned if the key does not exist.
- #
- # Return value: single line reply
+ def randkey
+ write "RANDOMKEY\r\n"
+ get_response
+ end
+
+ def list_length(key)
+ write "LLEN #{key}\r\n"
+ case i = get_response
+ when -2
+ raise RedisError, "key: #{key} does not hold a list value"
+ else
+ i
+ end
+ end
+
def type?(key)
- timeout_retry(3, 3){
- write "TYPE #{key}\r\n"
- single_line_reply
- }
+ write "TYPE #{key}\r\n"
+ get_response
end
- # RPUSH key string
- #
- # Time complexity: O(1)
- # Add the given string to the tail of the list contained at key. If the key
- # does not exist an empty list is created just before the append operation.
- # If the key exists but is not a List an error is returned.
- #
- # Return value: status code reply
def push_tail(key, string)
- timeout_retry(3, 3){
- write "RPUSH #{key} #{string.to_s.size}\r\n#{string.to_s}\r\n"
- status_code_reply
- }
- end
-
- # LPUSH key string
- # Time complexity: O(1)
- # Add the given string to the head of the list contained at key. If the
- # key does not exist an empty list is created just before the append operation.
- # If the key exists but is not a List an error is returned.
- #
- # Return value: status code reply
+ write "RPUSH #{key} #{string.to_s.size}\r\n#{string.to_s}\r\n"
+ get_response
+ end
+
def push_head(key, string)
- timeout_retry(3, 3){
- write "LPUSH #{key} #{string.to_s.size}\r\n#{string.to_s}\r\n"
- status_code_reply
- }
+ write "LPUSH #{key} #{string.to_s.size}\r\n#{string.to_s}\r\n"
+ get_response
end
- # LPOP key
- #
- # Time complexity: O(1)
- # Atomically return and remove the first element of the list. For example if
- # the list contains the elements "a","b","c" LPOP will return "a" and the
- # list will become "b","c".
- #
- # If the key does not exist or the list is already empty the special value
- # 'nil' is returned.
- #
- # Return value: bulk reply
def pop_head(key)
- timeout_retry(3, 3){
- write "LPOP #{key}\r\n"
- bulk_reply
- }
+ write "LPOP #{key}\r\n"
+ get_response
end
-
- # RPOP key
- # This command works exactly like LPOP, but the last element instead
- # of the first element of the list is returned/deleted.
+
def pop_tail(key)
- timeout_retry(3, 3){
- write "RPOP #{key}\r\n"
- bulk_reply
- }
- end
-
- # LSET key index value
- # Time complexity: O(N) (with N being the length of the list)
- # Set the list element at index (see LINDEX for information about the index argument) with the new value. Out of range indexes will generate an error. Note that setting the first or last elements of the list is O(1).
- #
- # Return value: status code reply
+ write "RPOP #{key}\r\n"
+ get_response
+ end
+
def list_set(key, index, val)
- timeout_retry(3, 3){
- write "LSET #{key} #{index} #{val.to_s.size}\r\n#{val}\r\n"
- status_code_reply
- }
+ write "LSET #{key} #{index} #{val.to_s.size}\r\n#{val}\r\n"
+ get_response == OK
end
-
-
- # LLEN key
- # Time complexity: O(1)
- # Return the length of the list stored at the specified key. If the key does not
- # exist zero is returned (the same behaviour as for empty lists). If the value
- # stored at key is not a list the special value -1 is returned. Note: client
- # library should raise an exception when -1 is returned instead to pass the
- # value back to the caller like a normal list length value.
- #
- # *Return value: integer reply, specifically:
- #
- # the length of the list as an integer
- # >=
- # 0 if the operation succeeded -2 if the specified key does not hold a list valu
+
def list_length(key)
- timeout_retry(3, 3){
- write "LLEN #{key}\r\n"
- case i = integer_reply
- when -2
- raise RedisError, "key: #{key} does not hold a list value"
- else
- i
- end
- }
+ write "LLEN #{key}\r\n"
+ case i = get_response
+ when -2
+ raise RedisError, "key: #{key} does not hold a list value"
+ else
+ i
+ end
end
-
- # LRANGE key start end
- # Time complexity: O(n) (with n being the length of the range)
- # Return the specified elements of the list stored at the specified key. Start
- # and end are zero-based indexes. 0 is the first element of the list (the list head),
- # 1 the next element and so on.
- #
- # For example LRANGE foobar 0 2 will return the first three elements of the list.
- #
- # start and end can also be negative numbers indicating offsets from the end of the list.
- # For example -1 is the last element of the list, -2 the penultimate element and so on.
- #
- # Indexes out of range will not produce an error: if start is over the end of the list,
- # or start > end, an empty list is returned. If end is over the end of the list Redis
- # will threat it just like the last element of the list.
- #
- # Return value: multi bulk reply
+
def list_range(key, start, ending)
- timeout_retry(3, 3){
- write "LRANGE #{key} #{start} #{ending}\r\n"
- multi_bulk_reply
- }
+ write "LRANGE #{key} #{start} #{ending}\r\n"
+ get_response
end
-
- # LTRIM key start end
- # Time complexity: O(n) (with n being len of list - len of range)
- # Trim an existing list so that it will contain only the specified range of
- # elements specified. Start and end are zero-based indexes. 0 is the first
- # element of the list (the list head), 1 the next element and so on.
- #
- # For example LTRIM foobar 0 2 will modify the list stored at foobar key so that
- # only the first three elements of the list will remain.
- #
- # start and end can also be negative numbers indicating offsets from the end of
- # the list. For example -1 is the last element of the list, -2 the penultimate
- # element and so on.
- #
- # Indexes out of range will not produce an error: if start is over the end of
- # the list, or start > end, an empty list is left as value. If end over the
- # end of the list Redis will threat it just like the last element of the list.
- #
- # Hint: the obvious use of LTRIM is together with LPUSH/RPUSH. For example:
- #
- # LPUSH mylist <someelement> LTRIM mylist 0 99
- # The above two commands will push elements in the list taking care that the
- # list will not grow without limits. This is very useful when using Redis
- # to store logs for example. It is important to note that when used in this
- # way LTRIM is an O(1) operation because in the average case just one element
- # is removed from the tail of the list.
- #
- # Return value: status code reply
def list_trim(key, start, ending)
- timeout_retry(3, 3){
- write "LTRIM #{key} #{start} #{ending}\r\n"
- status_code_reply
- }
+ write "LTRIM #{key} #{start} #{ending}\r\n"
+ get_response
end
-
- # LINDEX key index
- # Time complexity: O(n) (with n being the length of the list)
- # Return the specified element of the list stored at the specified key. 0 is
- # the first element, 1 the second and so on. Negative indexes are supported,
- # for example -1 is the last element, -2 the penultimate and so on.
- #
- # If the value stored at key is not of list type an error is returned. If
- # the index is out of range an empty string is returned.
- #
- # Note that even if the average time complexity is O(n) asking for the first
- # or the last element of the list is O(1).
- #
- # Return value: bulk reply
+
def list_index(key, index)
- timeout_retry(3, 3){
- write "LINDEX #{key} #{index}\r\n"
- bulk_reply
- }
+ write "LINDEX #{key} #{index}\r\n"
+ get_response
end
-
- # SADD key member
- # Time complexity O(1)
- # Add the specified member to the set value stored at key. If member is
- # already a member of the set no operation is performed. If key does not
- # exist a new set with the specified member as sole member is crated. If
- # the key exists but does not hold a set value an error is returned.
- #
- # *Return value: integer reply, specifically:
- #
- # 1 if the new element was added 0 if the new element was already a member
- # of the set -2 if the key contains a non set value
+
+ def list_rm(key, count, value)
+ write "LREM #{key} #{count} #{value.to_s.size}\r\n#{value}\r\n"
+ case num = get_response
+ when -1
+ raise RedisError, "key: #{key} does not exist"
+ when -2
+ raise RedisError, "key: #{key} does not hold a list value"
+ else
+ num
+ end
+ end
+
def set_add(key, member)
- timeout_retry(3, 3){
- write "SADD #{key} #{member.to_s.size}\r\n#{member}\r\n"
- case integer_reply
- when 1
- true
- when 0
- false
- when -2
- raise RedisError, "key: #{key} contains a non set value"
- end
- }
+ write "SADD #{key} #{member.to_s.size}\r\n#{member}\r\n"
+ case get_response
+ when 1
+ true
+ when 0
+ false
+ when -2
+ raise RedisError, "key: #{key} contains a non set value"
+ end
end
-
- # SREM key member
- #
- # Time complexity O(1)
- # Remove the specified member from the set value stored at key. If member
- # was not a member of the set no operation is performed. If key does not
- # exist or does not hold a set value an error is returned.
- #
- # *Return value: integer reply, specifically:
- #
- # 1 if the new element was removed 0 if the new element was not a member
- # of the set -2 if the key does not hold a set value
+
def set_delete(key, member)
- timeout_retry(3, 3){
- write "SREM #{key} #{member.to_s.size}\r\n#{member}\r\n"
- case integer_reply
- when 1
- true
- when 0
- false
- when -2
- raise RedisError, "key: #{key} contains a non set value"
- end
- }
+ write "SREM #{key} #{member.to_s.size}\r\n#{member}\r\n"
+ case get_response
+ when 1
+ true
+ when 0
+ false
+ when -2
+ raise RedisError, "key: #{key} contains a non set value"
+ end
end
-
- # SCARD key
- # Time complexity O(1)
- # Return the set cardinality (number of elements). If the key does not
- # exist 0 is returned, like for empty sets. If the key does not hold a
- # set value -1 is returned. Client libraries should raise an error when -1
- # is returned instead to pass the value to the caller.
- #
- # *Return value: integer reply, specifically:
- #
- # the cardinality (number of elements) of the set as an integer
- # >=
- # 0 if the operation succeeded -2 if the specified key does not hold a set value
+
def set_count(key)
- timeout_retry(3, 3){
- write "SCARD #{key}\r\n"
- case i = integer_reply
- when -2
- raise RedisError, "key: #{key} contains a non set value"
- else
- i
- end
- }
+ write "SCARD #{key}\r\n"
+ case i = get_response
+ when -2
+ raise RedisError, "key: #{key} contains a non set value"
+ else
+ i
+ end
end
-
- # SISMEMBER key member
- #
- # Time complexity O(1)
- # Return 1 if member is a member of the set stored at key, otherwise 0 is
- # returned. On error a negative value is returned. Client libraries should
- # raise an error when a negative value is returned instead to pass the value
- # to the caller.
- #
- # *Return value: integer reply, specifically:
- #
- # 1 if the element is a member of the set 0 if the element is not a member of
- # the set OR if the key does not exist -2 if the key does not hold a set value
+
def set_member?(key, member)
- timeout_retry(3, 3){
- write "SISMEMBER #{key} #{member.to_s.size}\r\n#{member}\r\n"
- case integer_reply
- when 1
- true
- when 0
- false
- when -2
- raise RedisError, "key: #{key} contains a non set value"
- end
- }
+ write "SISMEMBER #{key} #{member.to_s.size}\r\n#{member}\r\n"
+ case get_response
+ when 1
+ true
+ when 0
+ false
+ when -2
+ raise RedisError, "key: #{key} contains a non set value"
+ end
end
-
- # SINTER key1 key2 ... keyN
- # Time complexity O(N*M) worst case where N is the cardinality of the smallest
- # set and M the number of sets
- # Return the members of a set resulting from the intersection of all the sets
- # hold at the specified keys. Like in LRANGE the result is sent to the client
- # as a multi-bulk reply (see the protocol specification for more information).
- # If just a single key is specified, then this command produces the same
- # result as SELEMENTS. Actually SELEMENTS is just syntax sugar for SINTERSECT.
- #
- # If at least one of the specified keys does not exist or does not hold a set
- # value an error is returned.
- #
- # Return value: multi bulk reply
+
+ def set_members(key)
+ write "SMEMBERS #{key}\r\n"
+ Set.new(get_response)
+ end
+
def set_intersect(*keys)
- timeout_retry(3, 3){
- write "SINTER #{keys.join(' ')}\r\n"
- Set.new(multi_bulk_reply)
- }
+ write "SINTER #{keys.join(' ')}\r\n"
+ Set.new(get_response)
end
-
- # SINTERSTORE dstkey key1 key2 ... keyN
- #
- # Time complexity O(N*M) worst case where N is the cardinality of the smallest set and M the number of sets
- # This commnad works exactly like SINTER but instead of being returned the resulting set is sotred as dstkey.
- #
- # Return value: status code reply
+
def set_inter_store(destkey, *keys)
- timeout_retry(3, 3){
- write "SINTERSTORE #{destkey} #{keys.join(' ')}\r\n"
- status_code_reply
- }
- end
-
- # SMEMBERS key
- #
- # Time complexity O(N)
- # Return all the members (elements) of the set value stored at key.
- # This is just syntax glue for SINTERSECT.
- def set_members(key)
- timeout_retry(3, 3){
- write "SMEMBERS #{key}\r\n"
- Set.new(multi_bulk_reply)
- }
+ write "SINTERSTORE #{destkey} #{keys.join(' ')}\r\n"
+ get_response
end
-
-
- # SORT key [BY pattern] [GET|DEL|INCR|DECR pattern] [ASC|DESC] [LIMIT start count]
- # Sort the elements contained in the List or Set value at key. By default sorting is
- # numeric with elements being compared as double precision floating point numbers.
- # This is the simplest form of SORT.
- # SORT mylist
- #
- # Assuming mylist contains a list of numbers, the return value will be the list of
- # numbers ordered from the smallest to the bigger number. In order to get the sorting
- # in reverse order use DESC:
- # SORT mylist DESC
- #
- # ASC is also supported but it's the default so you don't really need it. If you
- # want to sort lexicographically use ALPHA. Note that Redis is utf-8 aware
- # assuming you set the right value for the LC_COLLATE environment variable.
- #
- # Sort is able to limit the number of results using the LIMIT option:
- # SORT mylist LIMIT 0 10
- # In the above example SORT will return only 10 elements, starting from the first one
- # (star is zero-based). Almost all the sort options can be mixed together. For example:
- # SORT mylist LIMIT 0 10 ALPHA DESC
- # Will sort mylist lexicographically, in descending order, returning only the first
- # 10 elements.
- # Sometimes you want to sort elements using external keys as weights to compare
- # instead to compare the actual List or Set elements. For example the list mylist
- # may contain the elements 1, 2, 3, 4, that are just the unique IDs of objects
- # stored at object_1, object_2, object_3 and object_4, while the keys weight_1,
- # weight_2, weight_3 and weight_4 can contain weights we want to use to sort the
- # list of objects identifiers. We can use the following command:
- # SORT mylist BY weight_*
- # the BY option takes a pattern (weight_* in our example) that is used in order to
- # generate the key names of the weights used for sorting. Weight key names are obtained
- # substituting the first occurrence of * with the actual value of the elements on the
- # list (1,2,3,4 in our example).
- # Still our previous example will return just the sorted IDs. Often it is needed to
- # get the actual objects sorted (object_1, ..., object_4 in the example). We can do
- # it with the following command:
- # SORT mylist BY weight_* GET object_*
- # Note that GET can be used multiple times in order to get more key for every
- # element of the original List or Set sorted.
-
- # redis.sort 'index', :by => 'weight_*',
- # :order => 'DESC ALPHA',
- # :limit => [0,10],
- # :get => 'obj_*'
+
def sort(key, opts={})
cmd = "SORT #{key}"
cmd << " BY #{opts[:by]}" if opts[:by]
cmd << " #{opts[:order]}" if opts[:order]
cmd << " LIMIT #{opts[:limit].join(' ')}" if opts[:limit]
cmd << "\r\n"
- write cmd
- multi_bulk_reply
- end
-
- # ADMIN functions for redis
-
- # SELECT index
- #
- # Select the DB with having the specified zero-based numeric index.
- # For default every new client connection is automatically selected to DB 0.
- # Return value: status code reply
- def select_db(index)
- timeout_retry(3, 3){
- write "SELECT #{index}\r\n"
- status_code_reply
- }
- end
-
- # MOVE key dbindex
- #
- # Move the specified key from the currently selected DB to the specified
- # destination DB. Note that this command returns 1 only if the key was
- # successfully moved, and 0 if the target key was already there or if
- # the source key was not found at all, so it is possible to use MOVE
- # as a locking primitive.
- #
- # *Return value: integer reply, specifically:
- #
- # 1 if the key was moved 0 if the key was not moved because already
- # present on the target DB or was not found in the current DB. -3
- # if the destination DB is the same as the source DB -4 if the database
- # index if out of range
- def move(key, index)
- timeout_retry(3, 3){
- write "MOVE #{index}\r\n"
- case integer_reply
- when 1
- true
- when 0
- false
- when -3
- raise RedisError, "destination db same as source db"
- when -4
- raise RedisError, "db index if out of range"
- end
- }
- end
-
- # SAVE
- #
- # Save the DB on disk. The server hangs while the saving is not completed,
- # no connection is served in the meanwhile. An OK code is returned when
- # the DB was fully stored in disk.
- # Return value: status code reply
- def save
- timeout_retry(3, 3){
- write "SAVE\r\n"
- status_code_reply
- }
- end
-
- # BGSAVE
- #
- # Save the DB in background. The OK code is immediately returned. Redis
- # forks, the parent continues to server the clients, the child saves
- # the DB on disk then exit. A client my be able to check if the operation
- # succeeded using the LASTSAVE command.
- # Return value: status code reply
- def bgsave
- timeout_retry(3, 3){
- write "BGSAVE\r\n"
- status_code_reply
- }
- end
-
- # LASTSAVE
- #
- # Return the UNIX TIME of the last DB save executed with success. A client
- # may check if a BGSAVE command succeeded reading the LASTSAVE value, then
- # issuing a BGSAVE command and checking at regular intervals every N seconds
- # if LASTSAVE changed.
- #
- # Return value: integer reply (UNIX timestamp)
- def lastsave
- timeout_retry(3, 3){
- write "LASTSAVE\r\n"
- integer_reply
- }
+ write(cmd)
+ get_response
end
-
- def quit
- timeout_retry(3, 3){
- write "QUIT\r\n"
- status_code_reply
- }
- end
-
- private
-
- def redis_unmarshal(obj)
- if obj[0] == 4
- Marshal.load(obj)
- else
- obj
+
+ def multi_bulk
+ res = read_proto
+ puts "mb res is #{res.inspect}" if $debug
+ list = []
+ Integer(res).times do
+ vf = get_response
+ puts "curren vf is #{vf.inspect}" if $debug
+ list << vf
+ puts "current list is #{list.inspect}" if $debug
end
- end
-
- def redis_marshal(obj)
- case obj
- when String, Integer
- obj
- else
- Marshal.dump(obj)
+ list
+ end
+
+ def get_reply
+ begin
+ r = read(1)
+ raise RedisError if (r == "\r" || r == "\n")
+ rescue RedisError
+ retry
end
+ r
end
-
- def close
- socket.close unless socket.closed?
- end
-
- def timeout_retry(time, retries, &block)
- timeout(time, &block)
- rescue TimeoutError
- retries -= 1
- retry unless retries < 0
+
+ def []=(key, val)
+ set(key,val)
end
- def socket
- connect if (!@socket or @socket.closed?)
- @socket
+
+ def set(key, val, expiry=nil)
+ write("SET #{key} #{val.to_s.size}\r\n#{val}\r\n")
+ s = get_response == OK
+ return expire(key, expiry) if s && expiry
+ s
end
- def connect
- @socket = TCPSocket.new(@opts[:host], @opts[:port])
- @socket.sync = true
- @socket
+ def expire(key, expiry=nil)
+ write("EXPIRE #{key} #{expiry}\r\n")
+ get_response == 1
end
+
+ def set_unless_exists(key, val)
+ write "SETNX #{key} #{val.to_s.size}\r\n#{val}\r\n"
+ get_response == 1
+ end
- def read(length, nodebug=true)
- retries = 3
- res = socket.read(length)
- puts "read: #{res}" if @opts[:debug] && nodebug
- res
- rescue
- retries -= 1
- if retries > 0
- connect
- retry
+ def status_code_reply
+ begin
+ res = read_proto
+ if res.index('-') == 0
+ raise RedisError, res
+ else
+ true
+ end
+ rescue RedisError
+ raise RedisError
end
end
- def write(data)
- puts "write: #{data}" if @opts[:debug]
- retries = 3
- socket.write(data)
- rescue
- retries -= 1
- if retries > 0
- connect
- retry
+ def get_response
+ begin
+ rtype = get_reply
+ rescue => e
+ raise RedisError, e.inspect
+ end
+ puts "reply_type is #{rtype.inspect}" if $debug
+ case rtype
+ when SINGLE
+ single_line
+ when BULK
+ bulk_reply
+ when MULTI
+ multi_bulk
+ when INT
+ integer_reply
+ when ERR
+ raise RedisError, single_line
+ else
+ raise RedisError, "Unknown response.."
end
end
- def nibble_end
- read(2)
+ def integer_reply
+ Integer(read_proto)
end
- def read_proto
- print "read proto: " if @opts[:debug]
+ def single_line
buff = ""
- while (char = read(1, false))
- print char if @opts[:debug]
- buff << char
- break if buff[-2..-1] == CTRLF
+ while buff[-2..-1] != "\r\n"
+ buff << read(1)
end
- puts if @opts[:debug]
+ puts "single_line value is #{buff[0..-3].inspect}" if $debug
buff[0..-3]
end
-
- def status_code_reply
- res = read_proto
- if res.index(ERRCODE) == 0
- raise RedisError, res
- else
- true
- end
- end
-
- def bulk_reply
- res = read_proto
- if res.index(ERRCODE) == 0
- err = read(res.to_i.abs)
- nibble_end
- raise RedisError, err
- elsif res != NIL
- val = read(res.to_i.abs)
- nibble_end
- val
- else
- nil
- end
- end
-
-
- def multi_bulk_reply
- res = read_proto
- if res.index(ERRCODE) == 0
- err = read(res.to_i.abs)
- nibble_end
- raise RedisError, err
- elsif res == NIL
- nil
- else
- items = Integer(res)
- list = []
- items.times do
- len = Integer(read_proto)
- if len == -1
- nil
- else
- list << read(len)
- end
- nibble_end
- end
- list
+ def read_proto
+ with_socket_management(@server) do |socket|
+ if res = socket.gets
+ x = res.chomp
+ puts "read_proto is #{x.inspect}\n\n" if $debug
+ x.to_i
+ end
end
end
- def single_line_reply
- read_proto
- end
-
- def integer_reply
- Integer(read_proto)
- end
-
end
projects / redis.git / blobdiff