rabbitMQ其实跟mysql等数据库差不多,都是需要通过url,账号,密码等去链接
public static Connection getConnection() throws Exception { //定义连接工厂 ConnectionFactory factory = new ConnectionFactory(); //设置服务地址 factory.setHost("127.0.0.1"); //端口 factory.setPort(5672); //设置账号信息,用户名、密码、vhost factory.setVirtualHost("/liyh"); factory.setUsername("liyh"); factory.setPassword("liyh"); // 通过工程获取连接 Connection connection = factory.newConnection(); return connection; }rabbitMQ包括简单队列,work模式,订阅模式,路由模式,通配符模式等五种
1、简单队列
生产者步骤:1、获取mq链接 2、创建通道 3、声明队列 4、发送消息 5、关闭链接
消费者步骤:1、获取mq链接 2、创建通道 3、声明队列 4、定义队列的消费者 5、监听队列 6、获取信息
2、work模式
步骤和简单队列一样,其中队列中每条消息只能由其中的一个消费者获取
3、订阅模式
生产者将消息发送到交换机中,交换机会将信息转发到绑定到其的队列,就是订阅了此交换机的队列
4、路由模式
路由模式跟订阅模式差不多,是订阅模式的扩展,订阅模式中交换机会将消息发送到所有的队列,而路由模式的交换机是将消息发送到其符合条件的队列
5、通配符模式
通配符模式跟路由模式差不多,“#”匹配一个或多个词,“*”只配置一个词,(注:词跟字符概念不同)