RabbitMq-【hello word模式】

• 简单模式[hello word]
• • • Demo
    • • pom
      • 生产者代码
      • 消费者代码

RabbitMq安装好以后访问默认的15672端口就能访问控制台了
实现一波最简单的hello word模式
消息生产者-----指派任务的
消息消费者-----执行任务的

        
        
            com.rabbitmq
            amqp-client
            5.8.0
        
        
        
            org.apache.commons
            commons-lang3
            3.8.1
        
        
        
            commons-io
            commons-io
            2.6
        

public class Producer {

    // 队列名称
    public static final String QueueName = "hello";

    //发消息
    public static void main(String[] args) throws IOException, TimeoutException {
        // 创建一个连接工厂
        ConnectionFactory factory = new ConnectionFactory();
        // 工厂ip，连接mq队列
        factory.setHost("119.91.233.11");
        //factory.setPort(15672);
        // 设置账号，同登录的那个
        factory.setUsername("admin");
        // 设置密码，同登录那个
        factory.setPassword("l22e.");
        // 创建连接
        Connection connection = factory.newConnection();
        // 通过连接获取信道,新增信道
        Channel channel = connection.createChannel();
        // 创建一个队列,
        
        channel.queueDeclare(QueueName, false, false, false, null);
        // 创建消息
        String message = "淦！world";
        // 发送消息
        
        channel.basicPublish("", QueueName, null, message.getBytes());

        System.out.println("消息发送完毕");
    }
}

执行完成后我们观察控制台


就能看到刚才我们发送的消息，队列为hello

在这里插入代码片

执行后我们来到控制台

消息已经被消费，任务执行完成

这个就是最简单的hello word 简单模式，简单的发送接收