python微服务框架Nameko

Nameko介绍

Nameko 是一款小巧、简洁的、异步通信方式的微服务架构

消费者与生产者基于 RPC 进行通讯

安装rabbitmq

nameko采用RabbitMQ作为注册中心,所以使用nameko必须要先安装RabbitMQ。

安装略过。

生产者与消费者

发布服务

新建hello_service.py发布服务,服务名称为“hello_service”

from nameko.rpc import rpc

class hello_service:
    name = "hello_service"

    @rpc
    def hello(self):
        print("hello world")

调用服务

新建client.py调用服务

from nameko.standalone.rpc import ClusterRpcProxy

CONFIG = {'AMQP_URI': "amqp://admin:admin@192.168.99.100"}


def compute():
    with ClusterRpcProxy(CONFIG) as rpc:
        rpc.hello_service.hello()


if __name__ == '__main__':
    compute()

测试

安装依赖库

pip3 install nameko

启动微服务

nameko run hello_service --broker amqp://admin:admin@192.168.99.100

启动client程序

pyhon client.py

可以看到服务端打印hello world

评论

Your browser is out-of-date!

Update your browser to view this website correctly. Update my browser now

×