通过Redis实现RPC远程方法调用

我发现经常研究并且为之兴奋的通过一件事就是对系统进行扩展。现在这对不同的远程人有着不同的意思。作为移植Monolithic应用到Microservices架构方法中的调用一部分,如何处理Microservices架构是通过我研究RPC的原因。  

RPC(或者叫做远程进程调用)是远程一个已经在计算机科学领域存在较长一段时间的概念。对此一种非常简单的调用理解就是发送一段消息到远程进程的能力,而不论它是通过在同一个系统上还是远程的系统。总的远程来说这是非常模糊的,而且对许多的调用实现来说是开放的。在我看来,通过当谈到RPC时,远程会有相当多的调用内容可供探讨,服务器托管比如消息的通过格式,以及你怎样将消息发送到远程进程上。远程有许多的调用方法来实现RPC,而这是我采用的一种,但对这篇文章来说,我准备使用‘JSON-RPC’来处理消息的格式,用Redis来发布消息。

通过Redis实现RPC远程方法调用

RPC和消息队列

原理基本上都一样,但是使用RPC的话,客户端会等待一个含有RPC调用结果的返回消息。如果你的消息队列系统允许你为发送者处理回调消息,那么你很可能就可以为RPC来使用它。在大多数的消息队列中,它们被用来触发那些不再需要回复给客户端的任务。

通过Redis实现RPC远程方法调用

为什么用Redis而不是其它的?

你应该能够在某个地主发现Redis是非常先进的技术,如果你说没有发现,你是怎么了?Redis对很多事情来说都是网站模板一个伟大的工具,你应该认真研究一下。学习之路能够平坦,并且不用学习太多的新内容,Redis都完美的符合这些想法,所以,让我们看看我们可以干些什么。

通过Redis实现RPC远程方法调用

Code

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}"     while true       channel, request = @client.brpop(@list_name)        request = MessagePack.unpack(request)        puts "Working on request: #{ request[id]}"       args = request[params].unshift(request[method])        result = @klass.send *args        reply = {          jsonrpc => 2.0,          result => result,          id => request[id]        }        @client.rpush(request[id], MessagePack.pack(reply))        @client.expire(request[id], 30)      end   end end RedisRpcServer.new(redis://localhost:6379, :fib,  Fibonacci.new).start

确是如此,它能工作是因为当你等待数据从服务器传回来时,Redis有命令能够让你阻塞等待。这是非常优秀的做法,它让你的客户端代码看上去像是在调用本地方法。

Ruby 相当酷,可是。。。

如果你想用其它语言怎么办?没问题,只要你的语言有很好的Redis库,你就可以做同样的事。让我们瞧一瞧用Python来建立一个服务端程序。云服务器

import redis  import msgpack  class Fibonacci:    def fib(self,n):      if n == 0:        return 0      elif n == 1:        return 1      else:        return self.fib(n-1) + self.fib(n-2)  class RedisRpcServer:    def __init__(self, redis_url, list_name, klass):      self.client = redis.from_url(redis_url)      self.list_name = list_name      self.klass = klass    def start(self):      print("Starting RPC server for " + self.list_name)      while True:        channel, request = self.client.brpop(fib)        request = msgpack.unpackb(request, encoding=utf-8)        print("Working on request: " + request[id])        result = getattr(self.klass, request[method])(*request[params])        reply = {          jsonrpc: 2.0,          result: result,          id: request[id]        }        self.client.rpush(request[id], msgpack.packb(reply, use_bin_type=True))        self.client.expire(request[id], 30)  RedisRpcServer(redis://localhost:6379, fib, Fibonacci()).start()

结论

这很好的证明了你头脑中的一些想法,当然,还需要更多的工作来处理异常。如果你用这个方法遇到任何的问题,我乐意帮助你。我的确希望在同样想法的一此地方使用RabbitMQ,但如果你已经在你的项目中使用了Redis,这将会是一个非常不错的方法。

英文原文:RPC using Redis

译文链接:http://www.oschina.net/translate/rpc-using-redis

滇ICP备2023000592号-31