server.py 文件源码

def on_request(ch, method, props, body):

    global REQ_COUNT

    REQ_COUNT += 1
    print(" [x] Listening ... Request Number: %i" % REQ_COUNT)
    body = json.load(StringIO(body))
    operator = body['operator']
    values = body['data']

    print(" [.] mathOps(%s)" % operator)
    response = json.dumps(mathOps(values, operator=operator), 
                                  separators=(',', ':'))
    print(" Output: %s\n" % response)
    basicProperties = pika.BasicProperties(correlation_id=props.correlation_id)
    ch.basic_publish(exchange='',
                     routing_key=props.reply_to,
                     properties=basicProperties,
                     body=str(response))
    ch.basic_ack(delivery_tag=method.delivery_tag)