1. 程式人生 > >redis在專案中的運用

redis在專案中的運用

controller程式碼

@Autowired
private RedisService redisService;

// 存入redis快取  將使用者資料都存到快取中,便於快速查詢
redisService.initializationAccount(pd);
//redis取值
redisService.getAccont(pd.getString("uid"));//從redis中取值

service層

@Service("RedisService")
public class RedisService {
	
	@Autowired
	private JedisPool jedisPool;
public void setAccount(String key,UserAccount accont){ if(StringUtils.isNotBlank(key) && accont != null){ RedisUtils redisUtils = new RedisUtils(jedisPool); redisUtils.setObject("U"+key, accont, 0); } } public UserAccount getAccont(String id){ UserAccount accont; RedisUtils
redisUtils = new RedisUtils(jedisPool); accont = (UserAccount)redisUtils.getObject("U"+id); if(accont == null ){ accont = new UserAccount(); } return accont; } public UserAccount getAccont2(String id){ RedisUtils redisUtils = new RedisUtils(jedisPool); return (UserAccount)redisUtils.
getObject("U"+id); } public Integer setLong(Object value){ Long long1 = (Long)value; String string = long1.toString(); Integer integer = Integer.parseInt(string); return integer; } @Autowired private IntRedisAccountService accountService; public UserAccount initializationAccount(PageData pd){ UserAccount account = new UserAccount(); try { //註釋:此處程式碼是從資料庫取出需要存的值(按需求定) PageData pageData = accountService.redisAccountList(pd); // account.setU_id(pageData.getString("u_id")); account.setID(pageData.getString("ID")); account.setHx_id(pageData.getString("hx_id")); account.setNick_name(pageData.getString("nick_name")); account.setName(pageData.getString("name")); account.setPassword(pageData.getString("password")); account.setId_card(pageData.getString("id_card")); account.setPhone(pageData.getString("phone")); account.setPic_url(pageData.getString("pic_url")); account.setLastlogin_time(pageData.getString("lastlogin_time")); account.setScode(pageData.getString("scode")); account.setCountry(pageData.getString("country")); account.setReferee(pageData.getString("referee")); account.setRefereenum(pageData.getLong("refereenum").intValue());// account.setWalletaddress(pageData.getString("walletaddress")); account.setRegistertime(pageData.getString("registertime")); account.setStatus(pageData.getLong("status").intValue());// account.setAssets(pageData.getFloat("assets"));// account.setColdassets(pageData.getFloat("coldassets")); account.setHotassets(pageData.getFloat("hotassets")); account.setUsertype(pageData.getLong("usertype").intValue());//long轉換成integer account.setRegisterip(pageData.getString("registerip")); account.setLastloginip(pageData.getString("lastloginip")); account.setAuditstatus(pageData.getLong("auditstatus").intValue());// account.setAudituid(pageData.getInteger("audituid")); account.setAudittime(pageData.getString("audittime")); setAccount(pageData.getString("u_id"), account); } catch (Exception e) { e.printStackTrace(); } return account; }

dao層

	/*
	*列表(全部)
	*/
	public PageData redisAccountList(PageData pd)throws Exception{
		return (PageData)dao.findForObject("RedisAccountMapper.RedisAccount", pd);
	}

mapper

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="RedisAccountMapper">
	
	<select id="RedisAccount" parameterType="pd" resultType="pd">
	SELECT 
			IFNULL((SELECT u_id FROM bit_user WHERE u_id= #{u_id}),0) AS u_id,
			IFNULL((SELECT ID FROM bit_user WHERE u_id= #{u_id}),0) AS ID,
			IFNULL((SELECT hx_id FROM bit_user WHERE u_id= #{u_id}),0) AS hx_id,
			IFNULL((SELECT nick_name FROM bit_user WHERE u_id= #{u_id}),0) AS nick_name,
			IFNULL((SELECT name FROM bit_user WHERE u_id= #{u_id}),0) AS name,
			IFNULL((SELECT password FROM bit_user WHERE u_id= #{u_id}),0) AS password,
			IFNULL((SELECT id_card FROM bit_user WHERE u_id= #{u_id}),0) AS id_card,
			IFNULL((SELECT phone FROM bit_user WHERE u_id= #{u_id}),0) AS phone,
			IFNULL((SELECT pic_url FROM bit_user WHERE u_id= #{u_id}),0) AS pic_url,
			IFNULL((SELECT lastlogin_time FROM bit_user WHERE u_id= #{u_id}),0) AS lastlogin_time,
			IFNULL((SELECT scode FROM bit_user WHERE u_id= #{u_id}),0) AS scode,
			IFNULL((SELECT country FROM bit_user WHERE u_id= #{u_id}),0) AS country,
			IFNULL((SELECT referee FROM bit_user WHERE u_id= #{u_id}),0) AS referee,
			IFNULL((SELECT refereenum FROM bit_user WHERE u_id= #{u_id}),0) AS refereenum,
			IFNULL((SELECT walletaddress FROM bit_user WHERE u_id= #{u_id}),0) AS walletaddress,
			IFNULL((SELECT registertime FROM bit_user WHERE u_id= #{u_id}),0) AS registertime,
			IFNULL((SELECT status FROM bit_user WHERE u_id= #{u_id}),0) AS status,
			IFNULL((SELECT assets FROM bit_user WHERE u_id= #{u_id}),0) AS assets,
			IFNULL((SELECT coldassets FROM bit_user WHERE u_id= #{u_id}),0) AS coldassets,
			IFNULL((SELECT hotassets FROM bit_user WHERE u_id= #{u_id}),0) AS hotassets,
			IFNULL((SELECT usertype FROM bit_user WHERE u_id= #{u_id}),0) AS usertype,
			IFNULL((SELECT registerip FROM bit_user WHERE u_id= #{u_id}),0) AS registerip,
			IFNULL((SELECT lastloginip FROM bit_user WHERE u_id= #{u_id}),0) AS lastloginip,
			IFNULL((SELECT auditstatus FROM bit_user WHERE u_id= #{u_id}),0) AS auditstatus,
			IFNULL((SELECT audituid FROM bit_user WHERE u_id= #{u_id}),0) AS audituid,
			IFNULL((SELECT audittime FROM bit_user WHERE u_id= #{u_id}),0) AS audittime
	</select>
</mapper>