[Serializable]
public class Packet : ISerializable
Packet 是我用来保存数据的类，实现了 ISerializable 以及我从 [ http://msdn.microsoft.com/en-us/library/ms182342.aspx]中读取的所有必需的构造函数和函数
[SecurityPermission(SecurityAction.Demand, SerializationFormatter = true)]
protected virtual void GetObjectData(SerializationInfo info, StreamingContext context)
[SecurityPermission(SecurityAction.LinkDemand, Flags = SecurityPermissionFlag.SerializationFormatter)]
private void ISerializable.GetObjectData(SerializationInfo info, StreamingContext context)
protected Packet(SerializationInfo info, StreamingContext context)
我将我的数据包放在一个 dll 中并在服务器和客户端应用程序中引用它，以便他们可以使用 TcpListener 传输数据包（转换为 byte[] 并发送、接收和转换回）
我测试了服务器客户端与单个数据包完美配合，无需发送文件或小于或等于 1mb 文件。这是服务器从客户端收到带有重命名命令的数据包时的日志
[7174c67d-518f-4960-affe-d3bc67320d7e] Waiting for message
20/07/2014 13:03:48: {Rename} SUCCESS from 7174c67d-518f-4960-affe-d3bc67320d7e to NewName
每个数据包，它将最大 1mb 长度的字节数组作为文件部分的数据放在 byte[] msgFileData 属性中，TcpListener 接收最大 2mb。
问题是当发送一个超过 1mb 的文件时，我将该文件拆分为每个最大 1mb 的部分，并且只有一些以正确格式接收的数据包，可以反序列化，并且一些是无效的数据包格式。它工作了一点时间，通常会显示这个错误，所以我只能在幸运的时刻上传它
20/07/2014 13:03:48: {Rename} SUCCESS from 7174c67d-518f-4960-affe-d3bc67320d7e to NewName
20/07/2014 13:03:48: [NewName] Waiting for message
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Uploaded 1/5 part of AMediumFile5mb.mp3 (Guid 40695b81-18b1-4329-bb00-344474458c47) from NewName
20/07/2014 13:04:22: Uploaded 2/5 part of AMediumFile5mb.mp3 (Guid 40695b81-18b1-4329-bb00-344474458c47) from NewName
20/07/2014 13:04:22: Error Packet: System.Runtime.Serialization.SerializationException: Binary stream '228' does not contain a valid BinaryHeader. Possible causes are invalid stream or object version change between serialization and deserialization.
at System.Runtime.Serialization.Formatters.Binary.__BinaryParser.Run()
at System.Runtime.Serialization.Formatters.Binary.ObjectReader.Deserialize(HeaderHandler handler, __BinaryParser serParser, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream, HeaderHandler handler, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream)
at engine.converter.prjnameConverter.BinaryDeserializeObject[T](Byte[] serializedType) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 74
at engine.converter.prjnameConverter.DeSerializeFromByteArray[T](Byte[] data) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 52
at prjname.entity.Client.readResponsePacket(Byte[] data, Packet& Packet, Boolean& bValidPacket) in d:\Work\C#\Project\Work\prjname-Server\entity\Client.cs:line 154
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Uploaded 3/5 part of AMediumFile5mb.mp3 (Guid 40695b81-18b1-4329-bb00-344474458c47) from NewName
20/07/2014 13:04:22: Error Packet: System.Runtime.Serialization.SerializationException: The input stream is not a valid binary format. The starting contents (in bytes) are: 30-0A-00-80-B2-98-3D-A7-FC-B4-41-FC-4F-02-81-03-8A ...
at System.Runtime.Serialization.Formatters.Binary.SerializationHeaderRecord.Read(__BinaryParser input)
at System.Runtime.Serialization.Formatters.Binary.__BinaryParser.ReadSerializationHeaderRecord()
at System.Runtime.Serialization.Formatters.Binary.__BinaryParser.Run()
at System.Runtime.Serialization.Formatters.Binary.ObjectReader.Deserialize(HeaderHandler handler, __BinaryParser serParser, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream, HeaderHandler handler, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream)
at engine.converter.prjnameConverter.BinaryDeserializeObject[T](Byte[] serializedType) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 74
at engine.converter.prjnameConverter.DeSerializeFromByteArray[T](Byte[] data) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 52
at prjname.entity.Client.readResponsePacket(Byte[] data, Packet& Packet, Boolean& bValidPacket) in d:\Work\C#\Project\Work\prjname-Server\entity\Client.cs:line 154
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Error Packet: System.Runtime.Serialization.SerializationException: The input stream is not a valid binary format. The starting contents (in bytes) are: 2B-01-83-40-2E-12-63-8F-C7-F6-89-B2-40-8C-CC-86-2E ...
at System.Runtime.Serialization.Formatters.Binary.SerializationHeaderRecord.Read(__BinaryParser input)
at System.Runtime.Serialization.Formatters.Binary.__BinaryParser.ReadSerializationHeaderRecord()
at System.Runtime.Serialization.Formatters.Binary.__BinaryParser.Run()
at System.Runtime.Serialization.Formatters.Binary.ObjectReader.Deserialize(HeaderHandler handler, __BinaryParser serParser, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream, HeaderHandler handler, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream)
at engine.converter.prjnameConverter.BinaryDeserializeObject[T](Byte[] serializedType) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 74
at engine.converter.prjnameConverter.DeSerializeFromByteArray[T](Byte[] data) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 52
at prjname.entity.Client.readResponsePacket(Byte[] data, Packet& Packet, Boolean& bValidPacket) in d:\Work\C#\Project\Work\prjname-Server\entity\Client.cs:line 154
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Error Packet: System.Runtime.Serialization.SerializationException: Binary stream '57' does not contain a valid BinaryHeader. Possible causes are invalid stream or object version change between serialization and deserialization.
at System.Runtime.Serialization.Formatters.Binary.__BinaryParser.Run()
at System.Runtime.Serialization.Formatters.Binary.ObjectReader.Deserialize(HeaderHandler handler, __BinaryParser serParser, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream, HeaderHandler handler, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream)
at engine.converter.prjnameConverter.BinaryDeserializeObject[T](Byte[] serializedType) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 74
at engine.converter.prjnameConverter.DeSerializeFromByteArray[T](Byte[] data) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 52
at prjname.entity.Client.readResponsePacket(Byte[] data, Packet& Packet, Boolean& bValidPacket) in d:\Work\C#\Project\Work\prjname-Server\entity\Client.cs:line 154
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Error Packet: System.Runtime.Serialization.SerializationException: The input stream is not a valid binary format. The starting contents (in bytes) are: AA-01-17-58-02-01-40-C1-D1-51-10-38-29-A8-D5-68-C0 ...
at System.Runtime.Serialization.Formatters.Binary.SerializationHeaderRecord.Read(__BinaryParser input)
at System.Runtime.Serialization.Formatters.Binary.__BinaryParser.ReadSerializationHeaderRecord()
at System.Runtime.Serialization.Formatters.Binary.__BinaryParser.Run()
at System.Runtime.Serialization.Formatters.Binary.ObjectReader.Deserialize(HeaderHandler handler, __BinaryParser serParser, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream, HeaderHandler handler, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream)
at engine.converter.prjnameConverter.BinaryDeserializeObject[T](Byte[] serializedType) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 74
at engine.converter.prjnameConverter.DeSerializeFromByteArray[T](Byte[] data) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 52
at prjname.entity.Client.readResponsePacket(Byte[] data, Packet& Packet, Boolean& bValidPacket) in d:\Work\C#\Project\Work\prjname-Server\entity\Client.cs:line 154
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Error Packet: System.Runtime.Serialization.SerializationException: Binary stream '150' does not contain a valid BinaryHeader. Possible causes are invalid stream or object version change between serialization and deserialization.
at System.Runtime.Serialization.Formatters.Binary.__BinaryParser.Run()
at System.Runtime.Serialization.Formatters.Binary.ObjectReader.Deserialize(HeaderHandler handler, __BinaryParser serParser, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream, HeaderHandler handler, Boolean fCheck, Boolean isCrossAppDomain, IMethodCallMessage methodCallMessage)
at System.Runtime.Serialization.Formatters.Binary.BinaryFormatter.Deserialize(Stream serializationStream)
at engine.converter.prjnameConverter.BinaryDeserializeObject[T](Byte[] serializedType) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 74
at engine.converter.prjnameConverter.DeSerializeFromByteArray[T](Byte[] data) in d:\Work\C#\Project\Work\prjnameDll\converter\prjnameConverter.cs:line 52
at prjname.entity.Client.readResponsePacket(Byte[] data, Packet& Packet, Boolean& bValidPacket) in d:\Work\C#\Project\Work\prjname-Server\entity\Client.cs:line 154
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Uploaded 4/5 part of AMediumFile5mb.mp3 (Guid 40695b81-18b1-4329-bb00-344474458c47) from NewName
它必须是这样的
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Uploaded 1/5 part of AMediumFile5mb.mp3 (Guid 40695b81-18b1-4329-bb00-344474458c47) from NewName
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Uploaded 2/5 part of AMediumFile5mb.mp3 (Guid 40695b81-18b1-4329-bb00-344474458c47) from NewName
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Uploaded 3/5 part of AMediumFile5mb.mp3 (Guid 40695b81-18b1-4329-bb00-344474458c47) from NewName
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Uploaded 4/5 part of AMediumFile5mb.mp3 (Guid 40695b81-18b1-4329-bb00-344474458c47) from NewName
20/07/2014 13:04:22: [NewName] Waiting for message
20/07/2014 13:04:22: Uploaded 5/5 part of AMediumFile5mb.mp3 (Guid 40695b81-18b1-4329-bb00-344474458c47) from NewName
**********客户*************
MainForm.cs
private void uploadFileToServerToolStripMenuItem_Click(object sender, EventArgs e)
{
OpenFileDialog dlgChooseUploadFile = new OpenFileDialog();
dlgChooseUploadFile.Multiselect = false;
/*some code*/
if (dlgChooseUploadFile.ShowDialog() == DialogResult.OK)
{
/*some code*/
string strFilePath = dlgChooseUploadFile.FileName;
muUser.Upload(strFilePath); //muUser is class User
}
}
用户.cs
public void Upload(string strFilePath)
{
OnLockForm(true); // Disable MainForm while uploading
UploadingForm uploader = new UploadingForm(strFilePath, this);//=> this: pass user as parameter to get user info like name, NetworkStream for sending request
uploader.OnStopUpload += new UploadingForm.StopUpload((string strMessage)=>
{
OnLockForm(false);
OnNotifyMessage(strMessage);
});
uploader.ShowDialog();
}
上传表单.cs
public partial class UploadingForm : Form
{
public delegate void StopUpload(string strMessage);
public StopUpload OnStopUpload;
private string mstrFilePath;
private User sender;
public UploadingForm(string strFilePath, User sender)
{
CheckForIllegalCrossThreadCalls = false;
this.mstrFilePath = strFilePath;
this.sender = sender;
InitializeComponent();
}
private void UploadingForm_Shown(object sender, EventArgs e)
{
//some code
ParepareUpload();
}
private void ParepareUpload()
{
Uploader uploader = new Uploader(mstrFilePath, sender);
uploader.OnAPartUploaded += new Uploader.APartUploaded(()=>
{
/*some code but I disabled this delegate*/
});
uploader.OnUploadCanceled+= new Uploader.UploadCancel((string strReason)=>
{
OnStopUpload(strReason);
this.Dispose();
});
uploader.OnUploadCompleted += new Uploader.UploadCompleted(() =>
{
OnStopUpload("Upload done");
this.Dispose();
});
uploader.Begin();
}
上传者.cs
public class Uploader
{
public delegate void UploadCompleted();
public UploadCompleted OnUploadCompleted;
public delegate void APartUploaded();
public APartUploaded OnAPartUploaded;
public delegate void UploadCancel(string strReason);
public UploadCancel OnUploadCanceled;
public string mstrFilePath { get; private set; }
public string mUserName { get; private set; }
public Guid mGuid { get; private set; }
private NetworkStream mnetStream { get; set; }
public Uploader(string strFilePath, User sender)
{
this.mGuid = Guid.NewGuid();
this.mUserName = sender.mstrName;
this.mstrFilePath = strFilePath;
this.mnetStream = sender.netStream;
}
public void Begin()
{
/*some code*/
BeginUploadFile();
}
private void BeginUploadFile()
{
try
{
string strFileName = Path.GetFileName(mstrFilePath);
long lFileSize = new FileInfo(mstrFilePath).Length;
byte iPartsCount = (byte)Math.Ceiling((decimal)lFileSize / engine.data.Packet.PACKET_MAXSIZE_UPLOADPART);
for (byte i = 1; i <= iPartsCount; i++)
{
int numBytesToRead = Packet.PACKET_MAXSIZE_UPLOADPART;
if (i == iPartsCount)
{
numBytesToRead = (int)(lFileSize - ((i - 1) * Packet.PACKET_MAXSIZE_UPLOADPART));
}
sendPacket(Packet.CreatePFileUpload(strFileName, i, iPartsCount, readPartOfFile(Packet.PACKET_MAXSIZE_UPLOADPART * (i - 1), numBytesToRead), mGuid));
}
OnUploadCompleted();
}
catch (Exception ex)
{
OnUploadCanceled(ex.ToString());
}
}
private object sync_readPartOfFile = new object();
private byte[] readPartOfFile(int iByteFrom, int numBytesToRead)
{
lock (sync_readPartOfFile)
try
{
using (FileStream fsSource = new FileStream(mstrFilePath, FileMode.Open, FileAccess.Read))
{
fsSource.Seek(iByteFrom, SeekOrigin.Begin);
iByteFrom = 0;
long lEnd = fsSource.Length;
// Read the source file into a byte array.
byte[] bytes = new byte[numBytesToRead];
while (numBytesToRead > 0)
{
// Read may return anything from iByteFrom to numBytesToRead.
int n = fsSource.Read(bytes, iByteFrom, numBytesToRead);
// Break when the end of the file is reached.
if (n == 0)
break;
iByteFrom += n;
numBytesToRead -= n;
}
return bytes;
}
}
catch
{
throw;
}
}
private object sync_sendRequest = new object();
private void sendPacket(Packet request)
{
lock (sync_sendRequest)
try
{
request.pkOwner = mUserName;
byte[] buffer = weHereConverter.SerizableObject(request);
mnetStream.Write(buffer, 0, buffer.Length);
mnetStream.Flush();
//OnAPartUploaded(); /*tempolary disabled*/
}
catch (Exception)
{
throw;
}
}
********服务器**********
ClientManager.cs // 保存客户端列表
public void Listen(TcpClient tcpClient, string strName)
{
Client client = new Client(tcpClient, strName);
client.OnNotifyDisconnect += new Client.NotifyDisconnect(ClientDisconnect);
client.OnNotifyMessage += new Client.NotifyMessage(ClientMessage);
client.OnNotifyReceivedData += new Client.NotifyReceivedData(ClientReceivedData);
lock (sync_mlistClient)
{
Packet pkNotifySignIn = Packet.CreatePServerNotify("*ding* welcome...someone");
foreach (Client c in mlistClient)
{
try
{
c.send(pkNotifySignIn);
}
catch { }
}
mlistClient.Add(client);
}
client.BeginListen();
}
private void ClientReceivedData(Packet pkData, Client client)
{
if (pkData.isSCmd())
{
if (pkData.ScmdType == Command.SCMD_RENAME) // packet rename
{
/*some code*/
}
else if (pkData.ScmdType == Command.SCMD_FILEUPLOAD)
{
//new Thread(() => thread_UploadFile(pkData)).Start();
thread_UploadFile(pkData);
}
else
{
/*some code*/
}
}
else if (pkData.isMessage())
{
new Thread(() => ForwardMessageToClient(pkData, client)).Start();
}
else
{
/*some code*/
}
}
// named thread but I call it like a normal method
private void thread_UploadFile(Packet pkUploadData)
{
//new Thread(() => thread_OnUploadingFile(pkUploadData)).Start();
thread_OnUploadingFile(pkUploadData);
}
private object sync_thread_OnUploadingFile = new object();
private void thread_OnUploadingFile(Packet pkUploadData)
{
lock (sync_thread_OnUploadingFile)
{
FileUploadInfo uploadInfo = getFileUploadInfo(pkUploadData);
if (uploadInfo.Fail) // reject packet, Fail marked as true when exception occured while writing to server's hard disk
return;
try
{
File.WriteAllBytes(getUploadFilePart(pkUploadData.ScmdFileUploadGuid, pkUploadData.ScmdFileUploadPartNumber), pkUploadData.msgFileData);
}
catch (Exception ex)
{
/*server log*/MakeThreadNotifyMessage("Error while uploading part " + pkUploadData.ScmdFileUploadPartNumber + "/" + pkUploadData.ScmdFileUploadPartsCount + " of " + pkUploadData.ScmdFileUploadName + " (Guid " + pkUploadData.ScmdFileUploadGuid + ") from " + pkUploadData.pkOwner + "\r\n" + ex);
uploadInfo.Fail = true;
}
finally
{
uploadInfo.OnAPartUploaded(); // increase count part uploaded in uploadInfo
if (!uploadInfo.Complete)
/*server log*/MakeThreadNotifyMessage("Uploaded " + uploadInfo.CountPartsUploaded + "/" + pkUploadData.ScmdFileUploadPartsCount + " part of " + pkUploadData.ScmdFileUploadName + " (Guid " + pkUploadData.ScmdFileUploadGuid + ") from " + pkUploadData.pkOwner);
}
}
}
private Dictionary<Guid, FileUploadInfo> mdictFileUpload = new Dictionary<Guid, FileUploadInfo>();
private object sync_mdictFileUpload = new object();
private FileUploadInfo getFileUploadInfo(Packet pkUploadData)
{
lock (sync_mdictFileUpload)
{
FileUploadInfo result;
if (!mdictFileUpload.TryGetValue(pkUploadData.ScmdFileUploadGuid, out result))
{
mdictFileUpload.Add(pkUploadData.ScmdFileUploadGuid, result = new FileUploadInfo(
pkUploadData.pkOwner, // uploader's name
pkUploadData.ScmdFileUploadGuid, // file guid because I save on save like G-U-I-D-filename_partposition.part
pkUploadData.ScmdFileUploadName, // file name
pkUploadData.ScmdFileUploadPartsCount // total parts count, ex: 5mb file will be splited into 5 parts
));
result.OnFileUploadCompleted += new FileUploadInfo.NotifyFileUploadCompleted(UploadCompleted);
}
return result;
}
}
文件上传信息.cs
public class FileUploadInfo
{
public delegate void NotifyFileUploadCompleted(FileUploadInfo uploadFile);
public NotifyFileUploadCompleted OnFileUploadCompleted;
public string UploaderName { get; private set; }
public string FileName { get; private set; }
public int PartsCount { get; private set; }
public Guid FileUploadGuid { get; private set; }
private int _CountPartsUploaded = 0;
private object sync_CountPartsUploaded = new object();
public int CountPartsUploaded
{
private set
{
lock (sync_CountPartsUploaded)
_CountPartsUploaded = value;
}
get
{
lock (sync_CountPartsUploaded)
return _CountPartsUploaded;
}
}
private bool _Fail = false;
private object sync_Fail = new object();
public bool Fail
{
get
{
lock (sync_Fail)
return _Fail;
}
set
{
lock (sync_Fail)
_Fail = value;
}
}
private bool _Complete = false;
private object sync_Complete = new object();
public bool Complete
{
get
{
lock (sync_Complete)
return _Complete;
}
set
{
lock (sync_Complete)
_Complete = value;
}
}
public FileUploadInfo(string UploaderName, Guid FileUploadGuid, string FileName, int PartsCount)
{
this.UploaderName = UploaderName;
this.FileUploadGuid = FileUploadGuid;
this.FileName = FileName;
this.PartsCount = PartsCount;
}
public void OnAPartUploaded()
{
CountPartsUploaded += 1;
if (CountPartsUploaded >= PartsCount)
{
OnFileUploadCompleted(this);
Complete = true;
}
}
}
客户端.cs
byte[] message = new byte[2097152];
int bytesRead;
while (true)
{
bytesRead = 0;
#region read client SPacket
try
{
//blocks until a client sends a message
/*server log*/OnNotifyMessage("[" + mstrName + "] Waiting for message");
bytesRead = netStream.Read(message, 0, 2097152);
if (bytesRead == 0)
{
//the client has disconnected from the server
break;
}
}
catch (Exception ex)
{
notifyError("Socket error", ex);
break;
}
#endregion
//message has successfully been received
Packet pkRequestFromClient;
Boolean bValidPacket;
readRPacket(message, out pkRequestFromClient, out bValidPacket);
if (bValidPacket)
{
processRequestPacket(pkRequestFromClient);
}
else
{
/*server log*/OnNotifyMessage("Error packet: "+ pkRequestFromClient.Exception);
}
private void readRPacket(byte[] data, out Packet packet, out bool bValidPacket)
{
try
{
packet = weHereConverter.DeSerializeFromByteArray<Packet>(data);
bValidPacket = true;
}
catch(Exception ex)
{
packet = Packet.CreateErrorPacket(ex);
bValidPacket = false;
}
}
真的需要帮助。。
感谢阅读！