我發(fā)現(xiàn)經(jīng)常研究并且為之興奮的一件事就是對系統(tǒng)進行擴展?，F(xiàn)在這對不同的人有著不同的意思。作為移植Monolithic應用到Microservices架構(gòu)方法中的一部分，如何處理Microservices架構(gòu)是我研究RPC的原因。

RPC（或者叫做遠程進程調(diào)用）是一個已經(jīng)在計算機科學領(lǐng)域存在較長一段時間的概念。對此一種非常簡單的理解就是發(fā)送一段消息到遠程進程的能力，而不論它是在同一個系統(tǒng)上還是遠程的系統(tǒng)?？偟膩碚f這是非常模糊的，而且對許多的實現(xiàn)來說是開放的。在我看來，當談到RPC時，會有相當多的內(nèi)容可供探討，比如消息的格式，以及你怎樣將消息發(fā)送到遠程進程上。有許多的方法來實現(xiàn)RPC，而這是我采用的一種，但對這篇文章來說，我準備使用‘JSON-RPC'來處理消息的格式，用Redis來發(fā)布消息。

RPC和消息隊列

原理基本上都一樣，但是使用RPC的話，客戶端會等待一個含有RPC調(diào)用結(jié)果的返回消息。如果你的消息隊列系統(tǒng)允許你為發(fā)送者處理回調(diào)消息，那么你很可能就可以為RPC來使用它。在大多數(shù)的消息隊列中，它們被用來觸發(fā)那些不再需要回復給客戶端的任務。

為什么用Redis而不是其它的？

你應該能夠在某個地主發(fā)現(xiàn)Redis是非常先進的技術(shù)，如果你說沒有發(fā)現(xiàn)，你是怎么了？Redis對很多事情來說都是一個偉大的工具，你應該認真研究一下。學習之路能夠平坦，并且不用學習太多的新內(nèi)容，Redis都完美的符合這些想法，所以，讓我們看看我們可以干些什么。

Client

復制代碼 代碼如下:
require 'redis'
require 'securerandom'
require 'msgpack'

class RedisRpcClient

  def initialize(redis_url, list_name)
    @client = Redis.connect(url: redis_url)
    @list_name = list_name.to_s
  end

  def method_missing(name, *args)
    request = {
      'jsonrpc' => '2.0',
      'method' => name,
      'params' => args,
      'id' => SecureRandom.uuid
    }

    @client.lpush(@list_name, request.to_msgpack)
    channel, response = @client.brpop(request['id'], timeout=30)

    MessagePack.unpack(response)['result']
  end

end

client = RedisRpcClient.new('redis://localhost:6379', :fib)
(1..30).each { |i| puts client.fib(i) }

Server

復制代碼 代碼如下:
require 'redis'
require 'msgpack'

class Fibonacci

  def fib(n)
    case n
    when 0 then 0
    when 1 then 1
    else
      fib(n - 1) + fib(n - 2)
    end
  end

end

class RedisRpcServer

  def initialize(redis_url, list_name, klass)
    @client = Redis.connect(url: redis_url)
    @list_name = list_name.to_s
    @klass = klass
  end

  def start
    puts "Starting RPC server for #{@list_name}"