统一消息系统

pip install pika nltk

import pika

# 连接到RabbitMQ服务器

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

channel = connection.channel()

# 声明队列

channel.queue_declare(queue='ai_requests')

# 发送消息

message = '请帮我查询今天的天气情况'

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

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

connection.close()

import pika

import nltk

from nltk.chat.util import Chat, reflections

# 初始化NLP模型

pairs = [

['hi', ['Hello!']],

['how are you', ['I am fine, thank you. How about you?']],

['what is your name', ['My name is AI Assistant.']],

]

chatbot = Chat(pairs, reflections)

# 连接到RabbitMQ服务器

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

channel = connection.channel()

# 声明队列

channel.queue_declare(queue='ai_requests')

channel.queue_declare(queue='ai_responses')

# 定义回调函数

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

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

response = chatbot.respond(body.decode())

channel.basic_publish(exchange='', routing_key='ai_responses', body=response)

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

# 开始消费

channel.basic_consume(callback, queue='ai_requests', no_ack=True)

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

channel.start_consuming()

import pika

# 连接到RabbitMQ服务器

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

channel = connection.channel()

# 声明队列

channel.queue_declare(queue='ai_responses')

# 定义回调函数

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

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

# 开始消费

channel.basic_consume(response_callback, queue='ai_responses', no_ack=True)

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

channel.start_consuming()