统一消息系统

// 定义消息生产者

class MessageProducer {

public void sendMessage(String message) {

// 发送消息到RabbitMQ

System.out.println("发送消息：" + message);

}

}

// 定义消息消费者

class MessageConsumer implements Runnable {

private String queueName;

public MessageConsumer(String queueName) {

this.queueName = queueName;

}

@Override

public void run() {

while (true) {

// 接收消息并处理

System.out.println("接收到消息：" + queueName);

}

}

}

public class Main {

public static void main(String[] args) {

MessageProducer producer = new MessageProducer();

MessageConsumer consumer = new MessageConsumer("schoolQueue");

// 启动消费者线程

Thread consumerThread = new Thread(consumer);

consumerThread.start();

// 模拟发送消息

producer.sendMessage("通知：本周五有重要讲座！");

}

}

]]>