Ruby and Python samples of MessagePack-RPC.

.gitignore

Gemfile.lock

README.md

A sample code of msgpack-rpc.

Setup

• for Ruby

bundle

• for Python

pip install msgpack-rpc-python

Run the sample

ruby server.rb

In another terminal,

ruby client.rb

Using python client,

python client.py

Call matplotlib func from Ruby

python plot_server.py

ruby plot_client.rb

Get Rails object from Python

ruby rails_server.rb

python rails_client.py

async_client.py

import msgpackrpc

client = msgpackrpc.Client(msgpackrpc.Address("localhost", 18800), unpack_encoding='utf-8')
future = client.call_async('delayed_add', 3, 1, 2)
print( future.get() )

async_client.rb

require 'msgpack/rpc'
c = MessagePack::RPC::Client.new('localhost',18800)

puts "async call"
future = c.call_async(:delayed_add, 1, 1, 2)
result = future.get
puts result

puts "sync call"
result = c.call(:delayed_add, 1, 1, 2)
puts result

puts "call_async is called against a synchronous method"
future = c.call_async(:add, 1, 2)
puts future.get

client.py

import msgpackrpc

client = msgpackrpc.Client(msgpackrpc.Address("localhost", 18800), unpack_encoding='utf-8')
result = client.call('add', 1, 2)
print( result )

result = client.call('hello')
print( result )

client.rb

require 'msgpack/rpc'
c = MessagePack::RPC::Client.new('localhost',18800)
result = c.call(:add, 1, 2)
puts result

puts c.call(:hello)

Gemfile

oacis = ENV['OACIS_ROOT']
unless oacis
  $stderr.puts "set environment variable 'OACIS_ROOT'"
  exit 1
end

eval_gemfile File.join( oacis, "Gemfile")

gem 'msgpack-rpc'

plot_client.rb

require 'msgpack/rpc'
c = MessagePack::RPC::Client.new('localhost',18800)
c.timeout = Float::INFINITY

xs = -3.14.step(3.14, 0.1).to_a
ys = xs.map {|x| Math.sin(x) }
c.call( :scatter, xs, ys )

plot_server.py

import msgpackrpc
import matplotlib.pyplot as plt
import numpy as np

class MyPlot(object):

    def scatter(self, x, y):
        plt.scatter(x,y)
        plt.show()

svr = msgpackrpc.Server( MyPlot(), unpack_encoding='utf-8' )
svr.listen( msgpackrpc.Address('localhost',18800) )
svr.start()

rails_client.py

import msgpackrpc

client = msgpackrpc.Client(msgpackrpc.Address("localhost", 18800), unpack_encoding='utf-8')
result = client.call('get_id', 'echo')
print( result )

result = client.call('get_sim', 'echo')
print( result )
print( result['name'] )

rails_server.rb

require 'msgpack/rpc'
require File.join( ENV['OACIS_ROOT'], 'config/environment' )

Object.class_eval do
  def to_msgpack(*args)
    to_s.to_msgpack(*args)
  end
end

class MyRailsHandler
  def get_id(name)
    Simulator.where(name: name).first.id
  end

  def get_sim(name)
    Simulator.where(name: name).first.as_json
  end
end

svr = MessagePack::RPC::Server.new
svr.listen('localhost', 18800, MyRailsHandler.new)
svr.run

server.py

import msgpackrpc
import threading, time

class MyHandler(object):

    def add(self, x, y):
        return x+y

    def delayed_add(self, t, x, y):
        print("delayed_add is called")
        ar = msgpackrpc.server.AsyncResult()
        def sleep_add():
            time.sleep(t)
            ar.set_result(x+y)
        thread = threading.Thread(target=sleep_add)
        thread.start()
        return ar

    def hello(self):
        return "hello"

svr = msgpackrpc.Server( MyHandler(), unpack_encoding='utf-8' )
svr.listen( msgpackrpc.Address('localhost',18800) )
svr.start()

server.rb

require 'msgpack/rpc'

class MyHandler
  def add(x,y)
    return x+y
  end

  def delayed_add(t,x,y)
    puts "delayed_add is called"
    as = MessagePack::RPC::AsyncResult.new
    Thread.new do
      sleep t
      as.result(x+y)
    end
    as
  end

  def hello
    "hello"
  end
end
svr = MessagePack::RPC::Server.new
svr.listen('localhost', 18800, MyHandler.new)
svr.run