SerializeUtils.java
2.25 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
package com.huaheng.framework.redis.serializer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.SerializationException;
import java.io.*;
public class SerializeUtils<T> implements RedisSerializer<T>
{
private static Logger logger = LoggerFactory.getLogger(SerializeUtils.class);
public static boolean isEmpty(byte[] data)
{
return (data == null || data.length == 0);
}
/**
* 序列化
*
* @param t
* @return
* @throws SerializationException
*/
@Override
public byte[] serialize(T t) throws SerializationException
{
byte[] result = null;
if (t == null)
{
return new byte[0];
}
try (ByteArrayOutputStream byteStream = new ByteArrayOutputStream(128);
ObjectOutputStream objectOutputStream = new ObjectOutputStream(byteStream))
{
if (!(t instanceof Serializable))
{
throw new IllegalArgumentException(
SerializeUtils.class.getSimpleName() + " requires a Serializable payload "
+ "but received an object of type [" + t.getClass().getName() + "]");
}
objectOutputStream.writeObject(t);
objectOutputStream.flush();
result = byteStream.toByteArray();
}
catch (Exception ex)
{
logger.error("Failed to serialize", ex);
}
return result;
}
/**
* 反序列化
*
* @param bytes
* @return
* @throws SerializationException
*/
@SuppressWarnings("unchecked")
@Override
public T deserialize(byte[] bytes) throws SerializationException
{
T result = null;
if (isEmpty(bytes))
{
return null;
}
ObjectInputStream objectInputStream;
try
{
objectInputStream = new ObjectInputStream(new ByteArrayInputStream(bytes));
result = (T) objectInputStream.readObject();
}
catch (Exception e)
{
logger.error("Failed to deserialize", e);
}
return result;
}
}