Python 微服务框架 Nameko 初体验

# 1、下载某个版本的RabbitMQ的镜像
# MQ版本号：3.9.5
docker pull rabbitmq:3.9.5-management

# 2、查看镜像
docker images

# 3、启动MQ容器
# p：指定应用端口及Web控制台端口
# hostname：主机名
# e：环境变量
# RABBITMQ_DEFAULT_VHOST：虚拟机名称
# RABBITMQ_DEFAULT_USER：用户名
# RABBITMQ_DEFAULT_PASS：密码
# 3e83da0dc938：MQ镜像ID
docker run -d --name rabbitmq3.9.5 -p 5672:5672 -p 15672:15672 -v `pwd`/data:/var/lib/rabbitmq --hostname myRabbit -e RABBITMQ_DEFAULT_VHOST=my_vhost  -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin 3e83da0dc938

# 安装依赖包
# nameko
pip3 install nameko

# flask
pip3 install flask

# producer_service.py

from nameko.rpc import rpc

class GenerateService(object):
    # 定义微服务名称
    name = "generate_service"

    @rpc
    def hello_world(self, msg):
        print('hello,i am been called by customer（消费者）,返回消息：{}'.format(msg))

        # 返回结果
        return "Hello World!I Am a msg from producer!"

# 注册服务
# producer_service：目标文件
# admin:admin：MQ用户名及密码
# ip地址:5672：MQ服务器ip地址及应用端口号
# my_vhost：虚拟机名
nameko run producer_service --broker amqp://admin:admin@ip地址:5672/my_vhost

from flask import Flask
from nameko.standalone.rpc import ClusterRpcProxy

app = Flask(__name__)

# MQ配置
config_mq = {'AMQP_URI': "amqp://admin:admin@ip地址:5672/my_vhost"}

@app.route('/hello_world', methods=['GET'])
def call_service():
    with ClusterRpcProxy(config_mq) as rpc:
        # 消费者调用微服务(生产者)，获取服务（生产者）的返回值
        result = rpc.generate_service.hello_world(msg="xag msg")

        # 返回结果
        return result, 200

app.run(debug=True)

# 调用API接口
http://127.0.0.1:5000/hello_world
Method：GET