利用Redis构建自定义标签（2）

最近工作有点忙，不过Redis构建自定义标签也基本已经实现

 

（1）整体设计

 

 

 

（2）Jedis配置

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:jee="http://www.springframework.org/schema/jee"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:jpa="http://www.springframework.org/schema/data/jpa"
xsi:schemaLocation="  
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd  
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.1.xsd  
        http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-4.1.xsd  
        http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.1.xsd  
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.1.xsd  
        http://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa.xsd"
>

<context:component-scan base-package="com.crm.redis" />
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<!--最大连接数 -->
<property name="maxTotal" value="2000" />
<!--最大空闲数 -->
<property name="maxIdle" value="300" />
<property name="minIdle" value="100" />
<!--最大等待时间ms -->
<property name="maxWaitMillis" value="30000" />
<property name="testOnBorrow" value="true" />
<property name="testOnReturn" value="true" />
<property name="testWhileIdle" value="true" />
</bean>

<bean id="shardedJedisPool" class="redis.clients.jedis.ShardedJedisPool"
destroy-method="destroy">
<constructor-arg ref="jedisPoolConfig" />

<constructor-arg>
<list>
<bean class="redis.clients.jedis.JedisShardInfo">
<constructor-arg value="localhost" />
<constructor-arg type="int" value="6379" />
<constructor-arg value="instance:02" />
</bean>

</list>
</constructor-arg>
</bean>

</beans>

 

 

 

（2）Redis配置

 

 

 

（3）Redis加载线程

package com.crm.redis.load;
import java.util.HashMap;
import java.util.List;
import com.crm.application.CrmContext;
import com.crm.common.bo.building.BOBuilding;
import com.crm.model.dictionary.BOCrmStaticData;
import com.crm.model.redis.BOCrmRedisCfg;
import com.crm.redis.JedisManager;
import com.crm.redis.load.interfaces.IRedisLoadSV;
import com.crm.service.base.BaseSVImpl;
import com.crm.service.dictionary.StaticDataSVImpl;
import com.crm.service.redis.RedisCfgSVImpl;
public class RedisLoadThread extends Thread {
 @Override
 public void run() {
  System.out.println("Redis加载线程准备执行....");
  loadDictionarys();
  loadCityControlFunctionCodes();
  loadBuildings();
 }
 private void loadBuildings() {
  JedisManager JedisManager = CrmContext.getBean("JedisManager", JedisManager.class);
  BaseSVImpl BaseSVImpl = CrmContext.getBean("BaseSVImpl", BaseSVImpl.class);
  RedisCfgSVImpl RedisCfgSVImpl = CrmContext.getBean("RedisCfgSVImpl", RedisCfgSVImpl.class);
  String sql = "SELECT * FROM DWB_WEB_PROJECT A";
  List<BOCrmRedisCfg> BOCrmRedisCfgs = RedisCfgSVImpl
    .getEntitys(" from BOCrmRedisCfg a where a.state = 'U' and a.code = 'B'", new HashMap());
  List<BOBuilding> BOBuildings = BaseSVImpl.executeNativeSelect(sql, new HashMap(), BOBuilding.class);
  for (BOCrmRedisCfg c : BOCrmRedisCfgs) {
   IRedisLoadSV sv = (IRedisLoadSV) CrmContext.getBean(c.getImplClass());
   sv.load(c, BOBuildings);
  }
 }
 private void loadCityControlFunctionCodes() {
  JedisManager JedisManager = CrmContext.getBean("JedisManager", JedisManager.class);
  RedisCfgSVImpl RedisCfgSVImpl = CrmContext.getBean("RedisCfgSVImpl", RedisCfgSVImpl.class);
  List<String> cityControlFunctionCodes = RedisCfgSVImpl.getCityControlFunctionCodes();
  JedisManager.lpush("cityControlFunctionCodes", cityControlFunctionCodes);
 }
 private void loadDictionarys() {
  JedisManager JedisManager = CrmContext.getBean("JedisManager", JedisManager.class);
  RedisCfgSVImpl RedisCfgSVImpl = CrmContext.getBean("RedisCfgSVImpl", RedisCfgSVImpl.class);
  StaticDataSVImpl StaticDataSVImpl = CrmContext.getBean("StaticDataSVImpl", StaticDataSVImpl.class);
  List<BOCrmRedisCfg> BOCrmRedisCfgs = RedisCfgSVImpl
    .getEntitys(" from BOCrmRedisCfg a where a.state = 'U' and a.code = 'D'", new HashMap());
  List<BOCrmStaticData> BOCrmStaticDatas = StaticDataSVImpl
    .getEntitys(" from BOCrmStaticData a where a.state = 'U' ", new HashMap());
  for (BOCrmRedisCfg c : BOCrmRedisCfgs) {
   IRedisLoadSV sv = (IRedisLoadSV) CrmContext.getBean(c.getImplClass());
   sv.load(c, BOCrmStaticDatas);
  }
 }
 @Override
 public void destroy() {
  System.out.println("线程销毁....");
 }
}

 

 

（4）编写自定义TLD

 

<tag>
  <name>multipleSelect</name>
  <tag-class>com.crm.taglib.CrmMultipleSelectTag</tag-class>
  <body-content>JSP</body-content>

  <attribute>
   <name>id</name>
   <required>true</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
  <attribute>
   <name>className</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
  <attribute>
   <name>crmTagCode</name>
   <required>true</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
 
  <attribute>
   <name>redisKey</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
 
  <attribute>
   <name>valueColumn</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
  <attribute>
   <name>textColumn</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
  <attribute>
   <name>tableName</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
  <attribute>
   <name>condition</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
  <attribute>
   <name>sql</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
  <attribute>
   <name>cityControl</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
 
 
  <attribute>
   <name>width</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
  <attribute>
   <name>onchange</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
  <attribute>
   <name>selectedValues</name>
   <required>false</required>
   <rtexprvalue>true</rtexprvalue>
   <type>java.lang.String</type>
  </attribute>
 </tag>

 

 

（5）自定义标签处理类

package com.crm.taglib;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.jsp.JspWriter;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.web.servlet.tags.RequestContextAwareTag;
import com.crm.common.bo.BOSelect;
import com.crm.common.bo.building.BOBuilding;
import com.crm.common.bo.operator.BOCity;
import com.crm.common.util.CrmConst;
import com.crm.common.util.SessionUtil;
import com.crm.model.dictionary.BOCrmStaticData;
import com.crm.redis.JedisManager;
import com.crm.service.base.BaseSVImpl;
@SuppressWarnings("serial")
public class CrmMultipleSelectTag extends RequestContextAwareTag {
 private Log log = LogFactory.getLog(CrmMultipleSelectTag.class);
 private String id;
 private String className;
 private String crmTagCode;
 private String redisKey;
 private String valueColumn;
 private String textColumn;
 private String tableName;
 private String condition;
 private String sql;
 private String cityControl;
 private String width;
 private String onchange;
 private String selectedValues;
 public String getId() {
  return id;
 }
 public void setId(String id) {
  this.id = id;
 }
 public String getClassName() {
  return className;
 }
 public void setClassName(String className) {
  this.className = className;
 }
 public String getCrmTagCode() {
  return crmTagCode;
 }
 public void setCrmTagCode(String crmTagCode) {
  this.crmTagCode = crmTagCode;
 }
 public String getRedisKey() {
  return redisKey;
 }
 public void setRedisKey(String redisKey) {
  this.redisKey = redisKey;
 }
 public String getValueColumn() {
  return valueColumn;
 }
 public void setValueColumn(String valueColumn) {
  this.valueColumn = valueColumn;
 }
 public String getTextColumn() {
  return textColumn;
 }
 public void setTextColumn(String textColumn) {
  this.textColumn = textColumn;
 }
 public String getTableName() {
  return tableName;
 }
 public void setTableName(String tableName) {
  this.tableName = tableName;
 }
 public String getCondition() {
  return condition;
 }
 public void setCondition(String condition) {
  this.condition = condition;
 }
 public String getSql() {
  return sql;
 }
 public void setSql(String sql) {
  this.sql = sql;
 }
 public String getCityControl() {
  return cityControl;
 }
 public void setCityControl(String cityControl) {
  this.cityControl = cityControl;
 }
 public String getWidth() {
  return width;
 }
 public void setWidth(String width) {
  this.width = width;
 }
 public String getOnchange() {
  return onchange;
 }
 public void setOnchange(String onchange) {
  this.onchange = onchange;
 }
 public String getSelectedValues() {
  return selectedValues;
 }
 public void setSelectedValues(String selectedValues) {
  this.selectedValues = selectedValues;
 }
 @Override
 protected int doStartTagInternal() throws Exception {
  HttpServletRequest req = (HttpServletRequest) pageContext.getRequest();
  BOCity c = SessionUtil.getCityInSession(req);
  long cityId = c.getCityId();
  log.info("开始执行【crm:multipleSelect】标签");
  JspWriter out = pageContext.getOut();
  try {
   String str = null;
   if (CrmConst.CrmTag.SELECT_REDIS.equals(crmTagCode)) {
    str = doSelectRedis(cityId);
   }
   if (CrmConst.CrmTag.SELECT_TABLE.equals(crmTagCode)) {
    str = doSelectSql(cityId);
   }
   out.write(str);
  } catch (Exception e) {
   e.printStackTrace();
  }
  return 0;
 }
 public String geneSQL(long cityId) {
  StringBuilder sql = new StringBuilder();
  sql.append(" SELECT T.").append(valueColumn).append(" SELECT_VALUE, ");
  sql.append(" T.").append(textColumn).append(" SELECT_TEXT ");
  sql.append(" FROM ").append(tableName).append(" T ");
  sql.append(" where 1=1 ");
  if (CrmConst.commonYesOrNoString.YES.equals(cityControl)) {
   sql.append(" AND T.CITY_ID = ").append(cityId);
  }
  if (!StringUtils.isEmpty(condition)) {
   sql.append(condition);
  }
  return sql.toString();
 }
 private String doSelectSql(long cityId) {
  BaseSVImpl BaseSVImpl = this.getRequestContext().getWebApplicationContext().getBean("BaseSVImpl",
    BaseSVImpl.class);
  List<String> selectValuesList = new ArrayList<String>();
  if (selectedValues != null) {
   selectValuesList = Arrays.asList(selectedValues.split(","));
  }
  StringBuffer sb = new StringBuffer();
  List<BOSelect> list = BaseSVImpl.executeNativeSelect(geneSQL(cityId), new HashMap(), BOSelect.class);
  sb.append("<select id='" + id + "' onchange='" + onchange + "' class='" + className
    + "' multiple='' data-placeholder='请选择...'>");
  for (BOSelect s : list) {
   if (selectValuesList.contains(s.getSelectValue())) {
    sb.append("<option value='" + s.getSelectValue() + "' selected='selected'>" + s.getSelectText()
      + "</option>");
   } else {
    sb.append("<option value='" + s.getSelectValue() + "'>" + s.getSelectText() + "</option>");
   }
  }
  sb.append("</select>");
  return sb.toString();
 }
 private String doSelectRedis(long cityId) {
  List<String> selectValuesList = new ArrayList<String>();
  selectValuesList = Arrays.asList(selectedValues.split(","));
  JedisManager JedisManager = this.getRequestContext().getWebApplicationContext().getBean("JedisManager",
    JedisManager.class);
  List<String> cityControlFunctionCodes = JedisManager.lrange("cityControlFunctionCodes", 0, -1);
  String[] redisKeyArray = redisKey.split(":");
  StringBuffer _redisKey = new StringBuffer(redisKey);
  if (cityControlFunctionCodes.contains(redisKeyArray[1])) {
   _redisKey.append(":").append(cityId);
  } else {
   _redisKey.append(":").append(0);
  }
  StringBuffer sb = new StringBuffer();
  if (CrmConst.RedisCfgCode.DICTIONARY.equals(redisKeyArray[0])) {
   List<BOCrmStaticData> list = (List<BOCrmStaticData>) JedisManager.getObject(_redisKey.toString());
   sb.append("<select id='" + id + "' onchange='" + onchange + "' class='" + className
     + "' multiple='' data-placeholder='请选择...'>");
   for (BOCrmStaticData s : list) {
    if (selectValuesList.contains(s.getValue())) {
     sb.append("<option value='" + s.getValue() + "' selected='selected'>" + s.getName() + "</option>");
    } else {
     sb.append("<option value='" + s.getValue() + "'>" + s.getName() + "</option>");
    }
   }
   sb.append("</select>");
  }
  if (CrmConst.RedisCfgCode.BUILDING.equals(redisKeyArray[0])) {
   List<BOBuilding> list = (List<BOBuilding>) JedisManager.getObject(_redisKey.toString());
   sb.append("<select id='" + id + "' onchange='" + onchange + "' class='" + className
     + "' multiple='' data-placeholder='请选择...'>");
   for (BOBuilding s : list) {
    if (selectValuesList.contains(s.getPrjId())) {
     sb.append("<option value='" + s.getPrjId() + "' selected='selected'>" + s.getPrjItemname()
       + "</option>");
    } else {
     sb.append("<option value='" + s.getPrjId() + "'>" + s.getPrjItemname() + "</option>");
    }
   }
   sb.append("</select>");
  }
  return sb.toString();
 }
}

 

 

（6）页面使用

 

<crm:singleSelect id="buildingId" crmTagCode="SELECT_REDIS" redisKey="B:100"

          className="chosen-select col-xs-10 col-sm-5" selectedValues="${BOCrmProject.buildingId}">

</crm:singleSelect>

 

（7）页面效果以及Redis存储

 

 

 

 

 

评论

1 楼 liyonghui160com 2017-01-11  

请问 redis的结构是什么样的？