- 微服务
- 按通信方式分为同步通信和异步通信
- Nameko 属于异步通信
- 同步通信
- 同步调用比较简单,一致性强,但是容易出调用问题,性能体验上也会差些。同步通信最常用的两种协议是RESTful和RPC,而目前使用最广泛,最有名的两种微服务框架Spring Cloud和Dubbo分别使用了RESTful和RPC协议。RESTful和RPC两种协议各有优势,具体使用要看业务场景。Dubbo框架是一个非常流行的采用同步通信的分布式微服务框架
- 首先一个微服务应用程序需要有服务的生产者和服务的消费者,另外还需要一个注册中心(常见的有zookeeper和rabbitmq等)来管理和调度服务。微服务架构的程序运行的一般步骤为:
- 服务提供方,即生产者启动服务,并将服务提交到注册中心注册服务
- 服务需求方,即消费者连接到注册中心,向注册中心发出请求,申请需要的服务
- 注册中心根据消费者发出的请求来调度服务,将对应的服务提供者(生产者)的信息发送给消费者
- 消费者和生产者之间建立连接,消费者调用服务
- 记录服务调用过程中的信息
- 异步通信
- 异步通信一般通过消息中间件来进行服务间通信,消息中间件能为调用之间提供的缓冲,确保消息积压不会冲垮被调用方,同时能保证调用方的服务体验,继续干自己该干的活,不至于被后台性能拖慢。不过需要付出的代价是一致性的减弱。
- nameko框架就是一个采用异步通信方式的微服务框架,采用RabbitMQ消息队列作为消息中间件,原理非常简单,使用起来也很方便。
- 安装注册中心
- nameko采用RabbitMQ作为注册中心,所以使用nameko必须要先安装RabbitMQ
- 以docker容器的方式运行RabbitMQ是最为简便快捷的方式,两行命令就搞定了,这里介绍如何使用docker运行RabbitMQ
- 第一步:从DockerHub拉取rabbitmq镜像 docker pull rabbitmq:management
- 第二步:运行RabbitMQ容器
docker run -d --hostname my-rabbit --name rabbit -p 15672:15672 -p 5672:5672 rabbitmq:management
- .如果需要设置用户名和密码,则使用这条命令
-
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
-
- 我运行容器时没有设置用户名和密码,所以使用用户名guest,密码guest登录。http://localhost:15672/
- 登录成功 ,界面
- 发布服务,将服务注册到Nameko
-
from nameko.rpc import rpc class hello_service: name = "hello_service" @rpc def hello(self): print("hello world")
-
- 调用服务的消费者
-
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()
-
- 生产者微服务启动
- 使用nameko框架的run命令启动微服务
nameko run producer.py --broker amqp://guest:guest@192.168.110.129
- 如果服务正常启动
-
运行了消费者 服务器后
- 生产者的函数被消费者调用
- 使用nameko框架的run命令启动微服务
- 案例二,通过Nameko 实现微服务通信
- 安装环境
- pip install nameko
- pip install yagmail