Không thể giải cứu từ Redis kết nối từ chối

Question

Tôi đang cố gắng để viết một chức năng mà cố gắng để kết nối với Redis sử dụng cài đặt TCP mặc định, và nếu thất bại, cố gắng để kết nối với Redis thông qua một ổ cắm unix. Mục đích của tôi là có một kịch bản kết nối duy nhất hoạt động trên tất cả các hệ thống của tôi, một số trong đó sử dụng TCP và các hệ thống khác sử dụng ổ cắm.

Tuy nhiên, tôi dường như không thể giải cứu từ các kết nối TCP thất bại. Đây là kịch bản thử nghiệm của tôi.

require "redis" 

def r 
    begin 
    $redis ||= Redis.new 
    rescue 
    $redis = Redis.new(:path => "/tmp/redis.sock") 
    end 
end 

puts "You have #{r.keys.count} redis keys" 

Khối rescue không bao giờ được thực thi và thay vào đó là ngoại lệ. Đây là đầu ra của tập lệnh này.

 
/usr/local/rvm/gems/ruby-1.9.2-p290/gems/redis-2.2.2/lib/redis/client.rb:236:in `rescue in establish_connection': Connection refused - Unable to connect to Redis on 127.0.0.1:6379 (Errno::ECONNREFUSED) 
    from /usr/local/rvm/gems/ruby-1.9.2-p290/gems/redis-2.2.2/lib/redis/client.rb:222:in `establish_connection' 
    from /usr/local/rvm/gems/ruby-1.9.2-p290/gems/redis-2.2.2/lib/redis/client.rb:23:in `connect' 
    from /usr/local/rvm/gems/ruby-1.9.2-p290/gems/redis-2.2.2/lib/redis/client.rb:247:in `ensure_connected' 
    from /usr/local/rvm/gems/ruby-1.9.2-p290/gems/redis-2.2.2/lib/redis/client.rb:137:in `block in process' 
    from /usr/local/rvm/gems/ruby-1.9.2-p290/gems/redis-2.2.2/lib/redis/client.rb:206:in `logging' 
    from /usr/local/rvm/gems/ruby-1.9.2-p290/gems/redis-2.2.2/lib/redis/client.rb:136:in `process' 
    from /usr/local/rvm/gems/ruby-1.9.2-p290/gems/redis-2.2.2/lib/redis/client.rb:46:in `call' 
    from /usr/local/rvm/gems/ruby-1.9.2-p290/gems/redis-2.2.2/lib/redis.rb:246:in `block in keys' 
    from /usr/local/rvm/rubies/ruby-1.9.2-p290/lib/ruby/1.9.1/monitor.rb:201:in `mon_synchronize' 
    from /usr/local/rvm/gems/ruby-1.9.2-p290/gems/redis-2.2.2/lib/redis.rb:245:in `keys' 
    from scripts/redis.rb:11:in `<main>' 

Tôi đã xác minh rằng Redis.new(:path => "/tmp/redis.sock") hoạt động như mong đợi. Tôi đã cố gắng cụ thể hơn với khối cứu hộ của mình bằng cách sử dụng rescue Errno::ECONNREFUSED để không có kết quả. Tôi không chắc tại sao tôi không thể bắt được ngoại lệ này.

Bất kỳ ý tưởng nào?

Answer 1

Nó chỉ ra các ngoại lệ không được ném khi gọi Redis.new. Ngoại lệ không bị ném cho đến khi một số phương thức nhất định (trong trường hợp này là Redis#keys) trên đối tượng kết nối được gọi. Chức năng kết nối được sửa đổi này xuất hiện để thực hiện thủ thuật.

require "redis" 

def r 
    begin 
    $redis ||= Redis.new 
    $redis.inspect # needed to know if connection failed 
    rescue 
    $redis = Redis.new(:path => "/tmp/redis.sock") 
    end 
    $redis 
end 

Answer 2

tôi thấy rằng $redis.inspect không thực sự thực hiện kết nối REDIS. Tôi đã thay thế nó bằng $redis.keys và điều đó đã loại bỏ một cách chính xác ngoại lệ. Lưu ý, đang chạy trên Heroko và nó đi trong môi trường biến . Sau đó tôi có một hằng số REDIS mà tôi sử dụng trong suốt ứng dụng.

Trong cấu hình của tôi/initializers/redis.rb:

uri = URI.parse(ENV['REDISTOGO_URL']) 
begin 
    redis ||= Redis.new(:host => uri.host, :port => uri.port, :password => uri.password) 
    redis.keys # needed to know if connection failed 
    REDIS = redis 
rescue 
    puts("Redis not loaded on #{uri.port}") 
    REDIS = nil 
end