RabbitMQ（四）事务消息，惰性队列，优先队列

本文主要是介绍RabbitMQ（四）事务消息，惰性队列，优先队列，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

事务消息

仅在生产者端有效，消费端无效

概念

总结：

• 在生产者端使用事务消息和消费端没有关系
• 在生产者端使用事务消息仅仅是控制事务内的消息是否发送
• 提交事务就把事务内所有消息都发送到交换机
• 回滚事务则事务内任何消息都不会被发送

配置

// 配置
import lombok.Data;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.transaction.RabbitTransactionManager;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
@Data
public class RabbitConfig {@Beanpublic RabbitTransactionManager transactionManager(CachingConnectionFactory connectionFactory) {return new RabbitTransactionManager(connectionFactory);}@Beanpublic RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);rabbitTemplate.setChannelTransacted(true);return rabbitTemplate;}
}

//测试@SpringBootTest
@Slf4j
public class RabbitMQTest {public static final String EXCHANGE_NAME = "exchange.tx.dragon";public static final String ROUTING_KEY = "routing.key.tx.dragon";@Autowiredprivate RabbitTemplate rabbitTemplate;@Test@Transactional@Rollback(value = true) // junit 默认回滚事务，所以想提交事务就设置为 falsepublic void testSendMessageInTx() {// 1、发送第一条消息rabbitTemplate.convertAndSend(EXCHANGE_NAME, ROUTING_KEY, "I am a dragon(tx msg ~~~01~~~)");// 2、抛出异常log.info("do bad:" + 10 / 0);// 3、发送第二条消息rabbitTemplate.convertAndSend(EXCHANGE_NAME, ROUTING_KEY, "I am a dragon(tx msg ~~~02~~~)");}}

惰性队列

概念

创建队列时，在Durability这里有两个选项可以选择

• Durable：持久化队列，消息会持久化到硬盘上
• Transient：临时队列，不做持久化操作，broker重启后消息会丢失
  
  
  
  https://www.rabbitmq.com/docs/lazy-queues

经典队列中的消息会尽可能早地移动到磁盘。 只有当使用者请求这些消息时，它们才会加载到 RAM 中

会从硬盘中读取，只能作为权宜之计

应用场景

优先队列

概念

默认情况：基于队列先进先出的特性，通常来说，先入队的先投递

• 设置优先级之后：优先级高的消息更大几率先投递
• 关键参数：x-max-priority

RabbitMQ允许我们使用一个正整数给消息设定优先级

• 消息的优先级数值取值范围：1~255
• RabbitMQ官网建议在1~5之间设置消息的优先级（优先级越高，占用CPU、
  内存等资源越多）

队列在声明时可以指定参数：x-max-priority

• 默认值：0 此时消息即使设置优先级也无效
• 指定一个正整数值：消息的优先级数值不能超过这个值

配置

配置exchange：exchange.test.priority

配置队列：queue.test.priority
x-max-priority

// 生产者：发三个从1开始，优先级越大消费的时候越在前面消费
// 下面是发一条消息的示例public static final String EXCHANGE_PRIORITY = "exchange.test.priority";
public static final String ROUTING_KEY_PRIORITY = "routing.key.test.priority";
@Test
public void test06SendMessage() {rabbitTemplate.convertAndSend(EXCHANGE_PRIORITY, ROUTING_KEY_PRIORITY, "message test proirity 3", message -> {// 消息本身的优先级数值// 切记：不能超过 x-max-priority:	10message.getMessageProperties().setPriority(3);return message;});
}

// 消费者
@Component
@Slf4j
public class MyMessageListener {public static final String QUEUE_PRIORITY = "queue.test.priority";@RabbitListener(queues = {QUEUE_PRIORITY})public void processMessagePriority(String dataString, Message message, Channel channel) throws IOException {log.info("[priority]" + dataString);channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);}
}

这篇关于RabbitMQ（四）事务消息，惰性队列，优先队列的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---