jsuchy-20080211-0.txt

Blog Title:  Rinda 101
Author:      Jim Suchy
Date:        February 11th, 2008

jsuchy-20080211-1.rb

require "rinda/tuplespace"

port = 4000
ts = Rinda::TupleSpace.new
DRb.start_service("druby://:#{port}", ts)
puts "Rinda listening on #{DRb.uri}..."
DRb.thread.join

jsuchy-20080211-2.sh

$ ruby server.rb

jsuchy-20080211-3.rb

require "rinda/rinda"
include Rinda

port = 4000
ts = DRbObject.new(nil, "druby://:#{port}")

while message = gets
  begin
    args = message.split(" ")
    method = args.shift.to_sym
    topic = args.shift.to_sym
    message = args.shift
    message = nil if message == "nil"
    tuple = [topic, message]

    puts ts.send(method, tuple)
  rescue Exception => e
    puts e.message
  end
end

jsuchy-20080211-4.sh

$ ruby client.rb

jsuchy-20080211-5.sh

write message hello
    Rinda::TupleEntry:0x4f998

write message world
    Rinda::TupleEntry:0x4cfa4

read message nil
    message
    hello

take message nil
    message
    hello

take message nil
    message
    world

jsuchy-20080211-6.rb

ts.write([:message, "hello"]) => Rinda::TupleEntry:0x4f998
ts.write([:message, "world"]) => Rinda::TupleEntry:0x4cfa4
ts.read([:message, nil]) => "hello"
ts.take([:message, nil]) => "hello"
ts.take([:message, nil]) => "world"

jsuchy-20080211-7.sh

1) [:message]
2) [:message, "hello"]
3) [:message, "hello", "world"]