关闭redis事务

007gzs · Jan 24, 2017 · cebce9b · cebce9b
1 parent 25f7482
commit cebce9b
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 11 deletions.
diff --git a/iBase4J-Biz-Web/src/main/java/org/ibase4j/core/listener/SessionListener.java b/iBase4J-Biz-Web/src/main/java/org/ibase4j/core/listener/SessionListener.java
@@ -55,19 +55,19 @@ public void sessionDestroyed(HttpSessionEvent event) {
  }
 
  private void setAllUserNumber(int n) {
- Long number = getAllUserNumber() + n;
+ Integer number = getAllUserNumber() + n;
  if (number >= 0) {
  logger.info("用户数：" + number);
  CacheUtil.getCache().set(Constants.ALLUSER_NUMBER, number, 60 * 60 * 24);
  }
  }
 
  /** 获取在线用户数量 */
- public static Long getAllUserNumber() {
- String v = (String) CacheUtil.getCache().get(Constants.ALLUSER_NUMBER);
+ public static Integer getAllUserNumber() {
+ Integer v = (Integer) CacheUtil.getCache().get(Constants.ALLUSER_NUMBER);
  if (v != null) {
- return Long.valueOf(v);
+ return v;
  }
- return 0L;
+ return 0;
  }
 }
diff --git a/iBase4J-Common/src/main/resources/spring/redis.xml b/iBase4J-Common/src/main/resources/spring/redis.xml
@@ -48,7 +48,7 @@
  <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"
  p:connection-factory-ref="jedisConnectionFactory"
  p:key-serializer-ref="keySerializer" p:value-serializer-ref="valueSerializer"
- p:enableTransactionSupport="true" />
+ p:enableTransactionSupport="false" />
  <!-- 缓存 -->
  <bean id="redisCacheManager" class="org.springframework.data.redis.cache.RedisCacheManager">
  <constructor-arg index="0" ref="redisTemplate" />

diff --git a/iBase4J-SYS-Web/src/main/java/org/ibase4j/core/listener/SessionListener.java b/iBase4J-SYS-Web/src/main/java/org/ibase4j/core/listener/SessionListener.java
@@ -49,19 +49,19 @@ public void sessionDestroyed(HttpSessionEvent event) {
  }
 
  private void setAllUserNumber(int n) {
- Long number = getAllUserNumber() + n;
+ Integer number = getAllUserNumber() + n;
  if (number >= 0) {
  logger.info("用户数：" + number);
  CacheUtil.getCache().set(Constants.ALLUSER_NUMBER, number, 60 * 60 * 24);
  }
  }
 
  /** 获取在线用户数量 */
- public static Long getAllUserNumber() {
- Long v = (Long) CacheUtil.getCache().get(Constants.ALLUSER_NUMBER);
+ public static Integer getAllUserNumber() {
+ Integer v = (Integer) CacheUtil.getCache().get(Constants.ALLUSER_NUMBER);
  if (v != null) {
  return v;
  }
- return 0L;
+ return 0;
  }
 }
diff --git a/iBase4J-SYS-Web/src/main/java/org/ibase4j/web/sys/SysSessionController.java b/iBase4J-SYS-Web/src/main/java/org/ibase4j/web/sys/SysSessionController.java
@@ -41,7 +41,7 @@ public class SysSessionController extends BaseController {
  public Object get(HttpServletRequest request, ModelMap modelMap) {
  Map<String, Object> params = WebUtil.getParameterMap(request);
  Page<?> list = sysSessionService.query(params);
- Long number = SessionListener.getAllUserNumber();
+ Integer number = SessionListener.getAllUserNumber();
  modelMap.put("userNumber", number); // 用户数大于会话数,有用户没有登录
  return setSuccessModelMap(modelMap, list);
  }