2024年4月

Java连接rabbitMQ（三步超简单）

作者: admin
时间: 2024-04-15
分类: 默认分类
评论

https://blog.csdn.net/cris_tian/article/details/131531080

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

第二步，配置连接
在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();
        }
    }
}