一 .概述

本次我们使用java客户端进行Rabbitmq的开发内容,首先我们需要搭建一个开发环境.

             
                  
       
        com.rabbitmq
                   
       
        amqp-client
                   
       
        5.5.0
               
          
     

二 .连接Rabbitmq

ConnectionFactory factory = new ConnectionFactory();        factory.setUsername("root");        factory.setPassword("trek");        factory.setVirtualHost("/");        factory.setHost("39.106.154.23");        factory.setPort(5672);                Connection connection = factory.newConnection();        //创建信道对象        Channel channel = connection.createChannel();        System.out.println(channel);

在上面的代码之中,我们核心的API就是创建一个ConnectionFactory对象,然后进行属性的配置.

当创建完ConnectionFactory之后,就可以获取Connection对象和Channel对象.

几乎所有的操作都是由Channel进行的.

---

 

三 .声明交换机和队列,然后进行绑定