Java连接rabbitMQ（三步超简单）

RabbitMQ安装教程网上特别多就不多赘述，这里主要说一下怎么去连接

第一步，创建工程添加依赖

创建一个Maven项目，打开pom.xml，添加两个依赖，并更新Maven。

    4.0.0    org.example    rabbitMQdemo    1.0-SNAPSHOT------------添加下面两个依赖------------                        com.rabbitmq            amqp-client            5.14.0                            org.slf4j            slf4j-nop            1.7.25            

第二步，配置连接

在src->main->java中新建一个文件夹utils，在此文件夹中添加class：rabbitMQUtils

package utils;import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;public class RabbitMQUtils {    private static final ConnectionFactory factory;    static {        factory = new ConnectionFactory();        factory.setHost("126.239.25.24");  // 换成自己的ip        factory.setPort(5672);  // 一般默认端口为5672        factory.setUsername("root");          factory.setPassword("123456");        factory.setAutomaticRecoveryEnabled(true);  // 开启Connection自动恢复功能        factory.setNetworkRecoveryInterval(5000);        factory.setVirtualHost("/");        factory.setConnectionTimeout(30 * 1000);        factory.setHandshakeTimeout(30 * 1000);        factory.setShutdownTimeout(0);    }    // 定义提供连接对象的方法    public static Connection getConnection() {        try {            return factory.newConnection();        } catch (Exception e) {            e.printStackTrace();        }        return null;    }    // 定义关闭通道和连接的方法    public static void closeAll(Channel chan, Connection conn) {        try{            if(chan != null)  chan.close();            if(conn != null)  conn.close();        } catch (Exception e) {            e.printStackTrace();        }    }}

需要注意的是要将ip、用户名、密码更换成自己的，如果是在服务器上装的MQ记得在安全组中把端口放行，另外记得设置虚拟用户"/"，或改成自己的虚拟用户名。

第三步，测试连接

使用直连测试连接效果，在src->main->java创建文件夹direct，添加两个class：consumer和producer。

package direct;import com.rabbitmq.client.*;import utils.RabbitMQUtils;import java.io.IOException;public class producer {    public static void main(String[] args) throws IOException {        Connection connection = RabbitMQUtils.getConnection();        assert connection != null;        final Channel channel = connection.createChannel();        // 声明交换机        channel.exchangeDeclare("direct_router", "direct", true, false, false, null);        // 声明消息队列        // 参数1: 队列名称        // 参数2: 定义是否需要持久化队列，true为持久化        // 参数3: 定义是否让当前连接独占队列，true为独占        // 参数4: 是否在消费完成后自动删除队列，true为删除        // 参数5: 额外附加参数，传入HashMap        channel.queueDeclare("direct_queue", false, false, false, null);        // 交换机与消息队列绑定        channel.queueBind("direct_queue", "direct_router", "Dir-RQ");        // 发送消息        // 参数1: 交换机名称        // 参数2: routingKey        // 参数3: 若为true，则当消息无法送达指定队列时会触发channel.BasicReturn事件否则broker会将消息直接丢弃        // 参数4: 传递消息的额外设置        // 参数5: 发送消息内容        String msg="direct producer message";        channel.basicPublish("direct_router", "Dir-RQ", true, null, msg.getBytes());        RabbitMQUtils.closeAll(channel, connection);    }}

package direct;import com.rabbitmq.client.*;import utils.RabbitMQUtils;import java.io.IOException;public class consumer {    public static void main(String[] args) throws IOException, InterruptedException {        Connection connection = RabbitMQUtils.getConnection();        assert connection != null;        final Channel channel = connection.createChannel();        DefaultConsumer consumer = new DefaultConsumer(channel){            @Override            public void handleDelivery(                    String consumerTag,                    Envelope envelope,                    AMQP.BasicProperties properties,                    byte[] body            ) throws IOException {                // 打印消息                String msg= new String(body, "utf-8");                System.out.println(msg);                // 应答机制 将队列中的消息删除掉，第二个参数为是否需要确认多个ACK                channel.basicAck(envelope.getDeliveryTag(), false);            }        };        // 接收消息        // 参数1: 队列名称        // 参数2: 是否自动签收消息，对应上面的应答机制，最好手动删，否则消费者多了可能会出问题        channel.basicConsume("direct_queue", false, "ConsumerTag", consumer);        Thread.sleep(20000);        RabbitMQUtils.closeAll(channel, connection);    }}

右键运行consumer，20s内运行producer就能看见控制台中接收到了producer发出的消息。

来源地址：https://blog.csdn.net/cris_tian/article/details/131531080