0

根据关于调用远程 RPC的最后一个问题，文档中包含的另一个示例是这个：

$ 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 部分——这样做是为了避免使用反向代理并处理端口号-)。

在 Nameko 中，如何在注册微服务时启动远程过程？正如上面帖子的答案中提到的，远程 RPC 调用不能在 @rpc 方法之外完成。

4

2 回答 2

0

使用一次入口点

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 True
于 2018-12-05T08:12:02.320 回答
0

实际上，这里回答的独立代理是实现此目的的方法：

Nameko - 从另一个服务调用 RPC 方法

于 2017-12-16T01:42:05.683 回答