redisTemplate 鍵值序列化策略
RedisSerializer<T>
StringRedisSerializer
JdkSerializationRedisSerializer
keySerializer
valueSerializer
hashKeySerializer
hashValueSerializer
public class RedisTemplate<K, V> extends RedisAccessor implements RedisOperations<K, V>, BeanClassLoaderAware {
private boolean enableDefaultSerializer = true;
private RedisSerializer<?> defaultSerializer;
private RedisSerializer keySerializer = null;
private RedisSerializer valueSerializer = null;
private RedisSerializer hashKeySerializer = null;
private RedisSerializer hashValueSerializer = null;
private RedisSerializer<String> stringSerializer = new StringRedisSerializer();
/* redisTemplate 默認的序列化策略 */
public void afterPropertiesSet() {
super.afterPropertiesSet();
boolean defaultUsed = false;
if (defaultSerializer == null) {
defaultSerializer = new JdkSerializationRedisSerializer(
classLoader != null ? classLoader : this.getClass().getClassLoader());
}
if (enableDefaultSerializer) {
if (keySerializer == null) {
keySerializer = defaultSerializer;
defaultUsed = true;
}
if (valueSerializer == null) {
valueSerializer = defaultSerializer;
defaultUsed = true;
}
if (hashKeySerializer == null) {
hashKeySerializer = defaultSerializer;
defaultUsed = true;
}
if (hashValueSerializer == null) {
hashValueSerializer = defaultSerializer;
defaultUsed = true;
}
}
//啟用默認序列化器並且默認序列化器被使用,檢查默認序列化器為 null ,則序列化器沒有全部初始化成功。
if (enableDefaultSerializer && defaultUsed) {
Assert.notNull(defaultSerializer, "default serializer null and not all serializers initialized");
}
if (scriptExecutor == null) {
this.scriptExecutor = new DefaultScriptExecutor<K>(this);
}
initialized = true;
}
}
keySerializer 字符串 哈希 列表 集合 有序集合的鍵的序列化策略。
valueSerializer 字符串 列表 集合 有序集合的值的序列化策略。
hashKeySerializer 哈希的小鍵的序列化策略
hashValueSerializer 哈希的值的序列化策略
StringRedisSerializer 只能是 String 對象
JdkSerializationRedisSerializer 實現了序列化接口的對象。
String 類型
RedisSerializer<T>
將一個對象序列化字節數組,存入 redis 。將 redis 得到的字節數組反序列化成對象。
public interface RedisSerializer<T> {
byte[] serialize(T t) throws SerializationException;
T deserialize(byte[] bytes) throws SerializationException;
}
@Test
public void testStrCR(){
redisTemplate.boundValueOps("用戶名").set("劉備");
String username = (String) redisTemplate.boundValueOps("用戶名").get();
System.out.println(username);//劉備
}
@Test
public void testStrD(){
redisTemplate.delete("用戶名");
}
127.0.0.1:6379> keys *
1) "\xe7\x94\xa8\xe6\x88\xb7\xe5\x90\x8d" UTF-8 用戶名
2) "\xd3\xc3\xbb\xa7\xc3\xfb" GBK 用戶名
127.0.0.1:6379> get "\xd3\xc3\xbb\xa7\xc3\xfb" GBK 用戶名
"\xe5\x88\x98\xe5\xa4\x87" UTF-8 劉備
127.0.0.1:6379> get "\xe7\x94\xa8\xe6\x88\xb7\xe5\x90\x8d" UTF-8 用戶名
"\xe5\x88\x98\xe5\xa4\x87" UTF-8 劉備
/*
可見 redis 命令行打印就是字節數組的16進制形式。中文字符串 + 編碼 = 字節數組。客戶端發送給 redis 的是字節數組。
*/
@Test
public void x3() throws UnsupportedEncodingException {
byte[] bytesUTF8 = "用戶名".getBytes("UTF-8");
System.out.println(bytesToHexString(bytesUTF8));//e794a8e688b7e5908d
byte[] bytesGBK = "用戶名".getBytes("GBK");
System.out.println(bytesToHexString(bytesGBK));//d3c3bba7c3fb
byte[] bytes= "劉備".getBytes("UTF-8");
System.out.println(bytesToHexString(bytes));//e58898e5a487
}
常用字節轉換(字符串轉16進制,16進制轉字符串)https://blog.csdn.net/yyz_1987/article/details/80634224
public static String bytesToHexString(byte[] src){
StringBuilder stringBuilder = new StringBuilder("");
if (src == null || src.length <= 0) {
return null;
}
for (int i = 0; i < src.length; i++) {
int v = src[i] & 0xFF;
String hv = Integer.toHexString(v);
if (hv.length() < 2) {
stringBuilder.append(0);
}
stringBuilder.append(hv);
}
return stringBuilder.toString();
}
//原文:https://blog.csdn.net/yyz_1987/article/details/80634224
package org.springframework.data.redis.serializer;
public class StringRedisSerializer implements RedisSerializer<String> {
private final Charset charset;
public StringRedisSerializer() {
this(Charset.forName("UTF8"));
}
public StringRedisSerializer(Charset charset) {
Assert.notNull(charset);
this.charset = charset;
}
public String deserialize(byte[] bytes) {
return (bytes == null ? null : new String(bytes, charset));
}
public byte[] serialize(String string) {
return (string == null ? null : string.getBytes(charset));
}
}
修改 redisTemplate 鍵值的序列化策略
<!-- 配置RedisTemplate -->
<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
<property name="connectionFactory" ref="jedisConnectionFactory"/>
<!-- 序列化策略 推薦使用StringRedisSerializer ,可以通過構造參數指定字符集,默認為 UTF-8 -->
<property name="keySerializer">
<bean class="org.springframework.data.redis.serializer.StringRedisSerializer">
<constructor-arg ref="gbkCharSet" />
</bean>
</property>
<property name="valueSerializer">
<bean class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
</property>
<property name="hashKeySerializer">
<bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
</property>
<property name="hashValueSerializer">
<bean class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
</property>
</bean>
package com.mozq.charset;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import java.nio.charset.Charset;
//@Component
@Configuration
public class CharSetUtil {
@Bean("gbkCharSet")
public Charset gbkCharSet(){
return Charset.forName("GBK");
}
}