工具类
public class RabbitMQConnection {
public static Connection getConnection() throws Exception{
//1.创建connectionFactory
ConnectionFactory connectionFactory = new ConnectionFactory();
//2.配置Host
connectionFactory.setHost("127.0.0.1");
//3.设置Port
connectionFactory.setPort(5672);
//4.设置账户和密码
connectionFactory.setUsername("guest");
connectionFactory.setPassword("guest");
//5.设置VirtualHost
connectionFactory.setVirtualHost("0517");
return connectionFactory.newConnection();
}
}
点对点(简单)的队列
工作(公平性)队列模式
发布订阅模式
路由模式Routing
通配符模式Topics(主题)