php调用nameko接口,nameko的RPC调用~nameko系列之二

nameko的设计与python语言所追求的简明快捷同出一辙。

微服务的框架很多，thrift就是非常出色的一款。thrift是跨语言的。基于thrift的python的代码实现可以参照 https://www.jianshu.com/p/82a6bdaabcd3 这个链接

针对上面的链接小结一下：

1、需要新建一个thrift格式的接口文件

2、对接口文件进行处理，将其变为py文件

3、开发client

4、开发server

对比前一篇文章，可以看出来基于thrift的开发还是不那么直接。

nameko之所以简单，就是没有重复造轮子，它将rabbitmq这个超级消息解决方案纳入其中。所有的微服务都是假设在这个消息队列上的一个插件。a服务想要调用b服务，只需要像调用本地的函数一样：

result = rpc.greeting_service.hello(name="jerry")

就ok

没有必要再去建立socket连接。

这样有个好处就是，可以将所有的微服务，作为功能，挂接在rabbitmq上，供别人调用，做到了功能的复用。

说到功能复用，对于团队开发软件项目而言，这已经完全超越了之前的代码复用，具备非常大的好处：不同的业务应用，可以由不同的微服务构建而来，这些微服务可能是之前开发过的，只要交互的信息相同，完全不用再次开发，或者将代码复制过来进行重新修订。如果不好用，完全可以基于原来的微服务进行迭代升级。

nameko的文档不完善，开发人员有时候懒得编写文档，可以理解，但是好在可以从源代码中找到若干信息。

RPCdiao'yo这是nameko存在的最核心的功能。

这里有两个问题：

1、如何定义有个微服务，供别人调用

2、如何调用已经开发好的微服务

第一个问题，前面已经有描述，就是采用装饰器的方式，定义某个方法可以作为微服务被调用。

from nameko.rpc import rpc

class GreetingService:

name = "greeting_service"

@rpc

def hello(self, name):

return "Hello, {}!".format(name)

说明：

a、微服务放在一个类中，

b、为这个微服务要起一个名称，

c、通过@rpc这个装饰器，将微服务进行注册即可。

第二个问题，调用.

有两种方案:

第一种是rpc的调用方法，也就是一个rpc方法内部再调用一个rpc方法

from nameko.rpc import rpc, RpcProxy

class ServiceY:

name = "service_y"

@rpc

def append_identifier(self, value):

return u"{}-y".format(value)

class ServiceX:

name = "service_x"

y = RpcProxy("service_y")

@rpc

def remote_method(self, value):

res = u"{}-x".format(value)

return self.y.append_identifier(res)

说明:

1、再ServiceY中定义了 一个rpc的方法，然后这个方法供ServiceX调用；在ServiceX中定义了remote_method这样一个rpc方法，在这个方法中调用了ServiceY中定义的rpc方法；

第二种是外部rpc的调用，也就是在方法前面没有将@rpc装饰器的调用方法

from flask import Flask, request

from nameko.standalone.rpc import ClusterRpcProxy

app = Flask(__name__)

CONFIG = {'AMQP_URI': "amqp://guest:guest@localhost"}

@app.route('/hello', methods=['POST'])

def hello():

with ClusterRpcProxy(CONFIG) as rpc:

result = rpc.greeting_service.hello(name="jerry")

return result, 200

app.run(debug=True)

说明：

1、这是一个独立的非RPC的服务，单独采用flask运行。当然你可以 使用任何方式运行service，比如使用nameko自己的方式。参见系列三中的内容。

2、使用clusterRpcProxy与rabbitmq连接在一起，并调用远程的方法。