Python微服务框架Nameko | python 小知识

1. 微服务介绍

微服务架构是一种将应用程序拆分为多个小型服务的方法，每个服务都可以独立开发、部署和扩展。这种架构使得应用程序更加模块化、可维护和可扩展。微服务架构的核心在于服务间的通信，主要有同步通信（如RESTful和RPC）和异步通信（如消息中间件）两种方式。

典型的微服务架构有高性能的Java RPC框架Dubbo和Spring Cloud。

请添加图片描述

2. Nameko简介

Nameko是一个用于构建分布式系统的Python库，它提供了一种简单而灵活的方式来构建微服务。Nameko支持将应用程序拆分为多个小型服务，每个服务都可以独立运行和扩展。它使用RPC（远程过程调用）作为服务之间的通信机制，支持异步通信和事件驱动的编程模型。

请添加图片描述

3. Nameko安装

Nameko可以通过pip安装，也可以使用源码安装。以下是使用pip安装的步骤：

pip install nameko

Nameko 的多个内置功能依赖于 RabbitMQ，RabbitMQ是一个基于AMQP（Advanced Message Queuing Protocol，高级消息队列协议）实现的开源消息代理软件，也可以称作面向消息的中间件。在AMQP模型中，消息在Producer中产生，发送到MQ的Exchange上，Exchange根据配置的路由方式发到相应的Queue上，Queue又将消息发送给Consumer。消息从Queue到Consumer有push和pull两种方式

安装RabbitMQ十分的简单，可以直接通过docker进行部署

# latest RabbitMQ 4.0.x
docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:4.0-management

4. 创建并运行第一个Nameko服务

4.1 创建服务文件

在你的工作目录下，新建一个Python文件（例如hello_service.py），并添加以下代码：

from nameko.rpc import rpc

class HelloService:
    name = "hello_service"

    @rpc
    def say_hello(self, name):
        return f"Hello, {name}!"

4.2 运行服务

在终端中定位到该文件所在的目录，并执行以下命令来启动服务：

nameko run hello_service

此时，Nameko将启动服务并监听特定的AMQP队列，等待接收RPC请求。

5. 测试Nameko服务

你可以使用Nameko自带的客户端工具或自定义客户端代码来测试服务。以下是一个简单的测试方法：

from nameko.standalone.rpc import ClusterRpcProxy

config = {
    'AMQP_URI': 'amqp://guest:guest@localhost//'  # RabbitMQ默认配置
}

with ClusterRpcProxy(config) as rpc:
    print(rpc.hello_service.say_hello('World'))

这段代码将连接到RabbitMQ并通过RPC调用say_hello方法，打印出结果。

6. 服务间的依赖注入

微服务之间经常需要互相调用，Nameko提供了一种优雅的方式来管理服务间的依赖——依赖注入。以下是一个示例：

from nameko.rpc import rpc, RpcProxy

class GreetingService:
    name = "greeting_service"

    @rpc
    def hello(self):
        return "Hello, Nameko!"

class UserService:
    name = "user_service"
    greeting_rpc = RpcProxy("greeting_service")

    @rpc
    def get_greeting(self):
        return self.greeting_rpc.hello()

在这个例子中，UserService通过RpcProxy注入了greeting_service，可以直接调用它的hello方法。

7. 事件监听与异步通信

除了RPC调用，Nameko还支持事件监听，实现异步通信。以下是一个示例：

from nameko.events import EventDispatcher, event_handler

class UserService:
    name = "user_service"
    dispatch = EventDispatcher()

    @rpc
    def create_user(self, username):
        self.dispatch("user_created", username)
        return "User created!"

class MailService:
    name = "mail_service"

    @event_handler("user_service", "user_created")
    def send_welcome_email(self, username):
        print(f"Sending welcome email to {username}...")