Python 微服务框架 Nameko 微服务通信(RabbitMQ)

1. 微服务
   1. 按通信方式分为同步通信和异步通信
   2. Nameko 属于异步通信
2. 同步通信
   1. 同步调用比较简单，一致性强，但是容易出调用问题，性能体验上也会差些。同步通信最常用的两种协议是RESTful和RPC，而目前使用最广泛，最有名的两种微服务框架Spring Cloud和Dubbo分别使用了RESTful和RPC协议。RESTful和RPC两种协议各有优势，具体使用要看业务场景。Dubbo框架是一个非常流行的采用同步通信的分布式微服务框架
   2. 首先一个微服务应用程序需要有服务的生产者和服务的消费者，另外还需要一个注册中心（常见的有zookeeper和rabbitmq等）来管理和调度服务。微服务架构的程序运行的一般步骤为：
   3. 1. 服务提供方，即生产者启动服务，并将服务提交到注册中心注册服务
      2. 服务需求方，即消费者连接到注册中心，向注册中心发出请求，申请需要的服务
      3. 注册中心根据消费者发出的请求来调度服务，将对应的服务提供者（生产者）的信息发送给消费者
      4. 消费者和生产者之间建立连接，消费者调用服务
      5. 记录服务调用过程中的信息
3. 异步通信
   1. 异步通信一般通过消息中间件来进行服务间通信，消息中间件能为调用之间提供的缓冲，确保消息积压不会冲垮被调用方，同时能保证调用方的服务体验，继续干自己该干的活，不至于被后台性能拖慢。不过需要付出的代价是一致性的减弱。
   2. nameko框架就是一个采用异步通信方式的微服务框架，采用RabbitMQ消息队列作为消息中间件，原理非常简单，使用起来也很方便。
4. 
5. 安装注册中心
   1. nameko采用RabbitMQ作为注册中心，所以使用nameko必须要先安装RabbitMQ
   2. 以docker容器的方式运行RabbitMQ是最为简便快捷的方式，两行命令就搞定了，这里介绍如何使用docker运行RabbitMQ
      1. 第一步：从DockerHub拉取rabbitmq镜像  docker pull rabbitmq:management
   3. 第二步：运行RabbitMQ容器

      docker run -d --hostname my-rabbit --name rabbit -p 15672:15672 -p 5672:5672 rabbitmq:management

   4. .如果需要设置用户名和密码，则使用这条命令　　

      1. docker run -d --hostname my-rabbit --name rabbit -e RABBITMQ_DEFAULT_USER=user -e RABBITMQ_DEFAULT_PASS=password -p 15672:15672 -p 5672:5672 rabbitmq:management

   5. 　我运行容器时没有设置用户名和密码，所以使用用户名guest，密码guest登录。http://localhost:15672/
   6. 登录成功 ，界面
      1. 
   7. 发布服务，将服务注册到Nameko

      1. from nameko.rpc import rpc
         
         class hello_service:
             name = "hello_service"
         
             @rpc
             def hello(self):
                 print("hello world")

   8. 调用服务的消费者

      1. from nameko.standalone.rpc import ClusterRpcProxy
         
         CONFIG = {'AMQP_URI': "amqp://guest:guest@192.168.110.129"}
         
         
         def compute():
             with ClusterRpcProxy(CONFIG) as rpc:
                 rpc.hello_service.hello()
         
         
         if __name__ == '__main__':
             compute()

   9. 生产者微服务启动
      1. 使用nameko框架的run命令启动微服务

         nameko run producer.py --broker amqp://guest:guest@192.168.110.129

      2. 如果服务正常启动
         1. 

         2. 运行了消费者 服务器后

            1. 

            2. 生产者的函数被消费者调用
6. 案例二，通过Nameko 实现微服务通信
7. 安装环境 
   1. pip install nameko
   2. pip install yagmail