统一消息系统

# 消息生产者（发送方）

import pika

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

channel = connection.channel()

channel.queue_declare(queue='hospital_notifications')

message = 'Patient has been registered.'

channel.basic_publish(exchange='',

routing_key='hospital_notifications',

body=message)

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

connection.close()

# 消息消费者（接收方）

import pika

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

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

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

channel = connection.channel()

channel.queue_declare(queue='hospital_notifications')

channel.basic_consume(callback,

queue='hospital_notifications',

no_ack=True)

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

channel.start_consuming()

import mysql.connector

def update_visit_count(doctor_id):

conn = mysql.connector.connect(

host="localhost",

user="root",

password="password",

database="hospital_db"

)

cursor = conn.cursor()

query = "UPDATE doctor_visits SET visits = visits + 1 WHERE doctor_id = %s"

cursor.execute(query, (doctor_id,))

conn.commit()

cursor.close()

conn.close()

def get_top_doctors(limit=5):

conn = mysql.connector.connect(

host="localhost",

user="root",

password="password",

database="hospital_db"

)

cursor = conn.cursor()

query = "SELECT doctor_id, visits FROM doctor_visits ORDER BY visits DESC LIMIT %s"

cursor.execute(query, (limit,))

results = cursor.fetchall()

cursor.close()

conn.close()

return results

import redis

r = redis.Redis(host='localhost', port=6379, db=0)

def update_redis_visit_count(doctor_id):

r.incr(f'doctor:{doctor_id}:visits')

def get_top_doctors_from_redis(limit=5):

pipe = r.pipeline()

for i in range(1, 100): # 假设有100个医生

pipe.get(f'doctor:{i}:visits')

results = pipe.execute()

# 这里只是简单演示，实际中应该用zset来维护排行榜

# 例如：r.zadd('doctor_rank', {f'doctor:{i}': int(results[i])})

# 然后使用r.zrevrange('doctor_rank', 0, limit-1)

return results