Class: Xunch::ListIdCache

Inherits:
Cache
  • Object
show all
Defined in:
lib/xunch/cache/list_id_cache.rb

Overview

列表缓存目前不支持并发写入，未来也不打算支持并发主要的使用场景是发现页热门的单线程写入和并发的读取并且提供remove接口，帮助从列表中移除已经不存在的声音，用户，专辑

Instance Method Summary collapse

Methods inherited from Cache

#batch_evict, #destroy, #evict, #ttl

Constructor Details

#initialize(options, shard_infos) ⇒ ListIdCache 



7
8
9
10
11
12
13
14
15
 
# File 'lib/xunch/cache/list_id_cache.rb', line 7

def initialize(options, shard_infos)
  unless RUBY_PLATFORM =~ /mingw/
    options[:driver] = 'hiredis'
  else
    options.delete(:driver)
  end
  super(options,shard_infos)
  # p options
end

Instance Method Details

#get(key, page, size) ⇒ Object

查询接口



22
23
24
25
26
27
28
29
30
31
 
# File 'lib/xunch/cache/list_id_cache.rb', line 22

def get(key, page, size)
  raise "key can not be nil." unless key != nil
  raise "page must be a positive number." unless page != nil and page > 0
  raise "size must be a positive number and less than 100." unless size != nil and size > 0 and size <= 100
  start = (page - 1) * size;
  stop = page * size - 1;
  new_key = assembleKey(key)
  ids = @shard_redis.lrange(new_key,start,stop)
  ids
end

#put(key, ids) ⇒ Object 



33
34
35
 
# File 'lib/xunch/cache/list_id_cache.rb', line 33

def put(key, ids)
  putex(key, ids, @options[:expire_time])
end

#putex(key, ids, ttl) ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/xunch/cache/list_id_cache.rb', line 37

def putex(key, ids, ttl)
  raise "key can not be nil." unless key != nil
  raise "ids can not be nil." unless ids != nil
  sub_keys = []
  ids.each { | id |
    raise "id in ids can not be nil." unless ids != nil
    sub_keys.push(id.to_s)
  }
  if sub_keys.length == 0
    return nil
  end
  temp_key = assembleTempKey(key)
  new_key = assembleKey(key)
  @shard_redis.lset(temp_key,new_key,sub_keys,ttl)
end

#remove(key, *sub_keys) ⇒ Object 



53
54
55
56
57
58
 
# File 'lib/xunch/cache/list_id_cache.rb', line 53

def remove(key, *sub_keys)
  raise "key can not be nil." unless key != nil
  raise "sub_key can not be nil." unless sub_keys != nil
  new_key = assembleKey(key)
  @shard_redis.lremove(new_key,*sub_keys)
end

#size(key) ⇒ Object 



61
62
63
64
65
 
# File 'lib/xunch/cache/list_id_cache.rb', line 61

def size(key)
  raise "key can not be nil." unless key != nil
  new_key = assembleKey(key)
  @shard_redis.llen(new_key)
end