--- /dev/null
+/**\r
+* Copyright (C) 2016 ZTE, Inc. and others. All rights reserved. (ZTE)\r
+*\r
+* Licensed under the Apache License, Version 2.0 (the "License");\r
+* you may not use this file except in compliance with the License.\r
+* You may obtain a copy of the License at\r
+*\r
+* http://www.apache.org/licenses/LICENSE-2.0\r
+*\r
+* Unless required by applicable law or agreed to in writing, software\r
+* distributed under the License is distributed on an "AS IS" BASIS,\r
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+* See the License for the specific language governing permissions and\r
+* limitations under the License.\r
+*/\r
+\r
+package org.openo.msb.wrapper.util;\r
+\r
+import java.io.BufferedInputStream;\r
+import java.io.File;\r
+import java.io.FileInputStream;\r
+import java.util.PropertyResourceBundle;\r
+import java.util.ResourceBundle;\r
+\r
+import org.apache.commons.lang3.StringUtils;\r
+import org.slf4j.Logger;\r
+import org.slf4j.LoggerFactory;\r
+\r
+import redis.clients.jedis.Jedis;\r
+import redis.clients.jedis.JedisPool;\r
+import redis.clients.jedis.JedisPoolConfig;\r
+\r
+\r
+\r
+public final class JedisUtil {\r
+ private static final Logger LOGGER = LoggerFactory.getLogger(JedisUtil.class);\r
+ private static String host = "127.0.0.1";\r
+ private static int port = 6379;\r
+ private static int connectionTimeout = 2000;\r
+ private static int DEFAULT_DB_INDEX = 0;\r
+\r
+ private static JedisPool jedisPool = null;\r
+ \r
+ public static String serverIp="127.0.0.1";\r
+ \r
+ public static int serverPort=10080;\r
+ \r
+ public static String propertiesName="redis.properties";\r
+ \r
+ public static String propertiesPath="";\r
+\r
+ \r
+ \r
+public static void main(String[] args) {\r
+ \r
+}\r
+\r
+ private JedisUtil() {\r
+ // private constructor\r
+\r
+ }\r
+ \r
+ private static void initialPool() {\r
+ try {\r
+ JedisPoolConfig config = new JedisPoolConfig();\r
+ \r
+// String pathtest=JedisUtil.class.getResource("").getPath();\r
+// String path ="/"+ pathtest.substring(0, pathtest.indexOf("assembly")).replace("file:/", "") +"assembly/"+defaultWorkspace;\r
+ \r
+ File propertiesFile = new File(propertiesPath);\r
+ \r
+ if (propertiesFile.exists()) {\r
+ \r
+ \r
+ BufferedInputStream inputStream =new BufferedInputStream(new FileInputStream(propertiesPath)); \r
+ ResourceBundle bundle =new PropertyResourceBundle(inputStream);\r
+ \r
+ if (bundle == null) {\r
+ throw new IllegalArgumentException(\r
+ "[redis.properties] is not found!");\r
+ }\r
+ \r
+\r
+ // 设置连接池基本信息\r
+ String strHost = bundle.getString("redis.host");\r
+ if(StringUtils.isNotEmpty(strHost)){\r
+ host = strHost;\r
+ }\r
+ String strPort = bundle.getString("redis.port");\r
+ if(StringUtils.isNotEmpty(strPort)){\r
+ port = Integer.valueOf(strPort);\r
+ }\r
+ \r
+ \r
+ String strTimeout = bundle.getString("redis.connectionTimeout");\r
+ if (StringUtils.isNotEmpty(strTimeout) ){\r
+ connectionTimeout = Integer.valueOf(strTimeout);\r
+ }\r
+ \r
+// serverIp=bundle.getString("server.ip");\r
+ serverPort=Integer.valueOf(bundle.getString("server.port"));\r
+ \r
+ String strDbIndex = bundle.getString("redis.db_index");\r
+ if (StringUtils.isNotEmpty(strDbIndex)) {\r
+ DEFAULT_DB_INDEX = Integer.valueOf(strDbIndex);\r
+ }\r
+\r
+ String strMaxTotal = bundle.getString("redis.pool.maxTotal");\r
+ if (StringUtils.isNotEmpty(strMaxTotal)) {\r
+ config.setMaxTotal(Integer.valueOf(strMaxTotal));\r
+ }\r
+\r
+ String strMaxIdle = bundle.getString("redis.pool.maxIdle");\r
+ if (StringUtils.isNotEmpty(strMaxIdle)) {\r
+ config.setMaxIdle(Integer.valueOf(strMaxIdle));\r
+ }\r
+\r
+ String strMaxWaitMillis = bundle.getString("redis.pool.maxWaitMillis");\r
+ if (StringUtils.isNotEmpty(strMaxWaitMillis)) {\r
+ config.setMaxWaitMillis(Long.valueOf(strMaxWaitMillis));\r
+ }\r
+\r
+ String strTestOnBorrow = bundle\r
+ .getString("redis.pool.testOnBorrow");\r
+ if (StringUtils.isNotEmpty(strTestOnBorrow)) {\r
+ config.setTestOnBorrow(Boolean.valueOf(strTestOnBorrow));\r
+ }\r
+\r
+ String strTestOnReturn = bundle\r
+ .getString("redis.pool.testOnReturn");\r
+ if (StringUtils.isNotEmpty(strTestOnReturn)) {\r
+ config.setTestOnReturn(Boolean.valueOf(strTestOnReturn));\r
+ }\r
+\r
+ }\r
+ \r
+ LOGGER.info("Redis server info: " + host + ":" + port);\r
+ LOGGER.info("nginx server info: " + serverIp + ":" + serverPort);\r
+ \r
+ \r
+// ResourceBundle bundle = ResourceBundle.getBundle("conf.redis");\r
+ \r
+ jedisPool = new JedisPool(config, host, port, connectionTimeout);\r
+ } catch (Exception e) {\r
+ LOGGER.error("Initiate Jedis pool failed!", e);\r
+ }\r
+ }\r
+ /**\r
+ * From the connection pool to obtain jedis instance, use the default database index number 0\r
+ * @return\r
+ */\r
+ public synchronized static Jedis borrowJedisInstance() {\r
+ if (jedisPool == null) {\r
+ initialPool();\r
+ }\r
+ try {\r
+ if (jedisPool != null) {\r
+ Jedis resource = jedisPool.getResource();\r
+ resource.select(DEFAULT_DB_INDEX);\r
+ return resource;\r
+ } else {\r
+ return null;\r
+ }\r
+ } catch (Exception e) {\r
+ LOGGER.error("Get Jedis from pool failed!", e);\r
+ return null;\r
+ }\r
+ }\r
+ /**\r
+ * From the connection pool to obtain jedis instance, using the specified database index number\r
+ * @return\r
+ */\r
+ public synchronized static Jedis borrowJedisInstance(final int dbIndex) {\r
+ if (jedisPool == null) {\r
+ initialPool();\r
+ }\r
+ try {\r
+ if (jedisPool != null) {\r
+ Jedis resource = jedisPool.getResource();\r
+ resource.select(dbIndex);\r
+ return resource;\r
+ } else {\r
+ return null;\r
+ }\r
+ } catch (Exception e) {\r
+ LOGGER.error("Get Jedis from pool failed!", e);\r
+ return null;\r
+ }\r
+ }\r
+ \r
+ /**\r
+ * returned to the pool jedis instance\r
+ * @param jedis\r
+ */\r
+ public static void returnJedisInstance(final Jedis jedis) {\r
+ if (jedis != null) {\r
+ jedis.close();\r
+ }\r
+ }\r
+ \r
+ \r
+ /** \r
+ * @Title getJedis \r
+ * @Description TODO(From the connection pool to obtain jedis instance) \r
+ * @throws Exception \r
+ * @return Jedis \r
+ */\r
+ public static Jedis getJedis() throws Exception{\r
+ \r
+ \r
+ Jedis jedis = borrowJedisInstance();\r
+ if (jedis == null) {\r
+ throw new Exception("fetch from jedis pool failed,null object!");\r
+ \r
+ }\r
+ \r
+ return jedis;\r
+ \r
+ }\r
+\r
+}
\ No newline at end of file
Code Review / msb / apigateway.git / blobdiff