Rinda, druby answering the RubyConf, RubyKaigi Masatoshi SEKI

Size: px

Start display at page:

Download "Rinda, druby answering the RubyConf, RubyKaigi Masatoshi SEKI"

ともあきねぎたや
5 years ago
Views:

1 Rinda, druby answering the RubyConf, RubyKaigi Masatoshi SEKI

3 05 druby Web

4 amazon.co.jp druby Web buy now!

5 Agile

6 Ruby Ruby Ruby XP

7 ERB druby Rinda RWiki Div Koya... products

8 users ERB druby Rinda RWiki Div Koya... Rinda other druby ERB

9 users ERB druby Rinda RWiki Div Koya... Rinda druby other ERB

10 ego-search ERB druby Rinda RWiki Div Koya... other ERB Rinda druby

11 Rinda other druby other ERB Rinda ERB druby

12 ERB

13 about me Rinda ERB Rinda druby

14 agenda druby, Rinda RubyKaigi 2006 Rinda and DRb in the Real World. Scaling Twitter

16 RubyKaigi 2006

druby drubyのやることブロック付きメソッド Rubyのメッセージングを拡張なぜ動くのか別のプロセスのオブジェクトのメソッドを起動するで? Procは参照渡し yieldはprocへの操作いろんな分散 Rubyなので IDL不要 proxyは一種類だけ寿命といえば永続化配置 drubyをなにに使うの?

17 druby drubyのやることブロック付きメソッド Rubyのメッセージングを拡張なぜ動くのか別のプロセスのオブジェクトのメソッドを起動するで? Procは参照渡し yieldはprocへの操作いろんな分散 Rubyなので IDL不要 proxyは一種類だけ寿命といえば永続化配置 drubyをなにに使うの? プロセス永遠の永続化マシン比較的に永続化機能一方よりは長生きだちょっと豪華な通信の代替手段長命なオブジェクト遺言に苦労するなら Web UI 2.0 Event! だいぶ短命長生き Webブラウザ長生きするオブジェクトの方が自はじめから長命なオブジェクトは Web UIとかつーかそのMVCでいいの? 然なときいかが? HTTP Web UI 長生きだと自然アプリケーション

19 (3) Object Object

22 cinq:~ mas$ irb --simple-prompt --noreadline >> require 'drb/drb' => true >> cinq:~ mas$ irb --simple-prompt --noreadline >> require 'drb/drb' => true >> OSX Thread

23 {} URI >> DRb.start_service('druby://localhost:12345', {}) => #<DRb::DRbServer:0x1c1e48...> >>

24 URI >> DRb.start_service => #<DRb::DRbServer:0x1c97c4...> >> ro = DRbObject.new_with_uri('druby://localhost: 12345') => #<DRb::DRbObject:...> >>

25 >> ro['client'] = 'Hello, Again' => "Hello, Again" >> >> DRb.front => {"client"=>"hello, Again"} >> DRb.front['server'] = 'Hello, World.' => "Hello, World." >> >> ro['server'] => "Hello, World." >> ro => #<DRb::DRbObject:..."> >> ro.keys => ["client", "server"] >> ro.values => ["Hello, Again", "Hello, World."] >>

26 Marshal dumpable Number, Boolean, String clone can t dump Proc, Thread, File reference

27 >> DRb.front['thread'] = Thread.current => #<Thread:0x1df7cc run> >> >> ro['thread'] => #<DRb::DRbObject:...> >> ro['thread'].status => "sleep" >>

28 >> ro['client'] => "Hello, Again" >> ro['client'].reverse! => "niaga,olleh" >> ro['client'] => "Hello, Again" >> >> DRb.front['client'] => "Hello, Again" >>

29 TupleSpace

35 Rinda もっとかっこいいやつ Linda Lindaの協調 out 並列処理糊言語 LindaとRinda 並列処理糊言語動的な構成変更 Ring タプルとタプルスペースパターンで指定使わなくても素振りしておけパターンマッチングブロックできる inとrd 参加者はタプルスペースだけを知ってるかっこいい並列処理 Rinda Tuple Spaceだけを知っている Engine Client RubyによるLindaの実装 Engine drubyを意識してくれる TupleSpace TupleはArray Hashで Client Engine

38 Tuple Space Engine Client Engine TupleSpace Engine Client

40 >> ts = Rinda::TupleSpace.new => #<Rinda::TupleSpace:...> >> DRb.front['ts'] = ts => #<Rinda::TupleSpace:...> >> TupleSpaceProxy druby >> it = DRbObject.new_with_uri('druby://localhost:12345? ts') => #<DRb::DRbObject:...> >> ts = Rinda::TupleSpaceProxy.new(it) => #<Rinda::TupleSpaceProxy:...> >>

41 >> ts.write([:seki, :age, 20]) => #<Rinda::TupleEntry:...> >> TupleSpace :seki :age 20

42 >> ts.write([:seki, :age, 20]) => #<Rinda::TupleEntry:...> >> TupleSpace >> ts.take([:seki, :age, nil]) => [:seki, :age, 20] >> :seki :age 20

43 >> ts.take([:seki, :age, nil]) TupleSpace

44 >> ts.take([:seki, :age, nil]) >> ts.write([:seki, :age, 20]) => #<Rinda::TupleEntry:...> >> TupleSpace :seki :age 20

45 >> ts.take([:seki, :age, nil]) >> ts.write([:seki, :age, 20]) => #<Rinda::TupleEntry:...> >> TupleSpace => [:seki, :age, 20] >> :seki :age 20

46 Answering druby, Again. Scaling Twitter Rinda and DRb in the Real World mput.dip.jp Nick Sieger s blog kiwamu

47 Rinda and DRb in the Real World Glenn Vanderburg mput kiwamu

48 Rinda and DRb in the Real World Tuple SPOF RingServer ID 2004

49 Rinda and DRb in the Real World Tuple SPOF RingServer ID 2004

50 Tuple Tuple RDBMS???

51 Tuple RPC...

52 Tuple read, take === nil

53 RPC Tuple /

54 RPC Tuple

55 RPC Tuple nil (Class, Regexp, Range)

56 RPC Tuple nil

57 RPC Tuple :snapshot , 240

58 RPC Tuple :snapshot , 240 :snapshot nil nil, nil, nil

59 RPC Tuple :snapshot , 240 :snapshot nil nil, nil, nil :snapshot_done img_320_240_12345.jpg

60 RPC Tuple :snapshot , 240 :snapshot nil nil, nil, nil :snapshot_done img_320_240_12345.jpg :snapshot_done nil

61 Scaling Twitter Rinda Big Bird. (scaling twitter) Shared Queue (TupleSpace) Built with DRb RingyDingy makes it stupid easy See Eric Hodel s documentation O(N) for take(). Sigh.

62 Sigh. Shared Queue (TupleSpace) O(N) for take(). Sigh.

63 O(N) :snapshot nil nil, nil, nil O(1)?

64 O(1)? Array#delete delete_at : rindex

65 :snapshot nil nil, nil, nil Symbol String Integer === O(1)

66 a Symbol nil nil, nil, nil tuple[0] Symbol

67 Rinda ruby_1_8

68 Rinda and DRb in the Real World Tuple SPOF RingServer ID 2004

69 RubyKaigi 2006 ( ) ( )

70 TupleSpace Tuple take, read plz Ring?

72 PTupleSpace TupleSpace Tuple TupleEntry Tuple cancel Tuple TupleStore

73 TupleStore Tuple TupleStoreLog Hash TupleStoreSimple RDB

74 Application Application Application PTupleSpace TupleStore Log log Marshal

75 PTupleSpace TupleStore Log log Marshal

76 Ring

77 TupleStore PTupleSpace druby

78 Rinda and DRb in the Real World Tuple SPOF RingServer ID 2004

79 Rinda and DRb in the Real World Tuple SPOF RingServer ID 2004

80 object_id

81 DRbIdConv ID TupleEntry

82 Rinda and DRb in the Real World Tuple SPOF RingServer ID 2004

83 2004?

84 RubyKaigi 2006 Rinda and DRb in the Real World. Scaling Twitter

85 ERB ERB way

86 toruby 4h Ruby 6/23

RubyKaigi2009 COBOL

RubyKaigi2009 COBOL seki@druby.org 3360 Pragmatic Bookshelf druby Web $32.00 International Journal of PARALLEL PROGRAMING !? MapReduce Rinda (map, reduce) map reduce key value [, ] [, ID] map()