004 java客户端的开发

一 .概述

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

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

二 .连接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进行的.

---

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