锦中融合门户系统

from flask import Flask

import pika

app = Flask(__name__)

def send_message(message):

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

channel = connection.channel()

channel.queue_declare(queue='notification')

channel.basic_publish(exchange='', routing_key='notification', body=message)

connection.close()

@app.route('/send')

def send():

send_message("这是一条统一消息")

return "消息已发送"

if __name__ == '__main__':

app.run(debug=True)