队列:一种数据结构,先进先出。
消息队列:简单的说就是用来进行消息传输的队列。
消息中间件:简单的说就是用来传输消息的中间载体,就是将你的信息发送到接受方,它并不关心发送的数据是什么。RabbitMQ就是一个消息中间件。
首先,安装RabbitMQ,可以参考这两篇帖子:《【Linux CentOS 7安装RabbitMQ详细教程】》、《【Windows安装RabbitMQ详细教程】》
然后在网页访问:http://服务器的ip:15672,输入账号密码。记得开放端口
看到此页面代表安装成功
准备就绪,先写个Hello World
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
public class ConnectionUtils {
public static Connection getConnection() {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("1.15.88.28");
factory.setPort(5672);
factory.setUsername("admin");
factory.setPassword("admin");
factory.setVirtualHost("/");
try {
return factory.newConnection();
} catch (IOException | TimeoutException e) {
e.printStackTrace();
}
return null;
}
}
public class Producer {
// 声明队列的名字
private static final String QUEUE_NAME = "queue_helloworld_1";
public static void main(String[] args) throws IOException, TimeoutException {
// 1. 获取连接
Connection connection = ConnectionUtils.getConnection();
// 2. 创建数据传输通道
Channel channel = connection.createChannel();
// 3. 声明队列
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
// 4. 发送数据到队列
channel.basicPublish("", QUEUE_NAME, MessageProperties.PERSISTENT_TEXT_PLAIN, "第一个队列消息...".getBytes());
// 5. 关闭通道
channel.close();
// 6. 关闭连接
connection.close();
}
}
public class Consumer {
// 声明队列的名字
private static final String QUEUE_NAME = "queue_helloworld_1";
public static void main(String[] args) throws IOException, TimeoutException {
// 1. 获取连接
Connection connection = ConnectionUtils.getConnection();
// 2. 创建通道
Channel channel = connection.createChannel();
// 3. 声明队列
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
// 4. 声明消费者
DefaultConsumer defaultConsumer = new DefaultConsumer(channel) {
@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
System.out.println("接收到的消息是:" + new String(body));
channel.basicAck(envelope.getDeliveryTag(), false);
}
};
// 5. 绑定消费者
channel.basicConsume(QUEUE_NAME, false, defaultConsumer);
}
}
本文到这里就结束了,简单介绍了一下RabbitMQ是什么,以及RabbitMQ的安装;