1、配置文件
2、配置管理类
3、使用
====================1、配置文件====================
一般在applicationContext-MyBatis.xml文件配置，由于编译问题，把<换成了《,读作自行换回即可。
《!– redis配置 –>
《bean id=”jedisPoolConfig” class=”redis.clients.jedis.JedisPoolConfig”>
《property name=”maxActive” value=”90”/>
《property name=”maxIdle” value=”5”/>
《property name=”maxWait” value=”1000”/>
《property name=”testOnBorrow” value=”true”/>
《/bean>
《bean id=”jedisPool” class=”redis.clients.jedis.JedisPool” destroy-method=”destroy”>
《constructor-arg ref=”jedisPoolConfig”/>
《constructor-arg value=”127.0.0.1”/>
《constructor-arg value=”6379”/>
《/bean>
《bean id=”redisAPI” class=”org.slsale.common.RedisAPI”>
《property name=”jedisPool” ref=”jedisPool”/>
《/bean>
=============2、配置管理类===========================
package org.slsale.common;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
public class RedisAPI {
public JedisPool jedisPool;//redis的连接池对象
public JedisPool getJedisPool() {return jedisPool;
}public void setJedisPool(JedisPool jedisPool) {this.jedisPool = jedisPool;
}
/*** set key and value to redis* @param key* @param value* @return*/
public boolean set(String key,String value){Jedis jedis = null;try {jedis = jedisPool.getResource();jedis.set(key, value);return true;} catch (Exception e) {// TODO: handle exceptione.printStackTrace();}return false;
}
/*** 判断某个key是否存在* @param key* @return*/
public boolean exist(String key){Jedis jedis = null;try {jedis = jedisPool.getResource();return jedis.exists(key);} catch (Exception e) {// TODO: handle exceptione.printStackTrace();}return false;
}public static void returnResource(JedisPool pool,Jedis jedis){if(jedis != null){pool.returnResource(jedis);}
}/*** 获取数据* @param key* @return*/
public String get (String key){String value = null;Jedis jedis = null;try {jedis = jedisPool.getResource();value = jedis.get(key);} catch (Exception e) {// TODO: handle exceptione.printStackTrace();}finally{//返还到连接池returnResource(jedisPool, jedis);}return value;
}
}
========================3、使用======================
本文忽略部分代码，只写出部分的使用场景，使用场景：用户登陆获取菜单，本人为个人代码存放，如有错误或其他敬请谅解！
package org.slsale.controller;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import javax.servlet.http.HttpSession;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.apache.log4j.Logger;
import org.slsale.common.Constants;
import org.slsale.common.RedisAPI;
import org.slsale.pojo.Affiche;
import org.slsale.pojo.Authority;
import org.slsale.pojo.Function;
import org.slsale.pojo.Information;
import org.slsale.pojo.Menu;
import org.slsale.pojo.User;
import org.slsale.service.affiche.AfficheService;
import org.slsale.service.function.FunctionService;
import org.slsale.service.information.InformationService;
import org.slsale.service.user.UserService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;
@Controller
public class LoginController extends BaseController {
private Logger logger = Logger.getLogger(LoginController.class);
@Resource
private UserService userService;
@Resource
private FunctionService functionService;
@Resource
private RedisAPI redisAPI;
@Resource
private InformationService informationService;
@Resource
private AfficheService afficheService;@RequestMapping("/main.html")
public ModelAndView main(HttpSession session){logger.debug("main======================== " );List<Information> infoList = null;List<Affiche> afficheList = null;Information information = new Information();Affiche affiche = new Affiche();information.setStarNum(0);information.setPageSize(5);information.setState(1);affiche.setStarNum(0);affiche.setPageSize(5);try {infoList = informationService.getInformationList(information);afficheList = afficheService.getPortalAfficheList(affiche);} catch (Exception e) {infoList = null;afficheList = null;}//menu listUser user = this.getCurrentUser();List<Menu> mList = null;if(null != user){Map<String, Object> model = new HashMap<String, Object>();model.put("user", user);/*** key:menuList+roleID---eg:"menuList2"* value:mList*///redis里有没有数据if(!redisAPI.exist("menuList"+user.getRoleId())){//redis没数据//根据当前用户获取菜单列表mListmList = getFuncByCurrentUser(user.getRoleId());//jsonif(null != mList){JSONArray jsonArray = JSONArray.fromObject(mList);String jsonString = jsonArray.toString();logger.debug("jsonString : " + jsonString);model.put("mList", jsonString);redisAPI.set("menuList"+user.getRoleId(), jsonString);}}else{// redis里有数据,直接从redis里取数据String redisMenuListKeyString = redisAPI.get("menuList"+user.getRoleId());logger.debug("menuList from redis: " + redisMenuListKeyString);if(null != redisMenuListKeyString && !"".equals(redisMenuListKeyString)){model.put("mList", redisMenuListKeyString);}else {return new ModelAndView("redirect:/");}}if(!redisAPI.exist("Role"+user.getRoleId()+"UrlList")){try {//get all role url list to redisAuthority authority = new Authority();authority.setRoleId(user.getRoleId());List<Function> functionList = functionService.getFunctionListByRoleId(authority);if(functionList != null){StringBuffer sBuffer = new StringBuffer();for(Function f:functionList){sBuffer.append(f.getFuncUrl());}redisAPI.set("Role"+user.getRoleId()+"UrlList", sBuffer.toString());}} catch (Exception e) {// TODO: handle exceptione.printStackTrace();}}model.put("infoList", infoList);model.put("afficheList", afficheList);session.setAttribute(Constants.SESSION_BASE_MODEL, model);return new ModelAndView("main",model);}return new ModelAndView("redirect:/");
}/*** 根据当前用户角色id获取功能列表（对应的菜单）* @param roleId* @return*/
protected List<Menu> getFuncByCurrentUser(int roleId){List<Menu> menuList = new ArrayList<Menu>();Authority authority = new Authority();authority.setRoleId(roleId);try {List<Function> mList = functionService.getMainFunctionList(authority);if(mList != null){for(Function function:mList){Menu menu = new Menu();menu.setMainMenu(function);function.setRoleId(roleId);List<Function> subList = functionService.getSubFunctionList(function);if(null != subList){menu.setSubMenus(subList);}menuList.add(menu);}}} catch (Exception e) {// TODO: handle exception}return menuList;
}@RequestMapping("/login.html")
@ResponseBody
public Object login(HttpSession session,@RequestParam String user){logger.debug("login===================");if(user == null || "".equals(user)){return "nodata";}else{JSONObject userObject = JSONObject.fromObject(user);User userObj= (User)userObject.toBean(userObject, User.class);try {if(userService.loginCodeIsExit(userObj) == 0){//不存在这个登录账号return "nologincode";}else{User _user = userService.getLoginUser(userObj);if(null != _user){//登录成功//当前用户存到session中session.setAttribute(Constants.SESSION_USER, _user);//更新当前用户登录的lastLoginTimeUser updateLoginTimeUser = new User();updateLoginTimeUser.setId(_user.getId());updateLoginTimeUser.setLastLoginTime(new Date());userService.modifyUser(updateLoginTimeUser);updateLoginTimeUser = null;return "success";}else{//密码错误return "pwderror";}}} catch (Exception e) {// TODO: handle exceptionreturn "failed";}}
}
/*** 注销* @param session* @return*/
@RequestMapping("/logout.html")
public String logout(HttpSession session){session.removeAttribute(Constants.SESSION_USER);session.invalidate();this.setCurrentUser(null);return "index";
}
//没有权限访问
@RequestMapping("/401.html")
public ModelAndView noRole(){return new ModelAndView("401");
}
}