我们先看看运行效果图：
上图中，我们启动了两个java进程，分别运行在 8080 和 8081 端口。当我们在 8080 端口添加 name 和 version 缓存后，立马在 8081 端口所在的 Java 进程中显示出来。同样，从 8081 端口删除一个缓存，立马在 8080 中体现出来。如果你仔细看，你会发现我们在 8080 端口中新添加的 name 和 version 缓存信息后，在 8081 中首次显示出来的 level 为 2（表示来自二级缓存），然后变为 level = 1（一级缓存）。
我们先看看项目结构，如下图：
下面将配置 Freemarker 模板，如下：
## Freemarker
# 指定 HttpServletRequest 的属性是否可以覆盖 controller 中与 model 同名项
spring.freemarker.allow-request-override=false
# 是否开启模版缓存
spring.freemarker.cache=true
# 是否检查模版路径是否存在
spring.freemarker.check-template-location=true
# 设定模版编码
spring.freemarker.charset=utf-8
# 设定Content-Type
spring.freemarker.content-type=text/html
# 设定所有request的属性在merge到模板的时候，是否要都添加到model中
spring.freemarker.expose-request-attributes=false
# 设定所有HttpSession的属性在merge到模板的时候，是否要都添加到model中
spring.freemarker.expose-session-attributes=false
# 设定是否以springMacroRequestContext的形式暴露RequestContext给Spring’s macrolibrary使用
spring.freemarker.expose-spring-macro-helpers=false
# 设定freemarker模板的前缀
spring.freemarker.prefix=
# 指定RequestContext属性的名
spring.freemarker.request-context-attribute=freemarker
# 设定模板的后缀
spring.freemarker.suffix=.ftl
# 设定模板的加载路径，多个以逗号分隔，默认: ["classpath:/templates/"]
spring.freemarker.template-loader-path=classpath:/templates/#J2Cache configuration
#########################################
# Cache Broadcast Method
# values:
# jgroups -> use jgroups's multicast
# redis -> use redis publish/subscribe mechanism (using jedis)
# lettuce -> use redis publish/subscribe mechanism (using lettuce, Recommend)
# rabbitmq -> use RabbitMQ publisher/consumer mechanism
# rocketmq -> use RocketMQ publisher/consumer mechanism
# none -> don't notify the other nodes in cluster
# xx.xxxx.xxxx.Xxxxx your own cache broadcast policy classname that implement net.oschina.j2cache.cluster.ClusterPolicy
#########################################
j2cache.broadcast = redis
# jgroups properties
jgroups.channel.name = j2cache
jgroups.configXml = /network.xml
# RabbitMQ properties
rabbitmq.exchange = j2cache
rabbitmq.host = localhost
rabbitmq.port = 5672
rabbitmq.username = guest
rabbitmq.password = guest
# RocketMQ properties
rocketmq.name = j2cache
rocketmq.topic = j2cache
# use ; to split multi hosts
rocketmq.hosts = 127.0.0.1:9876
#########################################
# Level 1&2 provider
# values:
# none -> disable this level cache
# ehcache -> use ehcache2 as level 1 cache
# ehcache3 -> use ehcache3 as level 1 cache
# caffeine -> use caffeine as level 1 cache(only in memory)
# redis -> use redis as level 2 cache (using jedis)
# lettuce -> use redis as level 2 cache (using lettuce)
# readonly-redis -> use redis as level 2 cache ,but never write data to it. if use this provider, you must uncomment `j2cache.L2.config_section` to make the redis configurations available.
# memcached -> use memcached as level 2 cache (xmemcached),
# [classname] -> use custom provider
#########################################
j2cache.L1.provider_class = ehcache3
j2cache.L2.provider_class = redis
# When L2 provider isn't `redis`, using `L2.config_section = redis` to read redis configurations
# j2cache.L2.config_section = redis
# Enable/Disable ttl in redis cache data (if disabled, the object in redis will never expire, default:true)
# NOTICE: redis hash mode (redis.storage = hash) do not support this feature)
j2cache.sync_ttl_to_redis = true
# Whether to cache null objects by default (default false)
j2cache.default_cache_null_object = true
#########################################
# Cache Serialization Provider
# values:
# fst -> using fast-serialization (recommend)
# kryo -> using kryo serialization
# json -> using fst's json serialization (testing)
# fastjson -> using fastjson serialization (embed non-static class not support)
# java -> java standard
# fse -> using fse serialization
# [classname implements Serializer]
#########################################
j2cache.serialization = json
#json.map.person = net.oschina.j2cache.demo.Person
#########################################
# Ehcache configuration
#########################################
# ehcache.configXml = /ehcache.xml
ehcache3.configXml = /ehcache3.xml
ehcache3.defaultHeapSize = 10000
#########################################
# Caffeine configuration
# caffeine.region.[name] = size, xxxx[s|m|h|d]
#
#########################################
caffeine.properties = /caffeine.properties
#########################################
# Redis connection configuration
#########################################
#########################################
# Redis Cluster Mode
#
# single -> single redis server
# sentinel -> master-slaves servers
# cluster -> cluster servers (\u6570\u636e\u5e93\u914d\u7f6e\u65e0\u6548\uff0c\u4f7f\u7528 database = 0\uff09
# sharded -> sharded servers (\u5bc6\u7801\u3001\u6570\u636e\u5e93\u5fc5\u987b\u5728 hosts \u4e2d\u6307\u5b9a\uff0c\u4e14\u8fde\u63a5\u6c60\u914d\u7f6e\u65e0\u6548 ; redis://user:password@127.0.0.1:6379/0\uff09
#
#########################################
redis.mode = single
#redis storage mode (generic|hash)
redis.storage = generic
## redis pub/sub channel name
redis.channel = j2cache
## redis pub/sub server (using redis.hosts when empty)
redis.channel.host =
#cluster name just for sharded
redis.cluster_name = j2cache
## redis cache namespace optional, default[empty]
redis.namespace =
## redis command scan parameter count, default[1000]
#redis.scanCount = 1000
## connection
# Separate multiple redis nodes with commas, such as 192.168.0.10:6379,192.168.0.11:6379,192.168.0.12:6379
redis.hosts = 127.0.0.1:6379
redis.timeout = 2000
redis.password =
redis.database = 0
redis.ssl = false
## redis pool properties
redis.maxTotal = 100
redis.maxIdle = 10
redis.maxWaitMillis = 5000
redis.minEvictableIdleTimeMillis = 60000
redis.minIdle = 1
redis.numTestsPerEvictionRun = 10
redis.lifo = false
redis.softMinEvictableIdleTimeMillis = 10
redis.testOnBorrow = true
redis.testOnReturn = false
redis.testWhileIdle = true
redis.timeBetweenEvictionRunsMillis = 300000
redis.blockWhenExhausted = false
redis.jmxEnabled = false
#########################################
# Lettuce scheme
#
# redis -> single redis server
# rediss -> single redis server with ssl
# redis-sentinel -> redis sentinel
# redis-cluster -> cluster servers
#
#########################################
## redis command scan parameter count, default[1000]
#lettuce.scanCount = 1000
lettuce.namespace =
lettuce.storage = hash
lettuce.channel = j2cache
lettuce.scheme = redis
lettuce.hosts = 127.0.0.1:6379
lettuce.password =
lettuce.database = 0
lettuce.sentinelMasterId =
lettuce.maxTotal = 100
lettuce.maxIdle = 10
lettuce.minIdle = 10
# timeout in milliseconds
lettuce.timeout = 10000
# redis cluster topology refresh interval in milliseconds
lettuce.clusterTopologyRefresh = 3000
#########################################
# memcached server configurations
# refer to https://gitee.com/mirrors/XMemcached
#########################################
memcached.servers = 127.0.0.1:11211
memcached.username =
memcached.password =
memcached.connectionPoolSize = 10
memcached.connectTimeout = 1000
memcached.failureMode = false
memcached.healSessionInterval = 1000
memcached.maxQueuedNoReplyOperations = 100
memcached.opTimeout = 100
memcached.sanitizeKeys = false<!-- for ehcache 3.x -->
<config
xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance'
xmlns='http://www.ehcache.org/v3'
xsi:schemaLocation="http://www.ehcache.org/v3 http://www.ehcache.org/schema/ehcache-core.xsd">
<!-- Don't remote default cache configuration -->
<cache-template name="default">
<key-type>java.lang.String</key-type>
<value-type>java.io.Serializable</value-type>
<expiry>
<ttl unit="seconds">1800</ttl>
</expiry>
<resources>
<heap>1000</heap>
<offheap unit="MB">100</offheap>
</resources>
</cache-template>
<cache alias="default" uses-template="default"/>
</config>本文件提供 UI 简单界面，代码如下：
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>J2Cache</title>
<script type="text/javascript" src="js/jquery-v1.8.1.js"></script>
</head>
<body>
<h3>新增/修改缓存</h3>
<div>
键: <input id="key" type="text"/>
值: <input id="value" type="text"/>
<button id="btnSubmit">提交</button>
</div>
<h3>缓存列表
<label style="font-size:14px;font-weight:bold;">
<input type="checkbox" id="autoRefresh" value="1" checked>自动刷新
</label>
</h3>
<table width="100%" border="1">
<thead>
<tr>
<th>key</th>
<th>value</th>
<th>region</th>
<th>level</th>
<th></th>
</tr>
</thead>
<tbody id="keyList"></tbody>
</table>
<script type="text/javascript">
var autoRefresh = false;
var intervalObj = null;
$(function(){
autoRefresh = $("#autoRefresh:checked").val();
function getCacheList(){
$.getJSON("/getCacheList", {}, function(ret){
var htmlCode = [];
for(var attr in ret) {
var row = ret[attr] || {};
htmlCode.push("<tr>")
htmlCode.push("<td>" + attr + "</td>");
htmlCode.push("<td>" + row.value + "</td>");
htmlCode.push("<td>" + row.region + "</td>");
htmlCode.push("<td>" + row.level + "</td>");
htmlCode.push("<td><a href=\"javascript:void(0);\" key=\"" + attr + "\"" +
" onclick=\"J2CacheDemo.deleteCache(event)\">删除</a></td>");
htmlCode.push("</tr>")
}
$("#keyList").html(htmlCode.join(""));
});
}
function startInterval() {
if(!!intervalObj) {
clearInterval(intervalObj);
}
intervalObj = setInterval(function(){
if(!!autoRefresh) {
getCacheList();
}
}, 2000);
}
$("#autoRefresh").change(function(){
autoRefresh = $("#autoRefresh:checked").val();
startInterval();
});
// 添加缓存
$("#btnSubmit").click(function(){
var key = $("#key").val();
var value = $("#value").val();
$.getJSON("/addCache", {
key: key,
value: value
}, function(ret){
if(ret.statu == "1") {
$("#key").val("");
$("#value").val("");
}
alert(ret.message);
});
});
function deleteCache(event) {
var key = $(event.target).attr("key");
$.getJSON("/deleteCache", {
key: key
}, function(ret){
if(ret.statu == "1") {
getCacheList();
}
alert(ret.message);
})
}
getCacheList();
startInterval();
window.J2CacheDemo = {
deleteCache: deleteCache
};
});
</script>
</body>
</html>package com.huangx.j2cache.demo2;
import net.oschina.j2cache.CacheChannel;
import net.oschina.j2cache.CacheObject;
import net.oschina.j2cache.J2Cache;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.HashMap;
import java.util.Map;
/**
* 可以通过运行时动态指定端口，如下：
* --server.port=8081
*/
@Controller
@SpringBootApplication
public class J2cacheDemo2Application {
private static final String REGION_NAME = "default";
private CacheChannel cacheChannel;
public J2cacheDemo2Application() {
this.cacheChannel = J2Cache.getChannel();
}
public static void main(String[] args) {
SpringApplication.run(J2cacheDemo2Application.class, args);
}
@RequestMapping("/")
public String index() {
return "index";
}
/**
* 添加缓存
* @param key 键
* @param value 值
* @return
*/
@GetMapping("/addCache")
@ResponseBody
public Map<String,Object> addCache(@RequestParam("key") String key,
@RequestParam("value") String value) {
Map<String,Object> map = new HashMap<>();
try {
this.cacheChannel.set(REGION_NAME, key, value);
map.put("statu", "1");
map.put("message", "操作成功");
} catch (Exception e) {
e.printStackTrace();
map.put("statu", "0");
map.put("message", "新增缓存失败，原因：" + e.getMessage());
}
return map;
}
/**
* 删除缓存
* @param key 键
* @return
*/
@GetMapping("/deleteCache")
@ResponseBody
public Map<String,Object> deleteCache(@RequestParam("key") String key) {
Map<String,Object> map = new HashMap<>();
try {
this.cacheChannel.evict(REGION_NAME, key);
map.put("statu", "1");
map.put("message", "操作成功");
} catch (Exception e) {
e.printStackTrace();
map.put("statu", "0");
map.put("message", "删除缓存失败，原因：" + e.getMessage());
}
return map;
}
/**
* 获取缓存列表
* @return
*/
@GetMapping("/getCacheList")
@ResponseBody
public Map<String, CacheObject> getCacheList() {
Map<String, CacheObject> map = new HashMap<String, CacheObject>();
try {
map = this.cacheChannel.get(REGION_NAME, this.cacheChannel.keys(REGION_NAME));
} catch (Exception e) {
e.printStackTrace();
}
return map;
}
}运行上面实例，在程序参数中通过 --server.port 指定服务的端口，分别运行 --server.port=8080 和 --server.port=8081。
川公网安备51010802032098
