消息推送系统

public void sendMessage(String message, String recipient) {

// 这里可以添加具体的发送逻辑

System.out.println("Sending message: " + message + " to " + recipient);

}

}

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.ConnectionFactory;

public class RabbitMQSender {

private final static String QUEUE_NAME = "message_queue";

public void send(String message) throws Exception {

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost");

try (Connection connection = factory.newConnection();

Channel channel = connection.createChannel()) {

channel.queueDeclare(QUEUE_NAME, false, false, false, null);

channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));

System.out.println(" [x] Sent '" + message + "'");

}

}

}