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

 更新时间:2014年09月02日 08:50:28   投稿:junjie  
这篇文章主要介绍了通过 Redis 实现 RPC 远程方法调用,支持多种编程语言,本文就以Ruby和Python为例,给出了实现代码,需要的朋友可以参考下
(福利推荐:【腾讯云】服务器最新限时优惠活动,云服务器1核2G仅99元/年、2核4G仅768元/3年,立即抢购>>>:9i0i.cn/qcloud

(福利推荐:你还在原价购买阿里云服务器?现在阿里云0.8折限时抢购活动来啦!4核8G企业云服务器仅2998元/3年,立即抢购>>>:9i0i.cn/aliyun

我发现经常研究并且为之兴奋的一件事就是对系统进行扩展。现在这对不同的人有着不同的意思。作为移植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}"
    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,这将会是一个非常不错的方法。

相关文章

  • Redis实现库存扣减的解决方案防止商品超卖

    Redis实现库存扣减的解决方案防止商品超卖

    在日常开发中有很多地方都有类似扣减库存的操作,比如电商系统中的商品库存,抽奖系统中的奖品库存等,基于redis实现扣减库存的具体实现,初始化库存回调函数(IStockCallback)扣减库存服务(StockService),感兴趣的朋友跟随小编一起看看吧
    2022-06-06
  • redis批量操作pipeline管道操作方法

    redis批量操作pipeline管道操作方法

    Redis本身是基于一个Request一个Response方式的同步请求,正常情况下,客户端发送一个命令,这篇文章主要介绍了redis批量操作pipeline管道,需要的朋友可以参考下
    2022-09-09
  • Redis?sentinel哨兵集群的实现步骤

    Redis?sentinel哨兵集群的实现步骤

    本文主要介绍了Redis?sentinel哨兵集群的实现步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-07-07
  • Redis简易延时队列的实现示例

    Redis简易延时队列的实现示例

    在实际的业务场景中,经常会遇到需要延时处理的业务,本文就来介绍有下Redis简易延时队列的实现示例,具有一定的参考价值,感兴趣的可以了解一下
    2023-12-12
  • Redis处理高并发之布隆过滤器详解

    Redis处理高并发之布隆过滤器详解

    这篇文章主要为大家介绍了Redis处理高并发之布隆过滤器详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-12-12
  • 为Java项目添加Redis缓存的方法

    为Java项目添加Redis缓存的方法

    Redis一般有Linux和Windows两种安装方式,本文就这两种方式给大家详细介绍,对java项目添加redis缓存相关知识,感兴趣的朋友一起看看吧
    2021-05-05
  • Redis的持久化详解

    Redis的持久化详解

    Redis是一个基于内存的数据库,它的数据是存放在内存中,内存有个问题就是关闭服务或者断电会丢失,Redis的数据也支持写到硬盘中,这个过程就叫做持久化,文中有详细的图介绍,需要的朋友可以参考下
    2023-06-06
  • 一文详解Redis中的持久化

    一文详解Redis中的持久化

    这篇文章主要介绍了一文详解Redis中的持久化,持久化功能有效地避免因进程退出造成的数据丢失问题,当下次重启时利用之前持久化的文件即可实现数据恢复
    2022-09-09
  • Redis分布式锁一定要避开的两个坑

    Redis分布式锁一定要避开的两个坑

    这篇文章主要为大家详细介绍了Redis中分布式锁一定要避开的两个坑以及对应的解决方法,文中的示例代码讲解详细,希望对大家有所帮助
    2023-04-04
  • Redis中实现查找某个值的范围

    Redis中实现查找某个值的范围

    这篇文章主要介绍了Redis中实现查找某个值的范围,本文的题引来了Redis作者Salvatore Sanfilippo(@antirez)的回答,比较经典,需要的朋友可以参考下
    2015-06-06

最新评论

?


http://www.vxiaotou.com