RabbitMQ初体验

这里官方使用的Pom是4.0.2版本

<dependencies>
　　<dependency>
　　　　<groupId>com.rabbitmq</groupId>
　　　　<artifactId>amqp-client</artifactId>
　　　　<version>4.0.2</version>
　　</dependency>
　　　<dependency>
　　　　<groupId>org.slf4j</groupId>
　　　　<artifactId>slf4j-api</artifactId>
　　　　<version>1.7.10</version>
　　</dependency>
　　<dependency>
　　　　<groupId>org.slf4j</groupId>
　　　　<artifactId>slf4j-log4j12</artifactId>
　　　　<version>1.7.5</version>
　　</dependency>
　　<dependency>
18　　　　 <groupId>log4j</groupId>
19　　　　 <artifactId>log4j</artifactId>
　　　　<version>1.2.17</version>
21　　 </dependency>
　　<dependency>
　　　　<groupId>junit</groupId>
　　　　<artifactId>junit</artifactId>
　　　　<version>4.11</version>
26 　　</dependency>
</dependencies>

简单队列 hello word

P：消息的生产者

C：消息的消费者

红色：队列

生产者将消息发送到队列，消费者从队列中获取消息。

那么我们根据以上的模型,咱们抽取出 3 个对象 生产者(用户发送消息) 队列(中间件):类似于容器(存储消息) 消费者(获取队列中的消息）

JAVA 操作 获取 MQ 连接

类似于我们在操作数据库的时候的要获取到连接然后才对数据进行

package cn.wh.util;

import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class RabbitMqConnectionUtil {
    /**
     * 获取mq的连接
     * @return
     */
    public static Connection getConnection() throws IOException, TimeoutException {
        //定义一个连接工厂
        ConnectionFactory factory=new ConnectionFactory();
        //设置服务器的地址
        factory.setHost("192.168.152.5");
        //AMQP 5672
        factory.setPort(5672);
        //设置哪一个数据库 vhost
        factory.setVirtualHost("/vhost_wh");
        //设置用户名
        factory.setUsername("wh");
        factory.setPassword("123");

        return  factory.newConnection();
    }
}

生产者发送数据到消息队列

package cn.wh.simple;

import cn.wh.util.RabbitMqConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class Send {
    private static final String QUEVE_NAME = "test_simple_queue";

    public static void main(String[] args) throws IOException {
        //获取一个连接
        Connection connection = null;
        try {
         
            connection = RabbitMqConnectionUtil.getConnection();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (TimeoutException e) {
            e.printStackTrace();
        }

        //创建一个通道
        Channel channel = connection.createChannel();
        // 创建队列声明
        channel.queueDeclare(QUEVE_NAME, false, false, false, null);

        //发送的消息
        String msg="hello simple";
        channel.basicPublish("",QUEVE_NAME,null,msg.getBytes());
        System.out.println("发送成功===============");
        try {
            channel.close();
            connection.close();
        } catch (TimeoutException e) {
            e.printStackTrace();
        }
    }
}

查看消消费者消费消费者消费消费者消费消费者消消费者消费消费者消费

package cn.wh.simple;

import cn.wh.util.RabbitMqConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.QueueingConsumer;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class Accept {
    private static final java.lang.String QUEVE_NAME = "test_simple_queue";
    public static void main(String[] args) throws IOException, InterruptedException {

        //获取一个连接
        Connection connection=null;
        {
            try {
                connection = RabbitMqConnectionUtil.getConnection();
            } catch (IOException e) {
                e.printStackTrace();
            } catch (TimeoutException e) {
                e.printStackTrace();
            }
            //定义管道
            Channel channel = connection.createChannel();
            //定义队列的消费者
            QueueingConsumer queueingConsumer = new QueueingConsumer(channel);
            channel.basicConsume(QUEVE_NAME,true,queueingConsumer);
            while (true){
                QueueingConsumer.Delivery delivery = queueingConsumer.nextDelivery();
                String msg = new String(delivery.getBody());


                System.out.println("msg"+ msg);
            }
        }
    }
}

简单队列的不足

耦合性高 生产消费一一对应(如果有多个消费者想都消费这个消息,就不行了) 队列名称变更时需要同时更改