RabbitMQ 快速入门

RabbitMQ 快速入门

引入依赖

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.22.0</version>
</dependency>

编写生产者代码

具体步骤：

1. 建立连接
2. 开启信道
3. 声明交换机
4. 声明队列
5. 发送消息
6. 释放资源

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();
}