消息推送系统

// 发送消息

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost");

Connection connection = factory.newConnection();

排课软件

Channel channel = connection.createChannel();

channel.queueDeclare("hello", false, false, false, null);

String message = "Hello World!";

channel.basicPublish("", "hello", null, message.getBytes());

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

channel.close();

connection.close();

// 接收消息

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost");

Connection connection = factory.newConnection();

Channel channel = connection.createChannel();

channel.queueDeclare("hello", false, false, false, null);

QueueingConsumer consumer = new QueueingConsumer(channel);

channel.basicConsume("hello", true, consumer);

while (true) {

QueueingConsumer.Delivery delivery = consumer.nextDelivery();

System.out.println(" [x] Received '" + new String(delivery.getBody()) + "'");

}