根据最后一个问题about invoking remote RPCs,文档中包含的另一个示例如下所示:
$ cat nameko.sh
#!/bin/bash
/usr/local/bin/nameko run service1:Microservice1 &
nameko_id=$!
echo 'Microservice 1 PID: ' $nameko_id
/usr/local/bin/nameko run service2:Microservice2 &
nameko_id=$!
echo 'Microservice 2 PID: ' $nameko_id
wait 2> /dev/null
$ cat service1.py
# -*- coding: utf-8 -*-
from nameko.rpc import rpc, RpcProxy
class Microservice1(object):
name = "microservice1"
@rpc
def hello(self):
print 'Microservice1 hello method invoked'
return True
$ cat service2.py
# -*- coding: utf-8 -*-
from nameko.rpc import rpc, RpcProxy
class Microservice2(object):
name = "microservice2"
microservice1 = RpcProxy('microservice1')
@rpc
def remote_hello(self):
print 'Microservice2 invokes hello method from Microservice1'
self.microservice1.hello()
return True我正在尝试构建一个架构,其中微服务在启动时向中央微服务注册自己(基本上,这个中央微服务负责显示REST API,其中每个微服务处理自己的REST API -this部分,以避免使用反向代理并处理端口号-)。
在Nameko中,如何在注册微服务时启动远程过程?正如在上面的帖子答案中所提到的,远程RPC调用不能在@rpc方法之外完成。
发布于 2017-12-16 09:42:06
实际上,这里回答的独立代理是实现这一点的方法:
发布于 2018-12-05 16:12:02
使用一次入口点
from nameko.testing.service import once
class Microservice2(object):
name = "microservice2"
microservice1 = RpcProxy('microservice1')
@rpc
def remote_hello(self):
print 'Microservice2 invokes hello method from Microservice1'
self.microservice1.hello()
return Truehttps://stackoverflow.com/questions/47832836
复制相似问题