我發(fā)現(xiàn)經(jīng)常研究并且為之興奮的一件事就是對(duì)系統(tǒng)進(jìn)行擴(kuò)展?，F(xiàn)在這對(duì)不同的人有著不同的意思。作為移植Monolithic應(yīng)用到Microservices架構(gòu)方法中的一部分，如何處理Microservices架構(gòu)是我研究RPC的原因。
RPC（或者叫做遠(yuǎn)程進(jìn)程調(diào)用）是一個(gè)已經(jīng)在計(jì)算機(jī)科學(xué)領(lǐng)域存在較長(zhǎng)一段時(shí)間的概念。對(duì)此一種非常簡(jiǎn)單的理解就是發(fā)送一段消息到遠(yuǎn)程進(jìn)程的能力，而不論它是在同一個(gè)系統(tǒng)上還是遠(yuǎn)程的系統(tǒng)?？偟膩?lái)說(shuō)這是非常模糊的，而且對(duì)許多的實(shí)現(xiàn)來(lái)說(shuō)是開(kāi)放的。在我看來(lái)，當(dāng)談到RPC時(shí)，會(huì)有相當(dāng)多的內(nèi)容可供探討，比如消息的格式，以及你怎樣將消息發(fā)送到遠(yuǎn)程進(jìn)程上。有許多的方法來(lái)實(shí)現(xiàn)RPC，而這是我采用的一種，但對(duì)這篇文章來(lái)說(shuō)，我準(zhǔn)備使用‘JSON-RPC'來(lái)處理消息的格式，用Redis來(lái)發(fā)布消息。
RPC和消息隊(duì)列
原理基本上都一樣，但是使用RPC的話(huà)，客戶(hù)端會(huì)等待一個(gè)含有RPC調(diào)用結(jié)果的返回消息。如果你的消息隊(duì)列系統(tǒng)允許你為發(fā)送者處理回調(diào)消息，那么你很可能就可以為RPC來(lái)使用它。在大多數(shù)的消息隊(duì)列中，它們被用來(lái)觸發(fā)那些不再需要回復(fù)給客戶(hù)端的任務(wù)。
為什么用Redis而不是其它的？
你應(yīng)該能夠在某個(gè)地主發(fā)現(xiàn)Redis是非常先進(jìn)的技術(shù)，如果你說(shuō)沒(méi)有發(fā)現(xiàn)，你是怎么了？Redis對(duì)很多事情來(lái)說(shuō)都是一個(gè)偉大的工具，你應(yīng)該認(rèn)真研究一下。學(xué)習(xí)之路能夠平坦，并且不用學(xué)習(xí)太多的新內(nèi)容，Redis都完美的符合這些想法，所以，讓我們看看我們可以干些什么。
Client
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
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
確是如此，它能工作是因?yàn)楫?dāng)你等待數(shù)據(jù)從服務(wù)器傳回來(lái)時(shí)，Redis有命令能夠讓你阻塞等待。這是非常優(yōu)秀的做法，它讓你的客戶(hù)端代碼看上去像是在調(diào)用本地方法。
Ruby 相當(dāng)酷，可是。。。
如果你想用其它語(yǔ)言怎么辦？沒(méi)問(wèn)題，只要你的語(yǔ)言有很好的Redis庫(kù)，你就可以做同樣的事。讓我們瞧一瞧用Python來(lái)建立一個(gè)服務(wù)端程序。
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é)論
這很好的證明了你頭腦中的一些想法，當(dāng)然，還需要更多的工作來(lái)處理異常。如果你用這個(gè)方法遇到任何的問(wèn)題，我樂(lè)意幫助你。我的確希望在同樣想法的一此地方使用RabbitMQ，但如果你已經(jīng)在你的項(xiàng)目中使用了Redis，這將會(huì)是一個(gè)非常不錯(cuò)的方法。
新聞熱點(diǎn)
疑難解答
圖片精選
網(wǎng)友關(guān)注
