[个人翻译]Redis 集群教程（中）

wsxxz

1  require './cluster'　　
2
　　
3  if ARGV.length != 2
　　
4      startup_nodes = [
　　
5          {:host => "127.0.0.1", :port => 7000},
　　
6          {:host => "127.0.0.1", :port => 7001}
　　
7      ]
　　
8  else
　　
9      startup_nodes = [
　　
10          {:host => ARGV[0], :port => ARGV[1].to_i}
　　
11      ]
　　
12  end
　　
13
　　
14  rc = RedisCluster.new(startup_nodes,32,:timeout => 0.1)
　　
15
　　
16  last = false
　　
17
　　
18  while not last
　　
19      begin
　　
20          last = rc.get("__last__")
　　
21          last = 0 if !last
　　
22      rescue => e
　　
23          puts "error #{e.to_s}"
　　
24          sleep 1
　　
25      end
　　
26  end
　　
27
　　
28  ((last.to_i+1)..1000000000).each{|x|
　　
29      begin
　　
30          rc.set("foo#{x}",x)
　　
31          puts rc.get("foo#{x}")
　　
32          rc.set("__last__",x)
　　
33      rescue => e
　　
34          puts "error #{e.to_s}"
　　
35      end
　　
36      sleep 0.1
　　
37  }