RabbitMQ 快速入门
引入依赖
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>5.22.0</version>
</dependency>
编写生产者代码
具体步骤:
- 建立连接
- 开启信道
- 声明交换机
- 声明队列
- 发送消息
- 释放资源
public static void main(String[] args) throws IOException, TimeoutException {
//1.建立连接
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("localhost");
connectionFactory.setPort(5672);
connectionFactory.setUsername("admin");
connectionFactory.setPassword("admin");
connectionFactory.setVirtualHost("study");
Connection connection = connectionFactory.newConnection();
//2.开启信道
Channel channel = connection.createChannel();
//3.声明交换机 使用内置的交换机
//4.声明队列
channel.queueDeclare(,,,,);
( ; i < ; i++) {
+ i;
channel.basicPublish(,,,msg.getBytes());
}
System.out.println();
channel.close();
connection.close();
}

