oscache作为一款老的本地缓存,应用场景主要有页面缓存和对象缓存。这里拿在maven项目中使用oscache作为对象缓存举例说明下用法:
1、导入jar包
<dependency>
<groupId>opensymphony</groupId>
<artifactId>oscache</artifactId>
<version>2.4.1</version>
</dependency>
2、在resources目录下新增配置文件oscache.properties
# CACHE IN MEMORY
#
# If you want to disable memory caching, just uncomment this line.
#
cache.memory=true # CACHE SIZE
#
# Default cache size in number of items. If a size is specified but not
# an algorithm, the cache algorithm used will be LRUCache.
#
cache.capacity=100000 # CACHE LISTENERS
#
# These hook OSCache events and perform various actions such as logging
# cache hits and misses, or broadcasting to other cache instances across a cluster.
# See the documentation for further information.
# # com.opensymphony.oscache.extra.CacheEntryEventListenerImpl # CACHE ALGORITHM
#
# Default cache algorithm to use. Note that in order to use an algorithm
# the cache size must also be specified. If the cache size is not specified,
# the cache algorithm will be Unlimited cache.
#
#cache.algorithm=com.opensymphony.oscache.base.algorithm.LRUCache
cache.algorithm=com.opensymphony.oscache.base.algorithm.FIFOCache # THREAD BLOCKING BEHAVIOR
#
# When a request is made for a stale cache entry, it is possible that another thread is already
# in the process of rebuilding that entry. This setting specifies how OSCache handles the
# subsequent 'non-building' threads. The default behaviour (cache.blocking=false) is to serve
# the old content to subsequent threads until the cache entry has been updated. This provides
# the best performance (at the cost of serving slightly stale data). When blocking is enabled,
# threads will instead block until the new cache entry is ready to be served. Once the new entry
# is put in the cache the blocked threads will be restarted and given the new entry.
# Note that even if blocking is disabled, when there is no stale data available to be served
# threads will block until the data is added to the cache by the thread that is responsible
# for building the data.
#
# cache.blocking=false # JAVAGROUPS CLUSTER PROPERTIES
#
# Configuration properites for the JavaGroups clustering. Only one of these
# should be specified. Default values (as shown below) will be used if niether
# property is set. See the clustering documentation and the JavaGroups project
# (www.javagroups.com) for more information on these settings.
#
#cache.cluster.properties=UDP(singleton_name\=screenWidthAdapter;tos\=8;mcast_addr\=225.90.21.10;mcast_port\=50103;mcast_send_buf_size\=640K;mcast_recv_buf_size\=25M;ip_ttl\=32;loopback\=true;discard_incompatible_packets\=true;enable_bundling\=true;max_bundle_size\=64K;max_bundle_timeout\=30;enable_diagnostics\=true;thread_naming_pattern\=book;timer.num_threads\=4;thread_pool.enabled\=true;thread_pool.min_threads\=2;thread_pool.max_threads\=8;thread_pool.keep_alive_time\=5000;thread_pool.queue_enabled\=true;thread_pool.queue_max_size\=10000;thread_pool.rejection_policy\=discard;oob_thread_pool.enabled\=true;oob_thread_pool.min_threads\=1;oob_thread_pool.max_threads\=8;oob_thread_pool.keep_alive_time\=5000;oob_thread_pool.queue_enabled\=false;oob_thread_pool.queue_max_size\=100;oob_thread_pool.rejection_policy\=Run)\:PING(timeout\=2000;num_initial_members\=3)\:MERGE2(min_interval\=10000;max_interval\=30000)\:FD(timeout\=20000;max_tries\=9)\:FD_SOCK()\:FD_ALL()\:VERIFY_SUSPECT(timeout\=15000)\:BARRIER()\:pbcast.NAKACK(retransmit_timeout\=300,600,1200,2400,4800,9600,19200;use_mcast_xmit\=true;use_stats_for_retransmission\=true;xmit_history_max_size\=500;max_rebroadcast_timeout\=20000;discard_delivered_msgs\=false;gc_lag\=500;use_stats_for_retransmission\=false;exponential_backoff\=0)\:UNICAST(timeout\=300,600,1200,2400,4800,9600,19200)\:pbcast.STABLE(stability_delay\=1000;desired_avg_gossip\=20000;max_bytes\=1M)\:pbcast.GMS(join_timeout\=3000;print_local_addr\=true;view_bundling\=true)\:FC(max_credits\=500K;min_threshold\=0.20;ignore_synchronous_response\=true)\:FRAG2(frag_size\=60K)\:pbcast.STATE_TRANSFER()
3、新增缓存类
package com.inspur.chinanet.point.cache; import java.math.BigDecimal;
import java.util.Date;
import java.util.concurrent.atomic.AtomicLong;
import java.util.logging.Logger; import com.opensymphony.oscache.base.NeedsRefreshException;
import com.opensymphony.oscache.general.GeneralCacheAdministrator;
import com.opensymphony.oscache.web.filter.ExpiresRefreshPolicy; /**
* 本地缓存
*
* @author wulinfeng
* @version C10 2018年3月28日
* @since SDP V300R003C10
*/
public class OsCache extends GeneralCacheAdministrator
{ private static final Logger LOG = Logger.getLogger("OsCache"); /**
* 序列化ID
*/
private static final long serialVersionUID = -3814537980571610987L; // 缓存命中次数
private AtomicLong hitCount = new AtomicLong(0L); // 总请求次数
private AtomicLong reqCount = new AtomicLong(0L); // 命中率
private double hitRate = 0D; private static final OsCache cache = new OsCache(); /**
* 单例
*/
public static OsCache getInstance()
{
return cache;
} /**
* 从OSCACHE中获取原始缓存数据
*
* @param key 缓存KEY值
* @param refreshTime 失效时间,-1时为永久缓存
* @return 原始缓存数据
*/
public Object get(String key, int refreshTime)
{
reqCount.incrementAndGet();
Object obj = null;
try
{
obj = this.getFromCache(key, refreshTime);
hitCount.incrementAndGet();
}
catch (NeedsRefreshException e)
{
this.cancelUpdate(key);
LOG.warning(e.getMessage());
}
return obj;
} /**
* 从OSCACHE中获取原始缓存数据
*
* @param key 缓存KEY值
* @param value Object 内容对象
* @param refreshTime 失效时间,-1时为永久缓存
* @return 原始缓存数据
*/
public void put(String key, Object value, int refreshTime)
{
if (refreshTime == -1)
{
this.putInCache(key, value);
}
else
{
this.putInCache(key, value, new ExpiresRefreshPolicy(refreshTime));
}
} /**
* 从OSCACHE中删除缓存数据
*
* @param key 缓存KEY值
*/
public void remove(String key)
{
this.removeEntry(key);
} /**
* 从OSCACHE中删除所有缓存数据
*
* @param date 预定删除时间
*/
public void removeAll(Date date)
{
if (date == null)
{
this.flushAll();
}
else
{
this.flushAll(date);
}
} /**
* 获取命中率
*
* @author wulinfeng
* @return
*/
public double getHitRate()
{
if (reqCount.longValue() == 0L)
{
return 0;
} hitRate = (double)hitCount.longValue() / reqCount.longValue();
BigDecimal bd = new BigDecimal(hitRate);
bd = bd.setScale(2, BigDecimal.ROUND_HALF_UP); return bd.doubleValue();
}
}
4、使用缓存主方法
public static void main(String[] args)
{
User user = (User)OsCache.getInstance().get("user_", -1); if(user != null)
{
LOG.info(user.toString());
}
else
{
LOG.info("no user.");
user = new User();
user.setName("wulinfeng");
user.setAge(34);
user.setSex(1);
OsCache.getInstance().put("user_", user, -1);
user = (User)OsCache.getInstance().get("user_", -1);
LOG.info(user.toString());
}
5、执行主方法结果
三月 28, 2018 9:12:48 下午 com.opensymphony.oscache.base.Config loadProperties
信息: OSCache: Getting properties from URL file:/E:/workspace/TeaPot/target/classes/oscache.properties for the default configuration
三月 28, 2018 9:12:48 下午 com.opensymphony.oscache.base.Config loadProperties
信息: OSCache: Properties read {cache.algorithm=com.opensymphony.oscache.base.algorithm.FIFOCache, cache.capacity=100000, cache.memory=true}
三月 28, 2018 9:12:48 下午 com.opensymphony.oscache.general.GeneralCacheAdministrator <init>
信息: Constructed GeneralCacheAdministrator()
三月 28, 2018 9:12:48 下午 com.opensymphony.oscache.general.GeneralCacheAdministrator createCache
信息: Creating new cache
三月 28, 2018 9:12:48 下午 com.inspur.chinanet.point.cache.OsCache get
警告: null
三月 28, 2018 9:12:48 下午 com.inspur.chinanet.point.App main
信息: no user.
三月 28, 2018 9:12:48 下午 com.inspur.chinanet.point.App main
信息: User [name=wulinfeng, sex=1, age=34]