Map实现缓存池介绍
缓存池是基于map实现的一种本机缓存的解决方案,优点就是不会重复创建对象(复用性),避免浪费资源和Gc回收造成的开销和查询Map复用对象比较快,缺点也显而易见因为他是通过Map来存储该复用对象,所以受限于map的值不易被Gc回收,一直保存到内存中,如果使用map来存储大量复用的数据,一直不能清除的话会导致内存泄漏。
-ps 使用基于Map缓存池要考虑业务场景,如果是复用对象是有边界则可以使用(如:文件存储对象,消息队列名等),如果是无边界的不推荐使用(如:用户对象,商品对象等)
这个案例我使用RabbitMQ的主题作为唯一标识
package com.example.demo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.concurrent.ConcurrentHashMap;
/**
* $RabbitTemplateContainer池化封装
* 每一个topic 对应一个RabbitTemplate
* 1. 提高发送的效率
* 2. 可以根据不同的需求制定化不同的RabbitTemplate, 比如每一个topic 都有自己的routingKey规则
* @author duanlinpeng
*/
@Slf4j
@Component
class RabbitTemplateContainer {
/* key :TOPIC , value : Template*/
private Map<String, RabbitTemplate> rabbitMap = new ConcurrentHashMap();
@Autowired
private ConnectionFactory connectionFactory;
/**
* @param message 队列消息对象
* @return
* @throws MessageRunTimeException
*/
public RabbitTemplate getTemplate(Message message) throws MessageRunTimeException {
//校验是否为空
Preconditions.checkNotNull(message);
//获取主题名
String topic = message.getTopic();
RabbitTemplate rabbitTemplate = rabbitMap.get(topic);
//返回池中已经存在对象
if (rabbitTemplate != null) {
return rabbitTemplate;
}
log.info("RabbitTemplateContainer.getTemplate topic: {} 不存在,创建一个", topic);
RabbitTemplate newTemplate = new RabbitTemplate(connectionFactory);
newTemplate.setExchange(topic);
newTemplate.setRoutingKey(message.getRoutingKey());
newTemplate.setRetryTemplate(new RetryTemplate());
rabbitMap.put(topic, newTemplate);
return rabbitMap.get(topic);
}
}
}
版权声明:本文为weixin_44519874原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。