统一消息系统

import pika

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

channel = connection.channel()

channel.queue_declare(queue='ai_queue')

message = "用户问：今天天气怎么样？"

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

print(" [x] Sent %r" % message)

connection.close()

import pika

import time

def ai_response(text):

# 简单模拟AI响应

if '天气' in text:

return "今天晴天，适合外出！"

else:

智慧校园服务平台

return "我暂时无法回答这个问题。"

def callback(ch, method, properties, body):

print(" [x] Received %r" % body.decode())

response = ai_response(body.decode())

print(" [x] AI Response: %r" % response)

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

channel = connection.channel()

channel.queue_declare(queue='ai_queue')

channel.basic_consume(queue='ai_queue', on_message_callback=callback, auto_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')

channel.start_consuming()