RabbitMQ之队列与消息持久化

channel.basicPublish("", queueName, MessageProperties.PERSISTENT_TEXT_PLAIN, msg.getBytes());

import java.io.IOException;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;

/**
 * 消息持久化
 * @author menghh
 *
 */
public class Send04 {

public static void main(String[] args) throws IOException {
ConnectionFactory factory = new ConnectionFactory();
//RabbitMQ-Server安装在本机，所以直接用127.0.0.1
factory.setHost("127.0.0.1");
//创建一个连接
Connection cOnn= factory.newConnection();
//创建一个通信通道
Channel channel = conn.createChannel();
//定义Queue名称
String queueName = "queue01";
//为Channel定义queue的属性，queueName为queue名称
channel.queueDeclare(queueName, true, false,false,null);
String msg = "Hello World!";
//发送消息
/**
 * 测试条件：1、在消息队列持久化的前提下2、接收消息方设置接收方式为手动接收，并不对接收消息进行确认
 * 不采用消息持久化，重启RabbitMQ服务后，消息队列存在，消息接收不到
 * 采用消息持久化，重启RabbitMQ服务后，消息队列存在，消息依然可以接收到消息，说明消息被持久化
 */
channel.basicPublish("", queueName, MessageProperties.PERSISTENT_TEXT_PLAIN, msg.getBytes());
//channel.basicPublish("", queueName, null, msg.getBytes());
System.out.println("send message["+msg+"] to "+queueName+"success!");
//关闭通道
channel.close();
//关闭连接
conn.close();
}
}

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;
import com.rabbitmq.client.QueueingConsumer.Delivery;

/**
 * 消息持久化
 * @author menghh
 *
 */
public class Recv04 {

public static void main(String[] args) throws Exception{
ConnectionFactory factory = new ConnectionFactory(); 
factory.setHost("127.0.0.1");
Connection cOnn= factory.newConnection();
Channel channel = conn.createChannel();
String queueName = "queue01";
channel.queueDeclare(queueName, true, false, false, null);
//以上部分和sender一样
//配置好获取消息得方式
QueueingConsumer cOnsumer=  new QueueingConsumer(channel);
channel.basicConsume(queueName, false,consumer);
//循环获取消息
while(true){
//获取消息，如果没有消息，这一步将会一直阻塞
Delivery delivery = consumer.nextDelivery();
String msg = new String(delivery.getBody());
//确认消息，已经收到  
            channel.basicAck(delivery.getEnvelope().getDeliveryTag(),false);  
System.out.println("received message["+msg+"] from "+queueName);
}
}
}