Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
X
xzxt-rest
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
常超
xzxt-rest
Commits
6e20b4c3
Commit
6e20b4c3
authored
Aug 21, 2018
by
chang_chao@founder.com.cn
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
修改redis配置,设置密码
parent
f0f0c7be
Show whitespace changes
Inline
Side-by-side
Showing
7 changed files
with
813 additions
and
68 deletions
+813
-68
src/main/java/com/cc/common/util/TestRedis.java
+122
-0
src/main/java/com/cc/common/util/redisUtil.java
+549
-0
src/main/java/com/cc/service/RedisService.java
+1
-1
src/main/java/com/cc/service/imp/RedisServiceImpl.java
+10
-9
src/main/resources/resource/db.properties
+40
-2
src/main/resources/spring/applicationContext-jedis.xml
+83
-56
src/main/resources/spring/springmvc.xml
+8
-0
No files found.
src/main/java/com/cc/common/util/TestRedis.java
0 → 100644
View file @
6e20b4c3
package
com
.
cc
.
common
.
util
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.Map
;
import
org.springframework.context.ApplicationContext
;
import
org.springframework.context.support.ClassPathXmlApplicationContext
;
public
class
TestRedis
{
public
static
void
main
(
String
[]
args
)
throws
Exception
{
@SuppressWarnings
(
"resource"
)
ApplicationContext
context
=
new
ClassPathXmlApplicationContext
(
"classpath:spring/applicationContext-jedis.xml"
);
redisUtil
redisUtil
=(
redisUtil
)
context
.
getBean
(
"redisUtil"
);
//=====================testString======================
//redisUtil.set("name", "常超");
//redisUtil.set("age", 24);
//redisUtil.set("address", "山西");
//System.out.println(redisUtil.set("address", "河北邯郸", 50));
//redisUtil.set("22222", "常超");
System
.
out
.
println
(
redisUtil
.
get
(
"15:CODE_AJDLB:05000000:05000100:抢劫案:05000100 | 抢劫案"
));
//redisUtil.set("age", 1000);
//Object object = redisUtil.get("user2");
//System.out.println(object);
//redisUtil.del("address");
//redisUtil.set("class", 15);
//long incr = redisUtil.incr("a", 1);
//System.out.println(incr);
//Thread.sleep(5000);
/*Map<String,Object> map=new HashMap<>();
map.put("name", "王赛超");
map.put("age", 24);
map.put("address", "河北邯郸666");
redisUtil.hmset("15532002725", map,1000);*/
//redisUtil.del("15532002725");
//redisUtil.hset("15532002725","address","河北邯郸",1000);
//redisUtil.hdel("15532002725", "name");
//System.out.println(redisUtil.sSetAndTime("15532002727",1000,"haha"));
//System.out.println(redisUtil.sGet("15532002727"));
//System.out.println(redisUtil.sHasKey("15532002727","name"));
/* System.out.println(redisUtil.lRemove("15532002728",1,2));
System.out.println(redisUtil.lGet("15532002728",0,-1));
System.out.println(redisUtil.lGetListSize("15532002728"));
System.out.println(redisUtil.lGetIndex("15532002728",1));*/
//System.out.println(redisUtil.getExpire("15532002725"));
//System.out.println(redisUtil.hget("15532002725","name"));
//System.out.println(redisUtil.hmget("15532002725"));
}
}
class
User
{
private
String
name
;
private
Integer
age
;
private
String
address
;
private
Double
classz
;
private
Float
classz2
;
public
User
()
{
super
();
}
public
User
(
String
name
,
Integer
age
,
String
address
,
Double
classz
,
Float
classz2
)
{
super
();
this
.
name
=
name
;
this
.
age
=
age
;
this
.
address
=
address
;
this
.
classz
=
classz
;
this
.
classz2
=
classz2
;
}
public
String
getName
()
{
return
name
;
}
public
void
setName
(
String
name
)
{
this
.
name
=
name
;
}
public
Integer
getAge
()
{
return
age
;
}
public
void
setAge
(
Integer
age
)
{
this
.
age
=
age
;
}
public
String
getAddress
()
{
return
address
;
}
public
void
setAddress
(
String
address
)
{
this
.
address
=
address
;
}
public
Double
getClassz
()
{
return
classz
;
}
public
void
setClassz
(
Double
classz
)
{
this
.
classz
=
classz
;
}
public
Float
getClassz2
()
{
return
classz2
;
}
public
void
setClassz2
(
Float
classz2
)
{
this
.
classz2
=
classz2
;
}
}
\ No newline at end of file
src/main/java/com/cc/common/util/redisUtil.java
0 → 100644
View file @
6e20b4c3
package
com
.
cc
.
common
.
util
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Set
;
import
java.util.concurrent.TimeUnit
;
import
org.springframework.data.redis.core.RedisTemplate
;
import
org.springframework.util.CollectionUtils
;
/**
*
* @author 常超
* 基于spring和redis的redisTemplate工具类
* 针对所有的hash 都是以h开头的方法
* 针对所有的Set 都是以s开头的方法 不含通用方法
* 针对所有的List 都是以l开头的方法
*/
public
class
redisUtil
{
private
RedisTemplate
<
String
,
Object
>
redisTemplate
;
public
void
setRedisTemplate
(
RedisTemplate
<
String
,
Object
>
redisTemplate
)
{
this
.
redisTemplate
=
redisTemplate
;
}
//=============================common============================
/**
* 指定缓存失效时间
* @param key 键
* @param time 时间(秒)
* @return
*/
public
boolean
expire
(
String
key
,
long
time
){
try
{
if
(
time
>
0
){
redisTemplate
.
expire
(
key
,
time
,
TimeUnit
.
SECONDS
);
}
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 根据key 获取过期时间
* @param key 键 不能为null
* @return 时间(秒) 返回0代表为永久有效
*/
public
long
getExpire
(
String
key
){
return
redisTemplate
.
getExpire
(
key
,
TimeUnit
.
SECONDS
);
}
/**
* 判断key是否存在
* @param key 键
* @return true 存在 false不存在
*/
public
boolean
hasKey
(
String
key
){
try
{
return
redisTemplate
.
hasKey
(
key
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 删除缓存
* @param key 可以传一个值 或多个
*/
@SuppressWarnings
(
"unchecked"
)
public
void
del
(
String
...
key
){
if
(
key
!=
null
&&
key
.
length
>
0
){
if
(
key
.
length
==
1
){
redisTemplate
.
delete
(
key
[
0
]);
}
else
{
redisTemplate
.
delete
(
CollectionUtils
.
arrayToList
(
key
));
}
}
}
//============================String=============================
/**
* 普通缓存获取
* @param key 键
* @return 值
*/
public
String
get
(
String
key
){
return
key
==
null
?
null
:
(
String
)
redisTemplate
.
opsForValue
().
get
(
key
);
}
/**
* 普通缓存放入
* @param key 键
* @param value 值
* @return true成功 false失败
*/
public
boolean
set
(
String
key
,
String
value
)
{
try
{
redisTemplate
.
opsForValue
().
set
(
key
,
value
);
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 模糊查询
* key:查询条件
*/
public
Set
<
String
>
keys
(
String
key
)
{
Set
<
String
>
result
=
redisTemplate
.
keys
(
key
);
return
result
;
}
/**
* 普通缓存放入并设置时间
* @param key 键
* @param value 值
* @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
* @return true成功 false 失败
*/
public
boolean
set
(
String
key
,
String
value
,
long
time
){
try
{
if
(
time
>
0
){
redisTemplate
.
opsForValue
().
set
(
key
,
value
,
time
,
TimeUnit
.
SECONDS
);
}
else
{
set
(
key
,
value
);
}
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 递增
* @param key 键
* @param
* @return
*/
public
long
incr
(
String
key
,
long
delta
){
if
(
delta
<
0
){
throw
new
RuntimeException
(
"递增因子必须大于0"
);
}
return
redisTemplate
.
opsForValue
().
increment
(
key
,
delta
);
}
/**
* 递减
* @param key 键
* @param
* @return
*/
public
long
decr
(
String
key
,
long
delta
){
if
(
delta
<
0
){
throw
new
RuntimeException
(
"递减因子必须大于0"
);
}
return
redisTemplate
.
opsForValue
().
increment
(
key
,
-
delta
);
}
//================================Map=================================
/**
* HashGet
* @param key 键 不能为null
* @param item 项 不能为null
* @return 值
*/
public
Object
hget
(
String
key
,
String
item
){
return
redisTemplate
.
opsForHash
().
get
(
key
,
item
);
}
/**
* 获取hashKey对应的所有键值
* @param key 键
* @return 对应的多个键值
*/
public
Map
<
Object
,
Object
>
hmget
(
String
key
){
return
redisTemplate
.
opsForHash
().
entries
(
key
);
}
/**
* HashSet
* @param key 键
* @param map 对应多个键值
* @return true 成功 false 失败
*/
public
boolean
hmset
(
String
key
,
Map
<
String
,
Object
>
map
){
try
{
redisTemplate
.
opsForHash
().
putAll
(
key
,
map
);
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* HashSet 并设置时间
* @param key 键
* @param map 对应多个键值
* @param time 时间(秒)
* @return true成功 false失败
*/
public
boolean
hmset
(
String
key
,
Map
<
String
,
Object
>
map
,
long
time
){
try
{
redisTemplate
.
opsForHash
().
putAll
(
key
,
map
);
if
(
time
>
0
){
expire
(
key
,
time
);
}
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 向一张hash表中放入数据,如果不存在将创建
* @param key 键
* @param item 项
* @param value 值
* @return true 成功 false失败
*/
public
boolean
hset
(
String
key
,
String
item
,
Object
value
)
{
try
{
redisTemplate
.
opsForHash
().
put
(
key
,
item
,
value
);
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 向一张hash表中放入数据,如果不存在将创建
* @param key 键
* @param item 项
* @param value 值
* @param time 时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
* @return true 成功 false失败
*/
public
boolean
hset
(
String
key
,
String
item
,
Object
value
,
long
time
)
{
try
{
redisTemplate
.
opsForHash
().
put
(
key
,
item
,
value
);
if
(
time
>
0
){
expire
(
key
,
time
);
}
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 删除hash表中的值
* @param key 键 不能为null
* @param item 项 可以使多个 不能为null
*/
public
void
hdel
(
String
key
,
Object
...
item
){
redisTemplate
.
opsForHash
().
delete
(
key
,
item
);
}
/**
* 判断hash表中是否有该项的值
* @param key 键 不能为null
* @param item 项 不能为null
* @return true 存在 false不存在
*/
public
boolean
hHasKey
(
String
key
,
String
item
){
return
redisTemplate
.
opsForHash
().
hasKey
(
key
,
item
);
}
/**
* hash递增 如果不存在,就会创建一个 并把新增后的值返回
* @param key 键
* @param item 项
* @param by 要增加几(大于0)
* @return
*/
public
double
hincr
(
String
key
,
String
item
,
double
by
){
return
redisTemplate
.
opsForHash
().
increment
(
key
,
item
,
by
);
}
/**
* hash递减
* @param key 键
* @param item 项
* @param by 要减少记(小于0)
* @return
*/
public
double
hdecr
(
String
key
,
String
item
,
double
by
){
return
redisTemplate
.
opsForHash
().
increment
(
key
,
item
,-
by
);
}
//============================set=============================
/**
* 根据key获取Set中的所有值
* @param key 键
* @return
*/
public
Set
<
Object
>
sGet
(
String
key
){
try
{
return
redisTemplate
.
opsForSet
().
members
(
key
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
null
;
}
}
/**
* 根据value从一个set中查询,是否存在
* @param key 键
* @param value 值
* @return true 存在 false不存在
*/
public
boolean
sHasKey
(
String
key
,
Object
value
){
try
{
return
redisTemplate
.
opsForSet
().
isMember
(
key
,
value
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 将数据放入set缓存
* @param key 键
* @param values 值 可以是多个
* @return 成功个数
*/
public
long
sSet
(
String
key
,
Object
...
values
)
{
try
{
return
redisTemplate
.
opsForSet
().
add
(
key
,
values
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
0
;
}
}
/**
* 将set数据放入缓存
* @param key 键
* @param time 时间(秒)
* @param values 值 可以是多个
* @return 成功个数
*/
public
long
sSetAndTime
(
String
key
,
long
time
,
Object
...
values
)
{
try
{
Long
count
=
redisTemplate
.
opsForSet
().
add
(
key
,
values
);
if
(
time
>
0
)
expire
(
key
,
time
);
return
count
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
0
;
}
}
/**
* 获取set缓存的长度
* @param key 键
* @return
*/
public
long
sGetSetSize
(
String
key
){
try
{
return
redisTemplate
.
opsForSet
().
size
(
key
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
0
;
}
}
/**
* 移除值为value的
* @param key 键
* @param values 值 可以是多个
* @return 移除的个数
*/
public
long
setRemove
(
String
key
,
Object
...
values
)
{
try
{
Long
count
=
redisTemplate
.
opsForSet
().
remove
(
key
,
values
);
return
count
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
0
;
}
}
//===============================list=================================
/**
* 获取list缓存的内容
* @param key 键
* @param start 开始
* @param end 结束 0 到 -1代表所有值
* @return
*/
public
List
<
Object
>
lGet
(
String
key
,
long
start
,
long
end
){
try
{
return
redisTemplate
.
opsForList
().
range
(
key
,
start
,
end
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
null
;
}
}
/**
* 获取list缓存的长度
* @param key 键
* @return
*/
public
long
lGetListSize
(
String
key
){
try
{
return
redisTemplate
.
opsForList
().
size
(
key
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
0
;
}
}
/**
* 通过索引 获取list中的值
* @param key 键
* @param index 索引 index>=0时, 0 表头,1 第二个元素,依次类推;index<0时,-1,表尾,-2倒数第二个元素,依次类推
* @return
*/
public
Object
lGetIndex
(
String
key
,
long
index
){
try
{
return
redisTemplate
.
opsForList
().
index
(
key
,
index
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
null
;
}
}
/**
* 将list放入缓存
* @param key 键
* @param value 值
* @param
* @return
*/
public
boolean
lSet
(
String
key
,
Object
value
)
{
try
{
redisTemplate
.
opsForList
().
rightPush
(
key
,
value
);
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 将list放入缓存
* @param key 键
* @param value 值
* @param time 时间(秒)
* @return
*/
public
boolean
lSet
(
String
key
,
Object
value
,
long
time
)
{
try
{
redisTemplate
.
opsForList
().
rightPush
(
key
,
value
);
if
(
time
>
0
)
expire
(
key
,
time
);
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 将list放入缓存
* @param key 键
* @param value 值
* @param
* @return
*/
public
boolean
lSet
(
String
key
,
List
<
Object
>
value
)
{
try
{
redisTemplate
.
opsForList
().
rightPushAll
(
key
,
value
);
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 将list放入缓存
* @param key 键
* @param value 值
* @param time 时间(秒)
* @return
*/
public
boolean
lSet
(
String
key
,
List
<
Object
>
value
,
long
time
)
{
try
{
redisTemplate
.
opsForList
().
rightPushAll
(
key
,
value
);
if
(
time
>
0
)
expire
(
key
,
time
);
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 根据索引修改list中的某条数据
* @param key 键
* @param index 索引
* @param value 值
* @return
*/
public
boolean
lUpdateIndex
(
String
key
,
long
index
,
Object
value
)
{
try
{
redisTemplate
.
opsForList
().
set
(
key
,
index
,
value
);
return
true
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
}
}
/**
* 移除N个值为value
* @param key 键
* @param count 移除多少个
* @param value 值
* @return 移除的个数
*/
public
long
lRemove
(
String
key
,
long
count
,
Object
value
)
{
try
{
Long
remove
=
redisTemplate
.
opsForList
().
remove
(
key
,
count
,
value
);
return
remove
;
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
0
;
}
}
}
\ No newline at end of file
src/main/java/com/cc/service/RedisService.java
View file @
6e20b4c3
...
...
@@ -8,5 +8,5 @@ public interface RedisService {
XzxtRestResult
ReadRedisRest
(
String
key
);
XzxtRestResult
DelRedisRest
(
String
key
);
XzxtRestResult
keysRedisRest
(
String
key
);
XzxtRestResult
hvalsRedisRest
(
String
hkey
);
/*XzxtRestResult hvalsRedisRest(String hkey);*/
}
src/main/java/com/cc/service/imp/RedisServiceImpl.java
View file @
6e20b4c3
...
...
@@ -2,7 +2,9 @@ package com.cc.service.imp;
import
com.cc.common.pojo.XzxtRestResult
;
import
com.cc.common.util.ExceptionUtil
;
import
com.cc.common.util.redisUtil
;
import
com.cc.dao.JedisClient
;
import
com.cc.pojo.SysDictitem
;
import
com.cc.service.RedisService
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Value
;
...
...
@@ -18,7 +20,7 @@ import java.util.Set;
public
class
RedisServiceImpl
implements
RedisService
{
@Autowired
private
JedisClient
jedisClient
;
private
redisUtil
redisUtil
;
/**
* 返回状态码:201:成功存入
* 返回状态码:202:成功读取
...
...
@@ -29,7 +31,7 @@ public class RedisServiceImpl implements RedisService {
@Override
public
XzxtRestResult
SaveRedisRest
(
String
key
,
String
value
)
{
try
{
jedisClient
.
set
(
key
,
value
);
redisUtil
.
set
(
key
,
value
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
XzxtRestResult
.
build
(
500
,
ExceptionUtil
.
getStackTrace
(
e
));
...
...
@@ -40,7 +42,7 @@ public class RedisServiceImpl implements RedisService {
public
XzxtRestResult
ReadRedisRest
(
String
key
)
{
String
result
=
""
;
try
{
result
=
jedisClient
.
get
(
key
);
result
=
redisUtil
.
get
(
key
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
XzxtRestResult
.
build
(
500
,
ExceptionUtil
.
getStackTrace
(
e
));
...
...
@@ -50,9 +52,8 @@ public class RedisServiceImpl implements RedisService {
@Override
public
XzxtRestResult
DelRedisRest
(
String
key
)
{
long
result
=
0
;
try
{
re
sult
=
jedisClient
.
del
(
key
);
re
disUtil
.
del
(
key
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
XzxtRestResult
.
build
(
500
,
ExceptionUtil
.
getStackTrace
(
e
));
...
...
@@ -64,24 +65,24 @@ public class RedisServiceImpl implements RedisService {
public
XzxtRestResult
keysRedisRest
(
String
key
)
{
Set
<
String
>
result
=
new
HashSet
<>();
try
{
result
=
jedisClient
.
keys
(
key
);
result
=
redisUtil
.
keys
(
key
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
XzxtRestResult
.
build
(
500
,
ExceptionUtil
.
getStackTrace
(
e
));
}
return
XzxtRestResult
.
build
(
204
,
"获取指定key"
,
result
);
}
@Override
/*
@Override
public XzxtRestResult hvalsRedisRest(String hkey) {
List<String> result=new ArrayList<>();
try {
result
=
jedisClient
.
hvals
(
hkey
);
result=
redisUtil
.hvals(hkey);
} catch (Exception e) {
e.printStackTrace();
return XzxtRestResult.build(500, ExceptionUtil.getStackTrace(e));
}
return XzxtRestResult.build(205,"获取指定key的value",result);
}
}
*/
}
src/main/resources/resource/db.properties
View file @
6e20b4c3
...
...
@@ -3,6 +3,43 @@ jdbc.url=jdbc:oracle:thin:@192.168.193.1:1521:XZXT
jdbc.username
=
XZXT
jdbc.password
=
XZXT
redis.host
=
127.0.0.1
#ip地址
redis.hostName
=
127.0.0.1
#端口号
redis.port
=
6379
redis.pass
=
#如果有密码
redis.password
=
123
#客户端超时时间单位是毫秒 默认是2000
redis.timeout
=
10000
#最大空闲数
redis.maxIdle
=
300
#连接池的最大数据库连接数。设为0表示无限制,如果是jedis 2.4以后用redis.maxTotal
#redis.maxActive=600
#控制一个pool可分配多少个jedis实例,用来替换上面的redis.maxActive,如果是jedis 2.4以后用该属性
redis.maxTotal
=
1000
#最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。
redis.maxWaitMillis
=
1000
#连接的最小空闲时间 默认1800000毫秒(30分钟)
redis.minEvictableIdleTimeMillis
=
300000
#每次释放连接的最大数目,默认3
redis.numTestsPerEvictionRun
=
1024
#逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1
redis.timeBetweenEvictionRunsMillis
=
30000
#是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
redis.testOnBorrow
=
true
#在空闲时检查有效性, 默认false
redis.testWhileIdle
=
true
#redis.sentinel.host1=172.20.1.230
#redis.sentinel.port1=26379
#redis.sentinel.host2=172.20.1.231
#redis.sentinel.port2=26379
#redis.sentinel.host3=172.20.1.232
#
redis.sentinel.port3
=
26379
\ No newline at end of file
src/main/resources/spring/applicationContext-jedis.xml
View file @
6e20b4c3
...
...
@@ -7,70 +7,96 @@
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd"
>
<!-- 连接池配置 -->
<bean
id=
"jedisPoolConfig"
class=
"redis.clients.jedis.JedisPoolConfig"
>
<!-- 最大连接数 -->
<property
name=
"maxTotal"
value=
"30"
/>
<!-- 最大空闲连接数 -->
<property
name=
"maxIdle"
value=
"10"
/>
<!-- 每次释放连接的最大数目 -->
<property
name=
"numTestsPerEvictionRun"
value=
"1024"
/>
<!-- 释放连接的扫描间隔(毫秒) -->
<property
name=
"timeBetweenEvictionRunsMillis"
value=
"30000"
/>
<!-- 连接最小空闲时间 -->
<property
name=
"minEvictableIdleTimeMillis"
value=
"1800000"
/>
<!-- 连接空闲多久后释放, 当空闲时间>该值 且 空闲连接>最大空闲连接数 时直接释放 -->
<property
name=
"softMinEvictableIdleTimeMillis"
value=
"10000"
/>
<!-- 获取连接时的最大等待毫秒数,小于零:阻塞不确定的时间,默认-1 -->
<property
name=
"maxWaitMillis"
value=
"1500"
/>
<!-- 在获取连接的时候检查有效性, 默认false -->
<property
name=
"testOnBorrow"
value=
"true"
/>
<!-- 在空闲时检查有效性, 默认false -->
<property
name=
"testWhileIdle"
value=
"true"
/>
<!-- 连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true -->
<property
name=
"blockWhenExhausted"
value=
"false"
/>
</bean>
<!-- 加载配置文件 -->
<context:property-placeholder
location=
"classpath:resource/*.properties"
/>
<!-- jedis客户端单机版 -->
<bean
id=
"redisClient"
class=
"redis.clients.jedis.JedisPool"
>
<constructor-arg
name=
"host"
value=
"${redis.host}"
></constructor-arg>
<constructor-arg
name=
"port"
value=
"${redis.port}"
></constructor-arg>
<constructor-arg
name=
"poolConfig"
ref=
"jedisPoolConfig"
></constructor-arg>
</bean>
<bean
id=
"jedisClient"
class=
"com.cc.dao.imp.JedisClientSingle"
/>
<!-- redis连接池配置-->
<bean
id=
"jedisPoolConfig"
class=
"redis.clients.jedis.JedisPoolConfig"
>
<!--最大空闲数-->
<property
name=
"maxIdle"
value=
"${redis.maxIdle}"
/>
<!--连接池的最大数据库连接数 -->
<property
name=
"maxTotal"
value=
"${redis.maxTotal}"
/>
<!--最大建立连接等待时间-->
<property
name=
"maxWaitMillis"
value=
"${redis.maxWaitMillis}"
/>
<!--逐出连接的最小空闲时间 默认1800000毫秒(30分钟)-->
<property
name=
"minEvictableIdleTimeMillis"
value=
"${redis.minEvictableIdleTimeMillis}"
/>
<!--每次逐出检查时 逐出的最大数目 如果为负数就是 : 1/abs(n), 默认3-->
<property
name=
"numTestsPerEvictionRun"
value=
"${redis.numTestsPerEvictionRun}"
/>
<!--逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1-->
<property
name=
"timeBetweenEvictionRunsMillis"
value=
"${redis.timeBetweenEvictionRunsMillis}"
/>
<!--是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个-->
<property
name=
"testOnBorrow"
value=
"${redis.testOnBorrow}"
/>
<!--在空闲时检查有效性, 默认false -->
<property
name=
"testWhileIdle"
value=
"${redis.testWhileIdle}"
/>
</bean >
<!-- jedis集群版配置 -->
<!--<bean id="redisClient" class="redis.clients.jedis.JedisCluster">
<constructor-arg name="nodes">
<set>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.193.128"></constructor-arg>
<constructor-arg name="port" value="7001"></constructor-arg>
<!-- redis集群配置 哨兵模式 -->
<!-- <bean id="sentinelConfiguration" class="org.springframework.data.redis.connection.RedisSentinelConfiguration">
<property name="master">
<bean class="org.springframework.data.redis.connection.RedisNode">
这个值要和Sentinel中指定的master的值一致,不然启动时找不到Sentinel会报错的
<property name="name" value="mymaster"></property>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.193.128"></constructor-arg>
<constructor-arg name="port" value="7002"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.193.128"></constructor-arg>
<constructor-arg name="port" value="7003"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.193.128"></constructor-arg>
<constructor-arg name="port" value="7004"></constructor-arg>
</property>
记住了,这里是指定Sentinel的IP和端口,不是Master和Slave的
<property name="sentinels">
<set>
<bean class="org.springframework.data.redis.connection.RedisNode">
<constructor-arg name="host" value="${redis.sentinel.host1}"></constructor-arg>
<constructor-arg name="port" value="${redis.sentinel.port1}"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort
">
<constructor-arg name="host" value="192.168.193.128
"></constructor-arg>
<constructor-arg name="port" value="7005
"></constructor-arg>
<bean class="org.springframework.data.redis.connection.RedisNode
">
<constructor-arg name="host" value="${redis.sentinel.host2}
"></constructor-arg>
<constructor-arg name="port" value="${redis.sentinel.port2}
"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort
">
<constructor-arg name="host" value="192.168.193.128
"></constructor-arg>
<constructor-arg name="port" value="7006
"></constructor-arg>
<bean class="org.springframework.data.redis.connection.RedisNode
">
<constructor-arg name="host" value="${redis.sentinel.host3}
"></constructor-arg>
<constructor-arg name="port" value="${redis.sentinel.port3}
"></constructor-arg>
</bean>
</set>
</constructor-arg>
</property>
</bean>
<bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
<constructor-arg name="sentinelConfig" ref="sentinelConfiguration"></constructor-arg>
<constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>
</bean> -->
<!--redis连接工厂 -->
<bean
id=
"jedisConnectionFactory"
class=
"org.springframework.data.redis.connection.jedis.JedisConnectionFactory"
destroy-method=
"destroy"
>
<property
name=
"poolConfig"
ref=
"jedisPoolConfig"
></property>
<!--IP地址 -->
<property
name=
"hostName"
value=
"${redis.hostName}"
></property>
<!--端口号 -->
<property
name=
"port"
value=
"${redis.port}"
></property>
<!--如果Redis设置有密码 -->
<property
name=
"password"
value=
"${redis.password}"
/>
<!--客户端超时时间单位是毫秒 -->
<property
name=
"timeout"
value=
"${redis.timeout}"
></property>
</bean>
<!--redis操作模版,使用该对象可以操作redis -->
<bean
id=
"redisTemplate"
class=
"org.springframework.data.redis.core.RedisTemplate"
>
<property
name=
"connectionFactory"
ref=
"jedisConnectionFactory"
/>
<!--如果不配置Serializer,那么存储的时候缺省使用String,如果用User类型存储,那么会提示错误User can't cast to String!! -->
<property
name=
"keySerializer"
>
<bean
class=
"org.springframework.data.redis.serializer.StringRedisSerializer"
/>
</property>
<property
name=
"valueSerializer"
>
<bean
class=
"org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer"
/>
</property>
<property
name=
"hashKeySerializer"
>
<bean
class=
"org.springframework.data.redis.serializer.StringRedisSerializer"
/>
</property>
<property
name=
"hashValueSerializer"
>
<bean
class=
"org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer"
/>
</property>
<!--开启事务 -->
<property
name=
"enableTransactionSupport"
value=
"true"
></property>
</bean >
<!--自定义redis工具类,在需要缓存的地方注入此类 -->
<bean
id=
"redisUtil"
class=
"com.cc.common.util.redisUtil"
>
<property
name=
"redisTemplate"
ref=
"redisTemplate"
/>
</bean>
<bean id="jedisClientCluster" class="com.taotao.rest.dao.impl.JedisClientCluster"></bean>-->
</beans>
\ No newline at end of file
src/main/resources/spring/springmvc.xml
View file @
6e20b4c3
...
...
@@ -14,4 +14,11 @@
<property
name=
"prefix"
value=
"/WEB-INF/jsp/"
/>
<property
name=
"suffix"
value=
".jsp"
/>
</bean>
<bean
id=
"appProperty"
class=
"org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"
>
<property
name=
"locations"
>
<array>
<value>
classpath:resource/*.properties
</value>
</array>
</property>
</bean>
</beans>
\ No newline at end of file
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment