1.概念
2.实战
2.1基本逻辑
首先创建生产者类，前面我们学习了rabbitmq的架构，所以我们在发送或者消费消息的时候首先需要创建一个工厂，然后配置好rabbitmq的连接信息，然后创建一个connection，然后创建一个channel，然后再发送或者消费消息
2.2首先创建一个基本的springboot项目
创建完之后，添加一个rabbitmq的依赖：
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>3.6.5</version>
</dependency>
创建生产者类：
public class Producer {
public static void main(String[] args) throws IOException, TimeoutException {
//1.创建一个ConnectionFactory
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("127.0.0.1");
connectionFactory.setPort(5672);
connectionFactory.setVirtualHost("/");
//设置mq连接的自动恢复
connectionFactory.setAutomaticRecoveryEnabled(true);
//设置mq连接自动回复的时间间隔
connectionFactory.setNetworkRecoveryInterval(3000);
//2.通过连接工厂创建连接
Connection connection = connectionFactory.newConnection();
//3.通过connection创建一个channel
Channel channel = connection.createChannel();
//4.通过channel发送数据
for(int i=0;i<5;i++){
String body = "this is a rabbit mq,no:"+i;
channel.basicPublish("","test001",null,body.getBytes());
}
channel.close();
connection.close();
}
}
创建消费者类：
public class Consumer {
public static void main(String[] args) throws IOException, TimeoutException, InterruptedException {
//1.创建一个ConnectionFactory
ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("localhost");
connectionFactory.setPort(5672);
connectionFactory.setVirtualHost("/");
//设置mq连接的自动恢复
connectionFactory.setAutomaticRecoveryEnabled(true);
//设置mq连接自动回复的时间间隔
connectionFactory.setNetworkRecoveryInterval(3000);
//2.通过连接工厂创建连接
Connection connection = connectionFactory.newConnection();
//3.通过connection创建一个channel
Channel channel = connection.createChannel();
//4.声明（创建）一个队列
String queueName = "test001";
channel.queueDeclare(queueName,true,false,false,null);
//5.创建一个消费者
QueueingConsumer queueingConsumer = new QueueingConsumer(channel);
channel.basicConsume(queueName,true,queueingConsumer);
while(true){
QueueingConsumer.Delivery delivery = queueingConsumer.nextDelivery();
String msg = new String(delivery.getBody());
System.err.println(msg);
}
}
}
然后我们首先启动一下消费者，因为在消费者里面我们创建了一个消息队列test001，不然先启动生产者，因为还没有test001，所以自然也就无法往这个队列发送消息了；
启动完消费者，我们这个时候再启动生产者，完了之后看消费者的日志框：
2.3注意
在上面的代码中，我们可以看到，我们在发送消息的时候可以发现我们并没有指定exchange，而是只指定了routingkey为test001。
而其实无论在消费者还是生产者中我们均没有创建exchange，仅仅创建了一个队列，这是为什么呢？
在rabbitmq中，发送消息的时候首先找exchange，如果你没有指定，那么就会进入到默认的exchange中:
而发送的routingkey由于没有指定exchange就会进入到默认的exchange，然后与所有的queue进行匹配，如果能匹配到消息就会发送过去，否则就发送不过去等于说发送失败了，就会把消息给删除掉。
