redis 简单使用

Posted 2020-10-28 wumengjuan

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了redis 简单使用相关的知识，希望对你有一定的参考价值。

/**
* @title: PropertiesUtil.java
* @package：util
* @description:TODO
* @author: [email protected]
* @date: 2017年3月4日下午10:33:22
* @version：V1.0
*/
package com.djzh.bank.util;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.Properties;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

/**
* @ClassName: PropertiesUtil
* @Description: 用一句话描述这个类的作用
* @date 2017年3月4日
* @author [email protected]
* @modify
*/
public class PropertiesUtil {
/** private static logger */
private static final Logger logger = LogManager.getLogger(PropertiesUtil.class);

private static Properties _prop = new Properties();

/**
* 读取配置文件
*
* @param fileName
*/
public static void readProperties(String fileName) {
try(InputStream in = PropertiesUtil.class.getResourceAsStream("/" + fileName);
BufferedReader bf = new BufferedReader(new InputStreamReader(in))) {

_prop.load(bf);

} catch (IOException e) {
//e.printStackTrace();
logger.error("readProperties Exception |{}",()->e.toString());
logger.debug("failed {}", e);
}
}

/**
* 根据key读取对应的value
*
* @param key
* @return
*/
public static String getProperty(String key) {
return _prop.getProperty(key);
}
}

package com.djzh.common.utils;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import com.djzh.bank.util.PropertiesUtil;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

public class RedisUtils {

private static final Logger logger = LogManager.getLogger(RedisUtils.class);

public static String PROPERTIES_NAME_STR = "redis.properties";

//Redis服务器IP192.168.1.45:6379

private static String ADDR = "";

//Redis的端口号

private static String PORT = "";

//访问密码,若你的redis服务器没有设置密码，就不需要用密码去连接

private static String AUTH = "";

//可用连接实例的最大数目，默认值为8；

private static String MAX_TOTAL = "";

//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。

private static String MAX_IDLE = "";

//等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。

private static String MAX_WAIT = "";

private static String TIMEOUT = "";

//在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；

private static boolean TEST_ON_BORROW = true;

private static JedisPool jedisPool = null;

/**

* 初始化Redis连接池

static {

try {

JedisPoolConfig config = new JedisPoolConfig();

//获得属性值(redis.properties)

PropertiesUtil.readProperties(PROPERTIES_NAME_STR);

MAX_TOTAL = PropertiesUtil.getProperty("MAX_TOTAL");

MAX_IDLE = PropertiesUtil.getProperty("MAX_IDLE");

MAX_WAIT = PropertiesUtil.getProperty("MAX_WAIT");

ADDR=PropertiesUtil.getProperty("ADDR");

PORT=PropertiesUtil.getProperty("PORT");

AUTH=PropertiesUtil.getProperty("AUTH");

TIMEOUT=PropertiesUtil.getProperty("TIMEOUT");

config.setMaxTotal(Integer.valueOf(MAX_TOTAL));

config.setMaxIdle(Integer.valueOf(MAX_IDLE));

config.setMaxWaitMillis(Integer.valueOf(MAX_WAIT));

config.setTestOnBorrow(TEST_ON_BORROW);

jedisPool = new JedisPool(config, ADDR, Integer.valueOf(PORT), Integer.valueOf(TIMEOUT));

} catch (Exception e) {

e.printStackTrace();

}

/**

* 获取Jedis实例

* @return

public synchronized static Jedis getJedis() {

try {

if (jedisPool != null) {

Jedis jedis = jedisPool.getResource();

return jedis;

} else {

return null;

}

} catch (Exception e) {

e.printStackTrace();

return null;

}

/**

* 释放jedis资源

* @param jedis

public static void returnResource(final Jedis jedis) {

if (jedis != null) {

jedisPool.returnResource(jedis);

}

public static void main(String[] args) {

RedisUtils.getJedis().set("xiaomin", "123");

System.out.println(RedisUtils.getJedis().get("xiaomin"));

//简单的key-value 存储

jedis.set("redis", "myredis");

System.out.println(jedis.get("redis"));

//在原有值得基础上添加,如若之前没有该key，则导入该key

//之前已经设定了redis对应"myredis",此句执行便会使redis对应"myredisyourredis"

jedis.append("redis", "yourredis");

jedis.append("content", "rabbit");

//mset 是设置多个key-value值参数（key1,value1,key2,value2,...,keyn,valuen）

//mget 是获取多个key所对应的value值参数（key1,key2,key3,...,keyn）返回的是个list

jedis.mset("name1","yangw","name2","demon","name3","elena");

System.out.println(jedis.mget("name1","name2","name3"));

//map

Map<String,String> user = new HashMap<String,String>();

user.put("name", "cd");

user.put("password", "123456");

//map存入redis

jedis.hmset("user", user);

//mapkey个数

System.out.println(String.format("len:%d", jedis.hlen("user")));

//map中的所有键值

System.out.println(String.format("keys: %s", jedis.hkeys("user") ));

//map中的所有value

System.out.println(String.format("values: %s", jedis.hvals("user") ));

//取出map中的name字段值

List<String> rsmap = jedis.hmget("user", "name","password");

System.out.println(rsmap);

//删除map中的某一个键值 password

jedis.hdel("user", "password");

System.out.println(jedis.hmget("user", "name", "password"));

//list

jedis.del("listDemo");

System.out.println(jedis.lrange("listDemo", 0, -1));

jedis.lpush("listDemo", "A");

jedis.lpush("listDemo", "B");

jedis.lpush("listDemo", "C");

System.out.println(jedis.lrange("listDemo", 0, -1));

System.out.println(jedis.lrange("listDemo", 0, 1));

//set

jedis.sadd("sname", "wobby");

jedis.sadd("sname", "kings");

jedis.sadd("sname", "demon");

System.out.println(String.format("set num: %d", jedis.scard("sname")));

System.out.println(String.format("all members: %s", jedis.smembers("sname")));

System.out.println(String.format("is member: %B", jedis.sismember("sname", "wobby")));

System.out.println(String.format("rand member: %s", jedis.srandmember("sname")));

//删除一个对象

jedis.srem("sname", "demon");

System.out.println(String.format("all members: %s", jedis.smembers("sname")));

}

package com.djzh.bank.bj;
import com.djzh.bank.bj.base.BJBaseRequest;import com.djzh.bank.util.PropertiesUtil;import com.djzh.bank.util.XmlModelUtil;
import org.apache.logging.log4j.Logger;import org.apache.logging.log4j.LogManager;
import org.w3c.dom.Document;import org.w3c.dom.Node;
import java.io.BufferedReader;import java.io.ByteArrayInputStream;import java.io.InputStream;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.HttpURLConnection;import java.net.URL;import java.net.URLEncoder;
import javax.xml.parsers.DocumentBuilder;import javax.xml.parsers.DocumentBuilderFactory;
public class AccountBaseUtil {
public static String PROPERTIES_NAME_STR = "bj_bank.properties"; // 登陆交易URL private static String userLogonUrlStr = "";
// 签退 URL private static String signOffUrlStr = "";
// 一般交易url private static String ceBankReqUrlStr = "";
// 数据签名URL private static String dataSignatureUrlStr = "";
private static final Logger logger = LogManager.getLogger(AccountBaseUtil.class);
private AccountBaseUtil() { try {
PropertiesUtil.readProperties(PROPERTIES_NAME_STR); userLogonUrlStr = PropertiesUtil.getProperty("userLogonUrlStr"); signOffUrlStr = PropertiesUtil.getProperty("signOffUrlStr"); ceBankReqUrlStr = PropertiesUtil.getProperty("ceBankReqUrlStr"); dataSignatureUrlStr = PropertiesUtil .getProperty("dataSignatureUrlStr"); } catch (Exception e) { logger.error("error:程序无法获取properties中的配置信息"); } }
private static AccountBaseUtil bjBankBaseReq = null;
public static AccountBaseUtil getInstance() { if (bjBankBaseReq == null) { bjBankBaseReq = new AccountBaseUtil(); } return bjBankBaseReq; }
/** * 登录交易 *   * @param serialNo * 交易序列号(客户端唯一标识) * @param reqTime * 客户端请求时间 * @param userID * 用户代码 * @param userPWD * 用户网银密码 * @return 返回 sessionID */ public String CebankUserLogon(BJBaseRequest req) { String v_desSession_id = null; URL url; HttpURLConnection urlConn; InputStream inStrm; String reqData; String retXml = new String(); // 获取报文 reqData = this.createLoginXML(req); // 发起连接 try {
String new_reqData = new String(); // 签名之后的数据 new_reqData = dataSignature(reqData); // 创建URL url = new URL(userLogonUrlStr + "?netType=3&reqData=" + new_reqData); // url = new URL(urlStr); logger.info(url.toString()); // 设置 HttpURLConnection urlConn = (HttpURLConnection) url.openConnection(); // 使用了Get方法 urlConn.setDoOutput(false); urlConn.setDoInput(true); urlConn.setUseCaches(true); urlConn.setRequestMethod("GET"); urlConn.setRequestProperty("User-Agent", "API"); urlConn.setConnectTimeout(10000);
urlConn.connect(); // POST方法参数 /* * OutputStream os = urlConn.getOutputStream(); String param; param * = "netType=3&reqData=" + reqData; *   * //param = URLEncoder.encode(param,"UTF-8"); *   * //String paramater = "netType=3&reqData=" + reqData; *   * //String paramater = reqData; //paramater = * dataSignature(paramater); //param = "netType=3&reqData=" + * paramater; *   * //param = dataSignature("netType=3&reqData=" + reqData); *   * os.write(param.getBytes()); */
// 获取返回报文字符串 inStrm = urlConn.getInputStream();
} catch (Exception ex) { logger.error("连接服务器失败"); return null; }
try(BufferedReader br = new BufferedReader(new InputStreamReader( inStrm, "gb2312"))) {     // InputStreamReader ir = new InputStreamReader(inStrm,"gb2312"); String line = new String(); while (line != null) { retXml += line; line = br.readLine(); } logger.info(retXml); } catch (Exception ex) { //ex.printStackTrace(); logger.error("读取服务器返回串错误 |{}",()->ex.toString());logger.debug("failed {}", ex); return null; } // 如果返回报文非空 if (!retXml.isEmpty()) v_desSession_id = this.parseLoginXML(retXml); return v_desSession_id; }
/** * 构建登录交易XML Document 报文 *   * @param serialNo * @param reqTime * @param userID * @param userPWD * @return 登录交易XML Document 报文 */ private String createLoginXML(BJBaseRequest req) { String retStr = null; Document reqData = null; try { DocumentBuilderFactory docFac = DocumentBuilderFactory .newInstance(); DocumentBuilder docB = docFac.newDocumentBuilder(); reqData = docB.newDocument(); // 设置 XML 文件版本为 1.0 reqData.setXmlVersion("1.0"); // 创建节点node Node n_root = reqData.createElement("BCCBEBankData"); Node n_opReq = reqData.createElement("opReq"); Node n_opName = reqData.createElement("opName"); n_opName.appendChild(reqData.createTextNode("CebankUserLogonOp")); // 交易名称 Node n_serialNo = reqData.createElement("serialNo"); n_serialNo.appendChild(reqData.createTextNode(req.getSerialNo())); Node n_reqTime = reqData.createElement("reqTime"); n_reqTime.appendChild(reqData.createTextNode(req.getReqTime())); Node n_ReqParam = reqData.createElement("ReqParam"); Node n_userID = reqData.createElement("userID"); n_userID.appendChild(reqData.createTextNode(req.getUserID())); Node n_userPWD = reqData.createElement("userPWD"); n_userPWD.appendChild(reqData.createTextNode(req.getUserPWD()));
// 连接节点 reqData.appendChild(n_root);
n_opReq.appendChild(n_opName); n_opReq.appendChild(n_serialNo); n_opReq.appendChild(n_reqTime);
n_ReqParam.appendChild(n_userID); n_ReqParam.appendChild(n_userPWD);
n_root.appendChild(n_opReq); n_opReq.appendChild(n_ReqParam);
retStr = XmlModelUtil.XMLDoc2Str(reqData); retStr = retStr.replace(" standalone=\"no\"", "");
logger.debug(retStr);
} catch (Exception ex) { //ex.printStackTrace(); logger.error("创建 <登录 XML 报文> 失败 |{}",()->ex.toString());logger.debug("failed {}", ex); return null; } // 返回报文 return retStr; }
/** * 签名 *   * @param reqData * @return 返回是签名后信息,签名失败返回null */ public static String dataSignature(String reqData) { URL url; HttpURLConnection urlConn; InputStream inStrm; String rethtml = new String(); String retData = null; // 发起连接 try { // 创建URL url = new URL(dataSignatureUrlStr); logger.debug(url.toString()); // 设置 HttpURLConnection urlConn = (HttpURLConnection) url.openConnection(); // 使用了POST方法 urlConn.setDoOutput(true); urlConn.setDoInput(true); urlConn.setUseCaches(false); urlConn.setRequestMethod("POST"); urlConn.setRequestProperty("User-Agent", "API"); urlConn.setConnectTimeout(10000);
String contentLength = Integer.toString(reqData.length());
urlConn.setRequestProperty("Content-Length", contentLength); urlConn.setRequestProperty("Content-Type", "INFOSEC_SIGN/1.0");
// POST方法参数 OutputStream os = urlConn.getOutputStream(); String param = new String();
// param = "<body>" + reqData + "</body>"; param = reqData;
os.write(param.getBytes());
// 获取返回报文字符串 inStrm = urlConn.getInputStream();
try (BufferedReader br = new BufferedReader(new InputStreamReader(inStrm, "gb2312"))) {
String line = new String();while (line != null) {retHtml += line;line = br.readLine();}logger.info(retHtml);// 如果返回报文非空if (!retHtml.isEmpty()) {int sign_pos_b = retHtml.indexOf("<sign>");int sign_pos_e = retHtml.indexOf("</sign>");retData = retHtml.substring(sign_pos_b + 6, sign_pos_e);
retData = URLEncoder.encode(retData, System.getProperty("file.encoding"));}} } catch (Exception ex) { logger.error("dataSignature方法失败"); return null;
} return retData; }
/** * 分析返回 XML 函数分析登录返回报文 *   * @param v_retXml * @return 分析登录返回报文 */ private String parseLoginXML(String v_retXml) { String retStr = new String(); String sessionID = null; String retXml = null; int indexOfsession; try { DocumentBuilderFactory docFac = DocumentBuilderFactory .newInstance(); DocumentBuilder docB = docFac.newDocumentBuilder(); indexOfsession = v_retXml.indexOf(‘|‘);
// 返回值 sessionID sessionID = v_retXml.substring(0, indexOfsession); retXml = v_retXml.substring(indexOfsession + 1);
InputStream is = new ByteArrayInputStream(retXml.getBytes());
Document retDoc = docB.parse(is); retDoc.normalize(); Node r_retCode = retDoc.getElementsByTagName("retCode").item(0) .getFirstChild(); retStr = r_retCode.getNodeValue(); if (retStr.equals(Integer.toString(0)) == false) { logger.debug(retStr); logger.debug(retDoc.getElementsByTagName("errMsg") .item(0).getFirstChild().getNodeValue()); } else { logger.debug(retDoc.getElementsByTagName("userName") .item(0).getFirstChild().getNodeValue()); logger.debug(retDoc.getElementsByTagName("corpName") .item(0).getFirstChild().getNodeValue()); logger.debug(retDoc.getElementsByTagName("lastLogon") .item(0).getFirstChild().getNodeValue()); } ; } catch (Exception ex) { //ex.printStackTrace(); logger.error("parseLoginXML Exception |{}"+retXml,()->ex.toString());logger.debug("failed {}", ex); }
if (sessionID.length() == 0) return null; else return sessionID; }
/** * 签退交易 *   * @param desSession_id * @return返回是否调用成功 0成功 -1失败 */ public int CebankUserSignOff(String desSession_id) { URL url; HttpURLConnection urlConn; // 发起连接 try { // 创建URL url = new URL(signOffUrlStr + "?dse_sessionId=" + desSession_id); // url = new URL(urlStr); logger.info(url.toString()); // 设置 HttpURLConnection urlConn = (HttpURLConnection) url.openConnection(); // 使用了Get方法 urlConn.setDoOutput(false); urlConn.setDoInput(true); urlConn.setUseCaches(true); urlConn.setRequestMethod("GET"); urlConn.setRequestProperty("User-Agent", "API"); urlConn.setConnectTimeout(10000); urlConn.connect(); /* * //POST方法参数 OutputStream os = urlConn.getOutputStream(); String * param = new String(); param = "dse_sessionId=" + desSession_id; * os.write(param.getBytes()); */ // 获取返回报文字符串 urlConn.getInputStream(); } catch (Exception ex) { //ex.printStackTrace(); logger.error("签退交易时，连接服务器失败 |{}",()->ex.toString());logger.debug("failed {}", ex); return -1; } return 0; }
/** * 一般交易 *   * @param opName * @param desSession_id * @param reqData * @return 银行接口返回的 XML String */ public String CebankReq(String opName, String desSession_id, String reqData) { // String v_desSession_id = null; URL url; HttpURLConnection urlConn; InputStream inStrm; String retXml = null;
// 发起连接 try {
// 创建URL // url = new URL(urlStr + "?dse_sessionId=" + desSession_id + // "&opName=" + opName + "&reqData=" + reqData);
url = new URL(ceBankReqUrlStr + "?dse_sessionId=" + desSession_id); logger.info(url.toString()); // 设置 HttpURLConnection urlConn = (HttpURLConnection) url.openConnection(); // 使用了post方法 urlConn.setDoOutput(true); urlConn.setDoInput(true); urlConn.setUseCaches(true); urlConn.setRequestMethod("POST"); urlConn.setRequestProperty("User-Agent", "API"); urlConn.setConnectTimeout(10000); // urlConn.connect();
// POST方法参数 OutputStream os = urlConn.getOutputStream(); String param = new String(); param = "opName=" + opName + "&reqData=" + reqData;
os.write(param.getBytes());
// 获取返回报文字符串 inStrm = urlConn.getInputStream();
} catch (Exception ex) { //ex.printStackTrace(); logger.error("一般交易时，连接服务器失败 |{}",()->ex.toString());logger.debug("failed {}", ex); return null; } try (BufferedReader br = new BufferedReader(new InputStreamReader( inStrm, "gb2312"))){     // InputStreamReader ir = new InputStreamReader(inStrm,"gb2312"); String line = new String(); while (line != null) { retXml += line; line = br.readLine(); } logger.info(retXml); } catch (Exception ex) { //ex.printStackTrace(); logger.error("一般交易时，读取服务器返回信息错误 |{}",()->ex.toString());logger.debug("failed {}", ex); return null; } return retXml; }
}

以上是关于redis 简单使用的主要内容，如果未能解决你的问题，请参考以下文章