通過 Redis 實現(xiàn) RPC 遠程方法調(diào)用(支持多種編程語言)
來源:易賢網(wǎng) 閱讀:1626 次 日期:2015-04-14 14:40:33
溫馨提示:易賢網(wǎng)小編為您整理了“通過 Redis 實現(xiàn) RPC 遠程方法調(diào)用(支持多種編程語言)”,方便廣大網(wǎng)友查閱!

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

RPC(或者叫做遠程進程調(diào)用)是一個已經(jīng)在計算機科學(xué)領(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ā)那些不再需要回復(fù)給客戶端的任務(wù)。

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

你應(yīng)該能夠在某個地主發(fā)現(xiàn)Redis是非常先進的技術(shù),如果你說沒有發(fā)現(xiàn),你是怎么了?Redis對很多事情來說都是一個偉大的工具,你應(yīng)該認真研究一下。學(xué)習之路能夠平坦,并且不用學(xué)習太多的新內(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 }"

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

確是如此,它能工作是因為當你等待數(shù)據(jù)從服務(wù)器傳回來時,Redis有命令能夠讓你阻塞等待。這是非常優(yōu)秀的做法,它讓你的客戶端代碼看上去像是在調(diào)用本地方法。

Ruby 相當酷,可是。。。

如果你想用其它語言怎么辦?沒問題,只要你的語言有很好的Redis庫,你就可以做同樣的事。讓我們瞧一瞧用Python來建立一個服務(wù)端程序。

代碼如下:

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()

結(jié)論

這很好的證明了你頭腦中的一些想法,當然,還需要更多的工作來處理異常。如果你用這個方法遇到任何的問題,我樂意幫助你。我的確希望在同樣想法的一此地方使用RabbitMQ,但如果你已經(jīng)在你的項目中使用了Redis,這將會是一個非常不錯的方法。

更多信息請查看IT技術(shù)專欄

更多信息請查看數(shù)據(jù)庫
由于各方面情況的不斷調(diào)整與變化,易賢網(wǎng)提供的所有考試信息和咨詢回復(fù)僅供參考,敬請考生以權(quán)威部門公布的正式信息和咨詢?yōu)闇剩?/div>

2025國考·省考課程試聽報名

  • 報班類型
  • 姓名
  • 手機號
  • 驗證碼
關(guān)于我們 | 聯(lián)系我們 | 人才招聘 | 網(wǎng)站聲明 | 網(wǎng)站幫助 | 非正式的簡要咨詢 | 簡要咨詢須知 | 加入群交流 | 手機站點 | 投訴建議
工業(yè)和信息化部備案號:滇ICP備2023014141號-1 云南省教育廳備案號:云教ICP備0901021 滇公網(wǎng)安備53010202001879號 人力資源服務(wù)許可證:(云)人服證字(2023)第0102001523號
聯(lián)系電話:0871-65099533/13759567129 獲取招聘考試信息及咨詢關(guān)注公眾號:hfpxwx
咨詢QQ:526150442(9:00—18:00)版權(quán)所有:易賢網(wǎng)