当前位置 主页 > 服务器问题 > win服务器问题汇总 >

    通过 Redis 实现 RPC 远程方法调用(支持多种编程语言)

    栏目:win服务器问题汇总 时间:2020-02-02 19:33

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

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

    RPC和消息队列

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

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

    你应该能够在某个地主发现Redis是非常先进的技术,如果你说没有发现,你是怎么了?Redis对很多事情来说都是一个伟大的工具,你应该认真研究一下。学习之路能够平坦,并且不用学习太多的新内容,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}"