Ruby Tutorial
Introduction
All Apache Thrift tutorials require that you have:
- Built and installed the Apache Thrift Compiler and Libraries, see Building from source for more details.
-
thrift -r --gen rb tutorial.thrift
- Followed all prerequisites listed below.
Prerequisites
Client
$:.push('gen-rb') $:.unshift '../../lib/rb/lib' require 'thrift' require 'calculator' begin port = ARGV[0] || 9090 transport = Thrift::BufferedTransport.new(Thrift::Socket.new('localhost', port)) protocol = Thrift::BinaryProtocol.new(transport) client = Calculator::Client.new(protocol) transport.open() client.ping() print "ping()\n" sum = client.add(1,1) print "1+1=", sum, "\n" sum = client.add(1,4) print "1+4=", sum, "\n" work = Work.new() work.op = Operation::SUBTRACT work.num1 = 15 work.num2 = 10 diff = client.calculate(1, work) print "15-10=", diff, "\n" log = client.getStruct(1) print "Log: ", log.value, "\n" begin work.op = Operation::DIVIDE work.num1 = 1 work.num2 = 0 quot = client.calculate(1, work) puts "Whoa, we can divide by 0 now?" rescue InvalidOperation => io print "InvalidOperation: ", io.why, "\n" end client.zip() print "zip\n" transport.close() rescue Thrift::Exception => tx print 'Thrift::Exception: ', tx.message, "\n" end
Server
$:.push('gen-rb') $:.unshift '../../lib/rb/lib' require 'thrift' require 'calculator' require 'shared_types' class CalculatorHandler def initialize() @log = {} end def ping() puts "ping()" end def add(n1, n2) print "add(", n1, ",", n2, ")\n" return n1 + n2 end def calculate(logid, work) print "calculate(", logid, ", {", work.op, ",", work.num1, ",", work.num2,"})\n" if work.op == Operation::ADD val = work.num1 + work.num2 elsif work.op == Operation::SUBTRACT val = work.num1 - work.num2 elsif work.op == Operation::MULTIPLY val = work.num1 * work.num2 elsif work.op == Operation::DIVIDE if work.num2 == 0 x = InvalidOperation.new() x.whatOp = work.op x.why = "Cannot divide by 0" raise x end val = work.num1 / work.num2 else x = InvalidOperation.new() x.whatOp = work.op x.why = "Invalid operation" raise x end entry = SharedStruct.new() entry.key = logid entry.value = "#{val}" @log[logid] = entry return val end def getStruct(key) print "getStruct(", key, ")\n" return @log[key] end def zip() print "zip\n" end end handler = CalculatorHandler.new() processor = Calculator::Processor.new(handler) transport = Thrift::ServerSocket.new(9090) transportFactory = Thrift::BufferedTransportFactory.new() server = Thrift::SimpleServer.new(processor, transport, transportFactory) puts "Starting the server..." server.serve() puts "done."
No comments:
Post a Comment