Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
武汉红喜
whatsmars
提交
d89338d1
W
whatsmars
项目概览
武汉红喜
/
whatsmars
通知
3
Star
0
Fork
1
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
W
whatsmars
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
d89338d1
编写于
1月 11, 2019
作者:
武汉红喜
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
去掉spring-data-redis封装
上级
25804ba7
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
8 addition
and
332 deletion
+8
-332
whatsmars-redis/pom.xml
whatsmars-redis/pom.xml
+8
-3
whatsmars-redis/src/main/java/org/hongxi/whatsmars/redis/client/service/RedisService.java
...g/hongxi/whatsmars/redis/client/service/RedisService.java
+0
-81
whatsmars-redis/src/main/java/org/hongxi/whatsmars/redis/client/service/impl/RedisServiceImpl.java
...whatsmars/redis/client/service/impl/RedisServiceImpl.java
+0
-248
未找到文件。
whatsmars-redis/pom.xml
浏览文件 @
d89338d1
...
...
@@ -7,7 +7,7 @@
<parent>
<groupId>
org.hongxi
</groupId>
<artifactId>
whatsmars-parent
</artifactId>
<version>
ByteStack.CN
1
</version>
<version>
Rocket.S
1
</version>
</parent>
<artifactId>
whatsmars-redis
</artifactId>
...
...
@@ -21,8 +21,8 @@
<artifactId>
jedis
</artifactId>
</dependency>
<dependency>
<groupId>
org.springframework
.data
</groupId>
<artifactId>
spring-
data-redis
</artifactId>
<groupId>
org.springframework
</groupId>
<artifactId>
spring-
context
</artifactId>
<optional>
true
</optional>
</dependency>
<dependency>
...
...
@@ -38,6 +38,11 @@
<artifactId>
logback-classic
</artifactId>
<optional>
true
</optional>
</dependency>
<dependency>
<groupId>
commons-logging
</groupId>
<artifactId>
commons-logging
</artifactId>
<optional>
true
</optional>
</dependency>
<dependency>
<groupId>
org.springframework
</groupId>
...
...
whatsmars-redis/src/main/java/org/hongxi/whatsmars/redis/client/service/RedisService.java
已删除
100644 → 0
浏览文件 @
25804ba7
package
org.hongxi.whatsmars.redis.client.service
;
import
java.io.Serializable
;
import
java.util.Collection
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Set
;
/**
* Created by shenhongxi on 2018/12/24.
*/
public
interface
RedisService
{
void
set
(
String
key
,
String
value
);
void
set
(
String
key
,
String
value
,
long
seconds
);
void
setIfAbsent
(
String
key
,
String
value
);
String
get
(
String
key
);
String
getAndSet
(
String
key
,
String
value
);
void
multiSet
(
Map
<
String
,
String
>
map
);
List
<
String
>
multiGet
(
Collection
<
String
>
keys
);
Long
increment
(
String
key
,
long
delta
);
Double
increment
(
String
key
,
double
delta
);
Integer
append
(
String
key
,
String
value
);
String
get
(
String
key
,
long
start
,
long
end
);
Long
size
(
String
key
);
Boolean
setBit
(
String
key
,
long
offset
,
boolean
value
);
Boolean
getBit
(
String
key
,
long
offset
);
long
sadd
(
String
key
,
String
...
values
);
Set
<
String
>
smembers
(
String
key
);
boolean
sismember
(
String
key
,
String
value
);
void
hset
(
String
key
,
String
hashKey
,
String
value
);
String
hget
(
String
key
,
String
hashKey
);
boolean
hexists
(
String
key
,
String
hashKey
);
void
hdel
(
String
key
,
String
...
hashKeys
);
long
leftPush
(
String
key
,
Serializable
value
);
Serializable
rightPop
(
String
key
);
List
<
Serializable
>
range
(
String
key
,
long
start
,
long
end
);
void
convertAndSend
(
String
channel
,
Object
obj
);
void
delete
(
String
key
);
boolean
exists
(
String
key
);
Set
<
String
>
matchKeys
(
String
pattern
);
<
T
>
void
set
(
String
key
,
T
value
,
long
seconds
)
throws
Exception
;
<
T
>
void
set
(
String
key
,
T
value
)
throws
Exception
;
<
T
>
T
get
(
String
key
,
Class
<
T
>
clazz
);
boolean
set
(
byte
[]
key
,
byte
[]
value
,
long
seconds
);
boolean
set
(
byte
[]
key
,
byte
[]
value
);
byte
[]
getBytes
(
String
key
);
}
whatsmars-redis/src/main/java/org/hongxi/whatsmars/redis/client/service/impl/RedisServiceImpl.java
已删除
100644 → 0
浏览文件 @
25804ba7
package
org.hongxi.whatsmars.redis.client.service.impl
;
import
com.alibaba.fastjson.JSON
;
import
com.fasterxml.jackson.databind.ObjectMapper
;
import
lombok.Setter
;
import
lombok.extern.slf4j.Slf4j
;
import
org.hongxi.whatsmars.redis.client.service.RedisService
;
import
org.springframework.dao.DataAccessException
;
import
org.springframework.data.redis.connection.RedisConnection
;
import
org.springframework.data.redis.core.RedisCallback
;
import
org.springframework.data.redis.core.RedisTemplate
;
import
org.springframework.data.redis.core.StringRedisTemplate
;
import
org.springframework.stereotype.Service
;
import
javax.annotation.Resource
;
import
java.io.Serializable
;
import
java.util.Collection
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Set
;
import
java.util.concurrent.TimeUnit
;
/**
* Created by shenhongxi on 2018/12/24.
*/
@Slf4j
@Service
public
class
RedisServiceImpl
implements
RedisService
{
@Resource
private
RedisTemplate
<
String
,
Serializable
>
redisTemplate
;
@Resource
private
StringRedisTemplate
stringRedisTemplate
;
@Setter
private
ObjectMapper
objectMapper
=
new
ObjectMapper
();
@Override
public
void
set
(
String
key
,
String
value
)
{
stringRedisTemplate
.
opsForValue
().
set
(
key
,
value
);
}
@Override
public
void
set
(
String
key
,
String
value
,
long
seconds
)
{
stringRedisTemplate
.
opsForValue
().
set
(
key
,
value
,
seconds
,
TimeUnit
.
SECONDS
);
}
@Override
public
void
setIfAbsent
(
String
key
,
String
value
)
{
stringRedisTemplate
.
opsForValue
().
setIfAbsent
(
key
,
value
);
}
@Override
public
String
get
(
String
key
)
{
return
stringRedisTemplate
.
opsForValue
().
get
(
key
);
}
@Override
public
String
getAndSet
(
String
key
,
String
value
)
{
return
stringRedisTemplate
.
opsForValue
().
getAndSet
(
key
,
value
);
}
@Override
public
void
multiSet
(
Map
<
String
,
String
>
map
)
{
stringRedisTemplate
.
opsForValue
().
multiSet
(
map
);
}
@Override
public
List
<
String
>
multiGet
(
Collection
<
String
>
keys
)
{
return
stringRedisTemplate
.
opsForValue
().
multiGet
(
keys
);
}
@Override
public
Long
increment
(
String
key
,
long
delta
)
{
return
stringRedisTemplate
.
opsForValue
().
increment
(
key
,
delta
);
}
@Override
public
Double
increment
(
String
key
,
double
delta
)
{
return
stringRedisTemplate
.
opsForValue
().
increment
(
key
,
delta
);
}
@Override
public
Integer
append
(
String
key
,
String
value
)
{
return
stringRedisTemplate
.
opsForValue
().
append
(
key
,
value
);
}
@Override
public
String
get
(
String
key
,
long
start
,
long
end
)
{
return
stringRedisTemplate
.
opsForValue
().
get
(
key
,
start
,
end
);
}
@Override
public
Long
size
(
String
key
)
{
return
stringRedisTemplate
.
opsForValue
().
size
(
key
);
}
@Override
public
Boolean
setBit
(
String
key
,
long
offset
,
boolean
value
)
{
return
stringRedisTemplate
.
opsForValue
().
setBit
(
key
,
offset
,
value
);
}
@Override
public
Boolean
getBit
(
String
key
,
long
offset
)
{
return
stringRedisTemplate
.
opsForValue
().
getBit
(
key
,
offset
);
}
@Override
public
long
sadd
(
String
key
,
String
...
values
)
{
return
stringRedisTemplate
.
opsForSet
().
add
(
key
,
values
);
}
@Override
public
Set
<
String
>
smembers
(
String
key
)
{
return
stringRedisTemplate
.
opsForSet
().
members
(
key
);
}
@Override
public
boolean
sismember
(
String
key
,
String
value
)
{
return
stringRedisTemplate
.
opsForSet
().
isMember
(
key
,
value
);
}
@Override
public
void
hset
(
String
key
,
String
hashKey
,
String
value
)
{
redisTemplate
.
opsForHash
().
put
(
key
,
hashKey
,
value
);
}
@Override
public
String
hget
(
String
key
,
String
hashKey
)
{
if
(
hexists
(
key
,
hashKey
))
{
return
redisTemplate
.
opsForHash
().
get
(
key
,
hashKey
).
toString
();
}
return
null
;
}
@Override
public
boolean
hexists
(
String
key
,
String
hashKey
)
{
return
redisTemplate
.
opsForHash
().
hasKey
(
key
,
hashKey
);
}
@Override
public
void
hdel
(
String
key
,
String
...
hashKeys
)
{
redisTemplate
.
opsForHash
().
delete
(
key
,
hashKeys
);
}
@Override
public
long
leftPush
(
String
key
,
Serializable
value
)
{
return
redisTemplate
.
opsForList
().
leftPush
(
key
,
value
);
}
@Override
public
Serializable
rightPop
(
String
key
)
{
return
redisTemplate
.
opsForList
().
rightPop
(
key
);
}
@Override
public
List
<
Serializable
>
range
(
String
key
,
long
start
,
long
end
)
{
return
redisTemplate
.
opsForList
().
range
(
key
,
start
,
end
);
}
@Override
public
void
convertAndSend
(
String
channel
,
Object
obj
)
{
assert
obj
!=
null
;
String
msg
=
obj
instanceof
String
?
String
.
valueOf
(
obj
)
:
JSON
.
toJSONString
(
obj
);
stringRedisTemplate
.
convertAndSend
(
channel
,
msg
);
}
@Override
public
void
delete
(
String
key
)
{
stringRedisTemplate
.
delete
(
key
);
}
@Override
public
boolean
exists
(
String
key
)
{
return
redisTemplate
.
execute
(
new
RedisCallback
<
Boolean
>()
{
@Override
public
Boolean
doInRedis
(
RedisConnection
connection
)
throws
DataAccessException
{
return
connection
.
exists
(
key
.
getBytes
());
}
});
}
@Override
public
Set
<
String
>
matchKeys
(
String
pattern
)
{
return
redisTemplate
.
keys
(
pattern
);
}
@Override
public
<
T
>
void
set
(
String
key
,
T
value
,
long
seconds
)
throws
Exception
{
this
.
set
(
key
.
getBytes
(),
serialize
(
value
),
seconds
);
}
@Override
public
<
T
>
void
set
(
String
key
,
T
value
)
throws
Exception
{
this
.
set
(
key
.
getBytes
(),
serialize
(
value
));
}
@Override
public
<
T
>
T
get
(
String
key
,
Class
<
T
>
clazz
)
{
byte
[]
value
=
this
.
getBytes
(
key
);
return
this
.
deserialize
(
value
,
clazz
);
}
@Override
public
boolean
set
(
byte
[]
key
,
byte
[]
value
,
long
seconds
)
{
return
redisTemplate
.
execute
(
new
RedisCallback
<
Boolean
>()
{
@Override
public
Boolean
doInRedis
(
RedisConnection
connection
)
throws
DataAccessException
{
connection
.
setEx
(
key
,
seconds
,
value
);
return
true
;
}
});
}
@Override
public
boolean
set
(
byte
[]
key
,
byte
[]
value
)
{
return
redisTemplate
.
execute
(
new
RedisCallback
<
Boolean
>()
{
@Override
public
Boolean
doInRedis
(
RedisConnection
connection
)
throws
DataAccessException
{
connection
.
set
(
key
,
value
);
return
true
;
}
});
}
@Override
public
byte
[]
getBytes
(
String
key
)
{
return
redisTemplate
.
execute
(
new
RedisCallback
<
byte
[]>()
{
@Override
public
byte
[]
doInRedis
(
RedisConnection
connection
)
throws
DataAccessException
{
return
connection
.
get
(
key
.
getBytes
());
}
});
}
private
<
T
>
byte
[]
serialize
(
T
value
)
throws
Exception
{
return
objectMapper
.
writeValueAsBytes
(
value
);
}
private
<
T
>
T
deserialize
(
byte
[]
value
,
Class
<
T
>
clazz
)
{
try
{
return
objectMapper
.
readValue
(
value
,
clazz
);
}
catch
(
Exception
e
)
{
log
.
error
(
e
.
getMessage
(),
e
);
}
return
null
;
}
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录