- 苏萦
-
public KCDataFormatter() { }
/// <summary>
/// 将DataSet格式化成字节数组byte[]
/// </summary>
/// <param name="dsOriginal">DataSet对象</param>
/// <returns>字节数组</returns>
public static byte[] GetBinaryFormatData(DataSet dsOriginal)
{
byte[] binaryDataResult = null;
MemoryStream memStream = new MemoryStream();
IFormatter brFormatter = new BinaryFormatter();
dsOriginal.RemotingFormat = SerializationFormat.Binary;
brFormatter.Serialize(memStream, dsOriginal);
binaryDataResult = memStream.ToArray();
memStream.Close();
memStream.Dispose();
return binaryDataResult;
}
/// <summary>
/// 将DataSet格式化成字节数组byte[],并且已经经过压缩
/// </summary>
/// <param name="dsOriginal">DataSet对象</param>
/// <returns>字节数组</returns>
public static byte[] GetBinaryFormatDataCompress(DataSet dsOriginal)
{
byte[] binaryDataResult = null;
MemoryStream memStream = new MemoryStream();
IFormatter brFormatter = new BinaryFormatter();
dsOriginal.RemotingFormat = SerializationFormat.Binary;
brFormatter.Serialize(memStream, dsOriginal);
binaryDataResult = memStream.ToArray();
memStream.Close();
memStream.Dispose();
return Compress(binaryDataResult);
}
/// <summary>
/// 解压数据
/// </summary>
/// <param name="data"></param>
/// <returns></returns>
public static byte[] Decompress(byte[] data)
{
byte[] bData;
MemoryStream ms = new MemoryStream();
ms.Write(data, 0, data.Length);
ms.Position = 0;
GZipStream stream = new GZipStream(ms, CompressionMode.Decompress, true);
byte[] buffer = new byte[1024];
MemoryStream temp = new MemoryStream();
int read = stream.Read(buffer, 0, buffer.Length);
while (read > 0)
{
temp.Write(buffer, 0, read);
read = stream.Read(buffer, 0, buffer.Length);
}
//必须把stream流关闭才能返回ms流数据,不然数据会不完整
stream.Close();
stream.Dispose();
ms.Close();
ms.Dispose();
bData = temp.ToArray();
temp.Close();
temp.Dispose();
return bData;
}
/// <summary>
/// 压缩数据
/// </summary>
/// <param name="data"></param>
/// <returns></returns>
public static byte[] Compress(byte[] data)
{
byte[] bData;
MemoryStream ms = new MemoryStream();
GZipStream stream = new GZipStream(ms, CompressionMode.Compress, true);
stream.Write(data, 0, data.Length);
stream.Close();
stream.Dispose();
//必须把stream流关闭才能返回ms流数据,不然数据会不完整
//并且解压缩方法stream.Read(buffer, 0, buffer.Length)时会返回0
bData = ms.ToArray();
ms.Close();
ms.Dispose();
return bData;
}
/// <summary>
/// 将字节数组反序列化成DataSet对象
/// </summary>
/// <param name="binaryData">字节数组</param>
/// <returns>DataSet对象</returns>
public static DataSet RetrieveDataSet(byte[] binaryData)
{
DataSet ds = null;
MemoryStream memStream = new MemoryStream(binaryData, true);
//byte[] bs = memStream.GetBuffer();
// memStream.Write(bs, 0, bs.Length);
//memStream.Seek(0, SeekOrigin.Begin);
IFormatter brFormatter = new BinaryFormatter();
ds = (DataSet)brFormatter.Deserialize(memStream);
return ds;
}
/// <summary>
/// 将字节数组反解压后序列化成DataSet对象
/// </summary>
/// <param name="binaryData">字节数组</param>
/// <returns>DataSet对象</returns>
public static DataSet RetrieveDataSetDecompress(byte[] binaryData)
{
DataSet dsOriginal = null;
MemoryStream memStream = new MemoryStream(Decompress(binaryData));
IFormatter brFormatter = new BinaryFormatter();
Object obj = brFormatter.Deserialize(memStream);
dsOriginal = (DataSet)obj;
return dsOriginal;
}
/// <summary>
/// 将object格式化成字节数组byte[]
/// </summary>
/// <param name="dsOriginal">object对象</param>
/// <returns>字节数组</returns>
public static byte[] GetBinaryFormatData(object dsOriginal)
{
byte[] binaryDataResult = null;
MemoryStream memStream = new MemoryStream();
IFormatter brFormatter = new BinaryFormatter();
brFormatter.Serialize(memStream, dsOriginal);
binaryDataResult = memStream.ToArray();
memStream.Close();
memStream.Dispose();
return binaryDataResult;
}
/// <summary>
/// 将objec格式化成字节数组byte[],并压缩
/// </summary>
/// <param name="dsOriginal">object对象</param>
/// <returns>字节数组</returns>
public static byte[] GetBinaryFormatDataCompress(object dsOriginal)
{
byte[] binaryDataResult = null;
MemoryStream memStream = new MemoryStream();
IFormatter brFormatter = new BinaryFormatter();
brFormatter.Serialize(memStream, dsOriginal);
binaryDataResult = memStream.ToArray();
memStream.Close();
memStream.Dispose();
return Compress(binaryDataResult);
}
/// <summary>
/// 将字节数组反序列化成object对象
/// </summary>
/// <param name="binaryData">字节数组</param>
/// <returns>object对象</returns>
public static object RetrieveObject(byte[] binaryData)
{
MemoryStream memStream = new MemoryStream(binaryData);
IFormatter brFormatter = new BinaryFormatter();
Object obj = brFormatter.Deserialize(memStream);
return obj;
}
- 左迁
-
* 回复内容中包含的链接未经审核,可能存在风险,暂不予完整展示!
===================== begin =======================
/**
* 将对象转成字节流
*
* @author yurentian@1*.com
* @param Object obj
* @return btye[] byteArray
*/
public static byte[] stringToByte(Object obj) {
byte[] byteArray = null;
if (obj != null) {
ByteArrayOutputStream byteos = new ByteArrayOutputStream();
ObjectOutputStream objos = null;
try {
objos = new ObjectOutputStream(byteos);
objos.writeObject(obj);
byteArray = byteos.toByteArray();
} catch (Exception e) {
e.printStackTrace();
} finally {
closeStream(objos);
closeStream(byteos);
}
}
return byteArray;
}
/**
* 关闭流
* @author yurentian@1*.com
* @param stream
* @return
*/
private static void closeStream(Object stream) {
if (stream != null) {
try {
if (stream instanceof InputStream) {
((InputStream) stream).close();
} else if (stream instanceof OutputStream) {
((OutputStream) stream).close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
===================== end =======================
- FinCloud
-
/// 将一个object对象序列化,返回一个byte[]
/// </summary>
/// <param name="obj">能序列化的对象</param>
/// <returns></returns>
public static byte[] ObjectToBytes(object obj)
{
using (MemoryStream ms = new MemoryStream())
{
IFormatter formatter = new BinaryFormatter();
formatter.Serialize(ms, obj);
return ms.GetBuffer();
}
}