Last active
December 21, 2015 00:28
-
-
Save sawanoboly/6219858 to your computer and use it in GitHub Desktop.
Redis Sentinel 環境で redis-namespace, sidekiqを動かす ref: http://qiita.com/sawanoboly/items/9ead476b2b00147fe48d
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ## -- snip -- | |
| Sidekiq.configure_server do |config| | |
| config.redis = { | |
| :master_name => "example-test", | |
| :sentinels => [ | |
| {:host => "localhost", :port => 26379}, | |
| {:host => "localhost", :port => 26380} | |
| ] | |
| } | |
| end | |
| Sidekiq.configure_client do |config| | |
| config.redis = { | |
| :master_name => "example-test", | |
| :sentinels => [ | |
| {:host => "localhost", :port => 26379}, | |
| {:host => "localhost", :port => 26380} | |
| ] | |
| } | |
| end | |
| ## -- snip -- |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| def client_opts(url, driver, timeout) | |
| if timeout | |
| { :url => url, :driver => driver, :timeout => timeout } | |
| else | |
| { :url => url, :driver => driver } | |
| end | |
| end |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| TID-oxgwckouo INFO: Running in ruby 2.0.0p247 (2013-06-27 revision 41674) [x86_64-darwin12.3.0] | |
| TID-oxgwcg8yk ERROR: Error fetching message: Error connecting to Redis on 127.0.0.1:16380 (ECONNREFUSED) | |
| # -- 接続切れた | |
| TID-oxgwcg8yk ERROR: /Users/sawanoboriyu/.rvm/gems/ruby-2.0.0-p247@redis-sentinel/gems/redis-3.0.4/lib/redis/client.rb:276:in `rescue in | |
| TID-oxgwcg8yk ERROR: /Users/sawanoboriyu/.rvm/gems/ruby-2.0.0-p247@redis-sentinel/gems/redis-3.0.4/lib/redis/client.rb:271:in `establish | |
| TID-oxgwcg8yk ERROR: /Users/sawanoboriyu/.rvm/gems/ruby-2.0.0-p247@redis-sentinel/gems/redis-3.0.4/lib/redis/client.rb:69:in `connect' | |
| TID-oxgwcg8yk ERROR: /Users/sawanoboriyu/github/others/redis-sentinel/lib/redis-sentinel/client.rb:25:in `block in connect_with_sentinel | |
| TID-oxgwcg8yk ERROR: /Users/sawanoboriyu/github/others/redis-sentinel/lib/redis-sentinel/client.rb:42:in `call' | |
| TID-oxgwcg8yk ERROR: /Users/sawanoboriyu/github/others/redis-sentinel/lib/redis-sentinel/client.rb:42:in `auto_retry_with_timeout' | |
| # -- redis-sentinel gemによるマスタ再発見まわり | |
| TID-oxgwcg8yk ERROR: /Users/sawanoboriyu/github/others/redis-sentinel/lib/redis-sentinel/client.rb:23:in `connect_with_sentinel' | |
| TID-oxgwevm7g ERROR: The master: example-test is currently not available. | |
| TID-oxgwevm7g ERROR: /Users/sawanoboriyu/github/others/redis-sentinel/lib/redis-sentinel/client.rb:75:in `discover_master' | |
| # -- 復旧 | |
| TID-oxgwcg8yk INFO: Redis is online, 16.16007900238037 sec downtime |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| # Make sure you have Sinatra installed, then start sidekiq with | |
| # ./bin/sidekiq -r ./examples/sinkiq.rb | |
| # Simply run Sinatra with | |
| # ruby examples/sinkiq.rb | |
| # and then browse to http://localhost:4567 | |
| # | |
| require 'sinatra' | |
| require 'sidekiq' | |
| require 'redis' | |
| $redis = Redis.new | |
| class SinatraWorker | |
| include Sidekiq::Worker | |
| def perform(msg="lulz you forgot a msg!") | |
| $redis.lpush("sinkiq-example-messages", msg) | |
| end | |
| end | |
| get '/' do | |
| stats = Sidekiq::Stats.new | |
| @failed = stats.failed | |
| @processed = stats.processed | |
| @messages = $redis.lrange('sinkiq-example-messages', 0, -1) | |
| erb :index | |
| end | |
| post '/msg' do | |
| SinatraWorker.perform_async params[:msg] | |
| redirect to('/') | |
| end | |
| __END__ | |
| @@ layout | |
| <html> | |
| <head> | |
| <title>Sinatra + Sidekiq</title> | |
| <body> | |
| <%= yield %> | |
| </body> | |
| </html> | |
| @@ index | |
| <h1>Sinatra + Sidekiq Example</h1> | |
| <h2>Failed: <%= @failed %></h2> | |
| <h2>Processed: <%= @processed %></h2> | |
| <form method="post" action="/msg"> | |
| <input type="text" name="msg"> | |
| <input type="submit" value="Add Message"> | |
| </form> | |
| <a href="/">Refresh page</a> | |
| <h3>Messages</h3> | |
| <% @messages.each do |msg| %> | |
| <p><%= msg %></p> | |
| <% end %> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| require 'sinatra' | |
| require 'sidekiq' | |
| require 'redis' | |
| require 'redis-sentinel' | |
| redis_conn = proc { | |
| Redis.new(:master_name => "example-test", | |
| :sentinels => [ | |
| {:host => "localhost", :port => 26379}, | |
| {:host => "localhost", :port => 26380} | |
| ]) | |
| } | |
| Sidekiq.configure_server do |config| | |
| config.redis = ConnectionPool.new(size: 10, &redis_conn) | |
| end | |
| Sidekiq.configure_client do |config| | |
| config.redis = ConnectionPool.new(size: 5, &redis_conn) | |
| end | |
| class SinatraWorker | |
| include Sidekiq::Worker | |
| def perform(msg="lulz you forgot a msg!") | |
| $redis.lpush("sinkiq-example-messages", msg) | |
| end | |
| end | |
| get '/' do | |
| stats = Sidekiq::Stats.new | |
| @failed = stats.failed | |
| @processed = stats.processed | |
| @messages = $redis.lrange('sinkiq-example-messages', 0, -1) | |
| erb :index | |
| end | |
| post '/msg' do | |
| SinatraWorker.perform_async params[:msg] | |
| redirect to('/') | |
| end | |
| __END__ | |
| @@ layout | |
| <html> | |
| <head> | |
| <title>Sinatra + Sidekiq</title> | |
| <body> | |
| <%= yield %> | |
| </body> | |
| </html> | |
| @@ index | |
| <h1>Sinatra + Sidekiq Example</h1> | |
| <h2>Failed: <%= @failed %></h2> | |
| <h2>Processed: <%= @processed %></h2> | |
| <form method="post" action="/msg"> | |
| <input type="text" name="msg"> | |
| <input type="submit" value="Add Message"> | |
| </form> | |
| <a href="/">Refresh page</a> | |
| <h3>Messages</h3> | |
| <% @messages.each do |msg| %> | |
| <p><%= msg %></p> | |
| <% end %> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| require 'redis' | |
| require 'redis-sentinel' | |
| redis = Redis.new(:master_name => "example-test", | |
| :sentinels => [ | |
| {:host => "localhost", :port => 26379}, | |
| {:host => "localhost", :port => 26380} | |
| ]) | |
| redis.set "foo", "bar" | |
| while true | |
| begin | |
| puts redis.get "foo" | |
| rescue => e | |
| puts "failed?", e | |
| end | |
| sleep 1 | |
| end |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| require 'redis' | |
| require 'redis-namespace' | |
| require 'redis-sentinel' | |
| redis_s = Redis.new(:master_name => "example-test", | |
| :sentinels => [ | |
| {:host => "localhost", :port => 26379}, | |
| {:host => "localhost", :port => 26380} | |
| ]) | |
| redis = Redis::Namespace.new(:myspace, :redis => redis_s) | |
| redis.set "foo", "bar" | |
| while true | |
| begin | |
| puts redis.get "foo" | |
| rescue => e | |
| puts "failed?", e | |
| end | |
| sleep 1 | |
| end |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment