From 7a51fc3b4fffd0d03c1c99773bace0879bd9647c Mon Sep 17 00:00:00 2001 From: Nikita Date: Thu, 28 Dec 2017 17:26:05 +0300 Subject: [PATCH] Tomcat 9 compatible module added. #1211 --- redisson-tomcat/pom.xml | 1 + redisson-tomcat/redisson-tomcat-9/pom.xml | 81 +++++++ .../org/redisson/tomcat/RedissonSession.java | 215 ++++++++++++++++++ .../tomcat/RedissonSessionManager.java | 194 ++++++++++++++++ .../tomcat/RedissonSessionManagerTest.java | 165 ++++++++++++++ .../java/org/redisson/tomcat/TestServlet.java | 94 ++++++++ .../org/redisson/tomcat/TomcatServer.java | 67 ++++++ .../src/test/webapp/META-INF/context.xml | 7 + .../src/test/webapp/WEB-INF/redisson.yaml | 2 + .../src/test/webapp/WEB-INF/web.xml | 22 ++ 10 files changed, 848 insertions(+) create mode 100644 redisson-tomcat/redisson-tomcat-9/pom.xml create mode 100644 redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSession.java create mode 100644 redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java create mode 100644 redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/RedissonSessionManagerTest.java create mode 100644 redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/TestServlet.java create mode 100644 redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/TomcatServer.java create mode 100644 redisson-tomcat/redisson-tomcat-9/src/test/webapp/META-INF/context.xml create mode 100644 redisson-tomcat/redisson-tomcat-9/src/test/webapp/WEB-INF/redisson.yaml create mode 100644 redisson-tomcat/redisson-tomcat-9/src/test/webapp/WEB-INF/web.xml diff --git a/redisson-tomcat/pom.xml b/redisson-tomcat/pom.xml index 464509ba7..4fce9593b 100644 --- a/redisson-tomcat/pom.xml +++ b/redisson-tomcat/pom.xml @@ -17,6 +17,7 @@ redisson-tomcat-6 redisson-tomcat-7 redisson-tomcat-8 + redisson-tomcat-9 diff --git a/redisson-tomcat/redisson-tomcat-9/pom.xml b/redisson-tomcat/redisson-tomcat-9/pom.xml new file mode 100644 index 000000000..a65f4dbdf --- /dev/null +++ b/redisson-tomcat/redisson-tomcat-9/pom.xml @@ -0,0 +1,81 @@ + + 4.0.0 + + + org.redisson + redisson-tomcat + 2.10.8-SNAPSHOT + ../ + + + redisson-tomcat-9 + jar + + Redisson/Tomcat-9 + + + + org.apache.tomcat.embed + tomcat-embed-core + 9.0.2 + provided + + + org.apache.tomcat.embed + tomcat-embed-logging-juli + 9.0.0.M6 + provided + + + org.apache.tomcat.embed + tomcat-embed-jasper + 9.0.2 + provided + + + org.apache.tomcat + tomcat-jasper + 9.0.2 + provided + + + + + + + com.mycila + license-maven-plugin + 3.0 + + ${basedir} +
${basedir}/../../header.txt
+ false + true + false + + src/main/java/org/redisson/ + + + target/** + + true + + JAVADOC_STYLE + + true + true + UTF-8 + + + + + check + + + + + + + + + diff --git a/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSession.java b/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSession.java new file mode 100644 index 000000000..a88e29561 --- /dev/null +++ b/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSession.java @@ -0,0 +1,215 @@ +/** + * Copyright 2016 Nikita Koksharov + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.redisson.tomcat; + +import java.lang.reflect.Field; +import java.util.HashMap; +import java.util.Map; +import java.util.Map.Entry; +import java.util.concurrent.TimeUnit; + +import org.apache.catalina.session.StandardSession; +import org.redisson.api.RMap; +import org.redisson.tomcat.RedissonSessionManager.ReadMode; + +/** + * Redisson Session object for Apache Tomcat + * + * @author Nikita Koksharov + * + */ +public class RedissonSession extends StandardSession { + + private final RedissonSessionManager redissonManager; + private final Map attrs; + private RMap map; + private final RedissonSessionManager.ReadMode readMode; + + public RedissonSession(RedissonSessionManager manager, RedissonSessionManager.ReadMode readMode) { + super(manager); + this.redissonManager = manager; + this.readMode = readMode; + + try { + Field attr = StandardSession.class.getDeclaredField("attributes"); + attrs = (Map) attr.get(this); + } catch (Exception e) { + throw new IllegalStateException(e); + } + } + + private static final long serialVersionUID = -2518607181636076487L; + + @Override + public Object getAttribute(String name) { + if (readMode == ReadMode.REDIS) { + return map.get(name); + } + + return super.getAttribute(name); + } + + @Override + public void setId(String id, boolean notify) { + super.setId(id, notify); + map = redissonManager.getMap(id); + } + + public void delete() { + map.delete(); + map = null; + } + + @Override + public void setCreationTime(long time) { + super.setCreationTime(time); + + if (map != null) { + Map newMap = new HashMap(3); + newMap.put("session:creationTime", creationTime); + newMap.put("session:lastAccessedTime", lastAccessedTime); + newMap.put("session:thisAccessedTime", thisAccessedTime); + map.putAll(newMap); + } + } + + @Override + public void access() { + super.access(); + + if (map != null) { + Map newMap = new HashMap(2); + newMap.put("session:lastAccessedTime", lastAccessedTime); + newMap.put("session:thisAccessedTime", thisAccessedTime); + map.putAll(newMap); + if (getMaxInactiveInterval() >= 0) { + map.expire(getMaxInactiveInterval(), TimeUnit.SECONDS); + } + } + } + + @Override + public void setMaxInactiveInterval(int interval) { + super.setMaxInactiveInterval(interval); + + if (map != null) { + map.fastPut("session:maxInactiveInterval", maxInactiveInterval); + if (maxInactiveInterval >= 0) { + map.expire(getMaxInactiveInterval(), TimeUnit.SECONDS); + } + } + } + + @Override + public void setValid(boolean isValid) { + super.setValid(isValid); + + if (map != null) { + if (!isValid && !map.isExists()) { + return; + } + + map.fastPut("session:isValid", isValid); + } + } + + @Override + public void setNew(boolean isNew) { + super.setNew(isNew); + + if (map != null) { + map.fastPut("session:isNew", isNew); + } + } + + @Override + public void endAccess() { + boolean oldValue = isNew; + super.endAccess(); + + if (isNew != oldValue) { + map.fastPut("session:isNew", isNew); + } + } + + @Override + public void setAttribute(String name, Object value, boolean notify) { + super.setAttribute(name, value, notify); + + if (map != null && value != null) { + map.fastPut(name, value); + } + } + + @Override + protected void removeAttributeInternal(String name, boolean notify) { + super.removeAttributeInternal(name, notify); + + if (map != null) { + map.fastRemove(name); + } + } + + public void save() { + Map newMap = new HashMap(); + newMap.put("session:creationTime", creationTime); + newMap.put("session:lastAccessedTime", lastAccessedTime); + newMap.put("session:thisAccessedTime", thisAccessedTime); + newMap.put("session:maxInactiveInterval", maxInactiveInterval); + newMap.put("session:isValid", isValid); + newMap.put("session:isNew", isNew); + + if (attrs != null) { + for (Entry entry : attrs.entrySet()) { + newMap.put(entry.getKey(), entry.getValue()); + } + } + + map.putAll(newMap); + + if (maxInactiveInterval >= 0) { + map.expire(getMaxInactiveInterval(), TimeUnit.SECONDS); + } + } + + public void load(Map attrs) { + Long creationTime = (Long) attrs.remove("session:creationTime"); + if (creationTime != null) { + this.creationTime = creationTime; + } + Long lastAccessedTime = (Long) attrs.remove("session:lastAccessedTime"); + if (lastAccessedTime != null) { + this.lastAccessedTime = lastAccessedTime; + } + Long thisAccessedTime = (Long) attrs.remove("session:thisAccessedTime"); + if (thisAccessedTime != null) { + this.thisAccessedTime = thisAccessedTime; + } + Boolean isValid = (Boolean) attrs.remove("session:isValid"); + if (isValid != null) { + this.isValid = isValid; + } + Boolean isNew = (Boolean) attrs.remove("session:isNew"); + if (isNew != null) { + this.isNew = isNew; + } + + for (Entry entry : attrs.entrySet()) { + setAttribute(entry.getKey(), entry.getValue(), false); + } + } + +} diff --git a/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java b/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java new file mode 100644 index 000000000..c170335f7 --- /dev/null +++ b/redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java @@ -0,0 +1,194 @@ +/** + * Copyright 2016 Nikita Koksharov + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.redisson.tomcat; + +import java.io.File; +import java.io.IOException; +import java.util.Map; + +import org.apache.catalina.LifecycleException; +import org.apache.catalina.LifecycleState; +import org.apache.catalina.Session; +import org.apache.catalina.session.ManagerBase; +import org.apache.juli.logging.Log; +import org.apache.juli.logging.LogFactory; +import org.redisson.Redisson; +import org.redisson.api.RMap; +import org.redisson.api.RedissonClient; +import org.redisson.client.codec.Codec; +import org.redisson.config.Config; + +/** + * Redisson Session Manager for Apache Tomcat + * + * @author Nikita Koksharov + * + */ +public class RedissonSessionManager extends ManagerBase { + + public enum ReadMode {REDIS, MEMORY} + + private final Log log = LogFactory.getLog(RedissonSessionManager.class); + + private RedissonClient redisson; + private String configPath; + + private ReadMode readMode = ReadMode.MEMORY; + + public String getReadMode() { + return readMode.toString(); + } + + public void setReadMode(String readMode) { + this.readMode = ReadMode.valueOf(readMode); + } + + public void setConfigPath(String configPath) { + this.configPath = configPath; + } + + public String getConfigPath() { + return configPath; + } + + @Override + public String getName() { + return RedissonSessionManager.class.getSimpleName(); + } + + @Override + public void load() throws ClassNotFoundException, IOException { + } + + @Override + public void unload() throws IOException { + } + + @Override + public Session createSession(String sessionId) { + RedissonSession session = (RedissonSession) createEmptySession(); + + session.setNew(true); + session.setValid(true); + session.setCreationTime(System.currentTimeMillis()); + session.setMaxInactiveInterval(getContext().getSessionTimeout() * 60); + + if (sessionId == null) { + sessionId = generateSessionId(); + } + + session.setId(sessionId); + session.save(); + + return session; + } + + public RMap getMap(String sessionId) { + return redisson.getMap("redisson_tomcat_session:" + sessionId); + } + + @Override + public Session findSession(String id) throws IOException { + Session result = super.findSession(id); + if (result == null && id != null) { + Map attrs = getMap(id).readAllMap(); + + if (attrs.isEmpty() || !Boolean.valueOf(String.valueOf(attrs.get("session:isValid")))) { + log.info("Session " + id + " can't be found"); + return null; + } + + RedissonSession session = (RedissonSession) createEmptySession(); + session.setId(id); + session.load(attrs); + + session.access(); + session.endAccess(); + return session; + } + + return result; + } + + @Override + public Session createEmptySession() { + return new RedissonSession(this, readMode); + } + + @Override + public void remove(Session session, boolean update) { + super.remove(session, update); + + if (session.getIdInternal() != null) { + ((RedissonSession)session).delete(); + } + } + + public RedissonClient getRedisson() { + return redisson; + } + + @Override + protected void startInternal() throws LifecycleException { + super.startInternal(); + redisson = buildClient(); + + setState(LifecycleState.STARTING); + } + + protected RedissonClient buildClient() throws LifecycleException { + Config config = null; + try { + config = Config.fromJSON(new File(configPath), getClass().getClassLoader()); + } catch (IOException e) { + // trying next format + try { + config = Config.fromYAML(new File(configPath), getClass().getClassLoader()); + } catch (IOException e1) { + log.error("Can't parse json config " + configPath, e); + throw new LifecycleException("Can't parse yaml config " + configPath, e1); + } + } + + try { + Config c = new Config(config); + Codec codec = c.getCodec().getClass().getConstructor(ClassLoader.class) + .newInstance(Thread.currentThread().getContextClassLoader()); + config.setCodec(codec); + + return Redisson.create(config); + } catch (Exception e) { + throw new LifecycleException(e); + } + } + + @Override + protected void stopInternal() throws LifecycleException { + super.stopInternal(); + + setState(LifecycleState.STOPPING); + + try { + if (redisson != null) { + redisson.shutdown(); + } + } catch (Exception e) { + throw new LifecycleException(e); + } + + } + +} diff --git a/redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/RedissonSessionManagerTest.java b/redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/RedissonSessionManagerTest.java new file mode 100644 index 000000000..3f0035f37 --- /dev/null +++ b/redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/RedissonSessionManagerTest.java @@ -0,0 +1,165 @@ +package org.redisson.tomcat; + +import java.io.File; +import java.io.IOException; +import java.nio.file.Paths; + +import org.apache.http.client.ClientProtocolException; +import org.apache.http.client.fluent.Executor; +import org.apache.http.client.fluent.Request; +import org.apache.http.cookie.Cookie; +import org.apache.http.impl.client.BasicCookieStore; +import org.junit.Assert; +import org.junit.Test; +import org.redisson.Redisson; +import org.redisson.api.RedissonClient; +import org.redisson.config.Config; + +public class RedissonSessionManagerTest { + + @Test + public void testSwitchServer() throws Exception { + // start the server at http://localhost:8080/myapp + TomcatServer server = new TomcatServer("/myapp", 8080, "src/test/"); + server.start(); + + Executor executor = Executor.newInstance(); + BasicCookieStore cookieStore = new BasicCookieStore(); + executor.use(cookieStore); + + write(executor, "test", "1234"); + Cookie cookie = cookieStore.getCookies().get(0); + + Executor.closeIdleConnections(); + server.stop(); + + server = new TomcatServer("myapp", 8080, "src/test/"); + server.start(); + + executor = Executor.newInstance(); + cookieStore = new BasicCookieStore(); + cookieStore.addCookie(cookie); + executor.use(cookieStore); + read(executor, "test", "1234"); + remove(executor, "test", "null"); + + Executor.closeIdleConnections(); + server.stop(); + } + + + @Test + public void testWriteReadRemove() throws Exception { + // start the server at http://localhost:8080/myapp + TomcatServer server = new TomcatServer("myapp", 8080, "src/test/"); + server.start(); + + Executor executor = Executor.newInstance(); + + write(executor, "test", "1234"); + read(executor, "test", "1234"); + remove(executor, "test", "null"); + + Executor.closeIdleConnections(); + server.stop(); + } + + @Test + public void testRecreate() throws Exception { + // start the server at http://localhost:8080/myapp + TomcatServer server = new TomcatServer("myapp", 8080, "src/test/"); + server.start(); + + Executor executor = Executor.newInstance(); + + write(executor, "test", "1"); + recreate(executor, "test", "2"); + read(executor, "test", "2"); + + Executor.closeIdleConnections(); + server.stop(); + } + + @Test + public void testUpdate() throws Exception { + // start the server at http://localhost:8080/myapp + TomcatServer server = new TomcatServer("myapp", 8080, "src/test/"); + server.start(); + + Executor executor = Executor.newInstance(); + + write(executor, "test", "1"); + read(executor, "test", "1"); + write(executor, "test", "2"); + read(executor, "test", "2"); + + Executor.closeIdleConnections(); + server.stop(); + } + + + @Test + public void testInvalidate() throws Exception { + File f = Paths.get("").toAbsolutePath().resolve("src/test/webapp/WEB-INF/redisson.yaml").toFile(); + Config config = Config.fromYAML(f); + RedissonClient r = Redisson.create(config); + r.getKeys().flushall(); + + // start the server at http://localhost:8080/myapp + TomcatServer server = new TomcatServer("myapp", 8080, "src/test/"); + server.start(); + + Executor executor = Executor.newInstance(); + BasicCookieStore cookieStore = new BasicCookieStore(); + executor.use(cookieStore); + + write(executor, "test", "1234"); + Cookie cookie = cookieStore.getCookies().get(0); + invalidate(executor); + + Executor.closeIdleConnections(); + + executor = Executor.newInstance(); + cookieStore = new BasicCookieStore(); + cookieStore.addCookie(cookie); + executor.use(cookieStore); + read(executor, "test", "null"); + invalidate(executor); + + Executor.closeIdleConnections(); + server.stop(); + + Assert.assertEquals(0, r.getKeys().count()); + } + + private void write(Executor executor, String key, String value) throws IOException, ClientProtocolException { + String url = "http://localhost:8080/myapp/write?key=" + key + "&value=" + value; + String response = executor.execute(Request.Get(url)).returnContent().asString(); + Assert.assertEquals("OK", response); + } + + private void read(Executor executor, String key, String value) throws IOException, ClientProtocolException { + String url = "http://localhost:8080/myapp/read?key=" + key; + String response = executor.execute(Request.Get(url)).returnContent().asString(); + Assert.assertEquals(value, response); + } + + private void remove(Executor executor, String key, String value) throws IOException, ClientProtocolException { + String url = "http://localhost:8080/myapp/remove?key=" + key; + String response = executor.execute(Request.Get(url)).returnContent().asString(); + Assert.assertEquals(value, response); + } + + private void invalidate(Executor executor) throws IOException, ClientProtocolException { + String url = "http://localhost:8080/myapp/invalidate"; + String response = executor.execute(Request.Get(url)).returnContent().asString(); + Assert.assertEquals("OK", response); + } + + private void recreate(Executor executor, String key, String value) throws IOException, ClientProtocolException { + String url = "http://localhost:8080/myapp/recreate?key=" + key + "&value=" + value; + String response = executor.execute(Request.Get(url)).returnContent().asString(); + Assert.assertEquals("OK", response); + } + +} diff --git a/redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/TestServlet.java b/redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/TestServlet.java new file mode 100644 index 000000000..1c68da965 --- /dev/null +++ b/redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/TestServlet.java @@ -0,0 +1,94 @@ +package org.redisson.tomcat; + +import java.io.IOException; + +import javax.servlet.ServletException; +import javax.servlet.http.HttpServlet; +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; +import javax.servlet.http.HttpSession; + +public class TestServlet extends HttpServlet { + + private static final long serialVersionUID = 1243830648280853203L; + + @Override + protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { + HttpSession session = req.getSession(); + + if (req.getPathInfo().equals("/write")) { + String[] params = req.getQueryString().split("&"); + String key = null; + String value = null; + for (String param : params) { + String[] paramLine = param.split("="); + String keyParam = paramLine[0]; + String valueParam = paramLine[1]; + + if ("key".equals(keyParam)) { + key = valueParam; + } + if ("value".equals(keyParam)) { + value = valueParam; + } + } + session.setAttribute(key, value); + + resp.getWriter().print("OK"); + } else if (req.getPathInfo().equals("/read")) { + String[] params = req.getQueryString().split("&"); + String key = null; + for (String param : params) { + String[] line = param.split("="); + String keyParam = line[0]; + if ("key".equals(keyParam)) { + key = line[1]; + } + } + + Object attr = session.getAttribute(key); + resp.getWriter().print(attr); + } else if (req.getPathInfo().equals("/remove")) { + String[] params = req.getQueryString().split("&"); + String key = null; + for (String param : params) { + String[] line = param.split("="); + String keyParam = line[0]; + if ("key".equals(keyParam)) { + key = line[1]; + } + } + + session.removeAttribute(key); + resp.getWriter().print(String.valueOf(session.getAttribute(key))); + } else if (req.getPathInfo().equals("/invalidate")) { + session.invalidate(); + + resp.getWriter().print("OK"); + } else if (req.getPathInfo().equals("/recreate")) { + session.invalidate(); + + session = req.getSession(); + + String[] params = req.getQueryString().split("&"); + String key = null; + String value = null; + for (String param : params) { + String[] paramLine = param.split("="); + String keyParam = paramLine[0]; + String valueParam = paramLine[1]; + + if ("key".equals(keyParam)) { + key = valueParam; + } + if ("value".equals(keyParam)) { + value = valueParam; + } + } + session.setAttribute(key, value); + + resp.getWriter().print("OK"); + } + } + +} diff --git a/redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/TomcatServer.java b/redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/TomcatServer.java new file mode 100644 index 000000000..d18978fb3 --- /dev/null +++ b/redisson-tomcat/redisson-tomcat-9/src/test/java/org/redisson/tomcat/TomcatServer.java @@ -0,0 +1,67 @@ +package org.redisson.tomcat; + +import java.net.MalformedURLException; + +import javax.servlet.ServletException; + +import org.apache.catalina.LifecycleException; +import org.apache.catalina.startup.Tomcat; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class TomcatServer { + + private Tomcat tomcat = new Tomcat(); + private int port; + private boolean isRunning; + + private static final Logger LOG = LoggerFactory.getLogger(TomcatServer.class); + private static final boolean isInfo = LOG.isInfoEnabled(); + + public TomcatServer(String contextPath, int port, String appBase) throws MalformedURLException, ServletException { + if(contextPath == null || appBase == null || appBase.length() == 0) { + throw new IllegalArgumentException("Context path or appbase should not be null"); + } + if(!contextPath.startsWith("/")) { + contextPath = "/" + contextPath; + } + + tomcat.setBaseDir("."); // location where temp dir is created + tomcat.setPort(port); + tomcat.getHost().setAppBase("."); + + tomcat.addWebapp(contextPath, appBase + "/webapp"); + } + + /** + * Start the tomcat embedded server + * @throws InterruptedException + */ + public void start() throws LifecycleException, InterruptedException { + tomcat.start(); + tomcat.getConnector(); + isRunning = true; + } + + /** + * Stop the tomcat embedded server + */ + public void stop() throws LifecycleException { + if(!isRunning) { + LOG.warn("Tomcat server is not running @ port={}", port); + return; + } + + if(isInfo) LOG.info("Stopping the Tomcat server"); + + tomcat.stop(); + tomcat.destroy(); + tomcat.getServer().await(); + isRunning = false; + } + + public boolean isRunning() { + return isRunning; + } + +} \ No newline at end of file diff --git a/redisson-tomcat/redisson-tomcat-9/src/test/webapp/META-INF/context.xml b/redisson-tomcat/redisson-tomcat-9/src/test/webapp/META-INF/context.xml new file mode 100644 index 000000000..52b0eafd8 --- /dev/null +++ b/redisson-tomcat/redisson-tomcat-9/src/test/webapp/META-INF/context.xml @@ -0,0 +1,7 @@ + + + + + + \ No newline at end of file diff --git a/redisson-tomcat/redisson-tomcat-9/src/test/webapp/WEB-INF/redisson.yaml b/redisson-tomcat/redisson-tomcat-9/src/test/webapp/WEB-INF/redisson.yaml new file mode 100644 index 000000000..28466f3ba --- /dev/null +++ b/redisson-tomcat/redisson-tomcat-9/src/test/webapp/WEB-INF/redisson.yaml @@ -0,0 +1,2 @@ +singleServerConfig: + address: "redis://127.0.0.1:6379" \ No newline at end of file diff --git a/redisson-tomcat/redisson-tomcat-9/src/test/webapp/WEB-INF/web.xml b/redisson-tomcat/redisson-tomcat-9/src/test/webapp/WEB-INF/web.xml new file mode 100644 index 000000000..9ff76e720 --- /dev/null +++ b/redisson-tomcat/redisson-tomcat-9/src/test/webapp/WEB-INF/web.xml @@ -0,0 +1,22 @@ + + + + + testServlet + org.redisson.tomcat.TestServlet + 1 + + + + testServlet + /* + + + + 30 + + + -- GitLab