c# - 将二进制格式化程序与异步套接字一起使用
问题描述
我正在尝试通过使用 BinaryFormatter 进行序列化/反序列化来利用 C# 中异步套接字的优势,但遇到了一些问题。主要是,我不断收到错误:
No map for object 1953724755
尝试反序列化网络流时。
我尝试更改为同步套接字,这似乎工作正常,但是当使用异步套接字(使用 BeginRecieve 和 EndRecieve 等)时,我仍然收到此错误。
这是我要反序列化的代码:
private void BeginDictionaryRecieve(IAsyncResult ar)
{
Stream socketStream = new NetworkStream(socketState.workSocket);
IFormatter dataFormatter = new BinaryFormatter();
socketState.workSocket.EndReceive(ar);
List<string> rackthatWasClicked = (List<string>)
dataFormatter.Deserialize(socketStream);
this.recievedListForRackDisplay = rackthatWasClicked;
OnDataRecieved.Invoke();
socketState.workSocket.BeginReceive(socketState.buffer, 0, StateObject.BufferSize, 0,new AsyncCallback(BeginDictionaryRecieve), socketState);
}
这是序列化代码(同步):
IPAddress ipAdd = IPAddress.Parse("127.0.0.1");
TcpClient myClient = new TcpClient();
myClient.Connect(ipAdd, 8002);
Stream clientStream = myClient.GetStream();
IFormatter f = new BinaryFormatter();
f.Serialize(clientStream, ShelfDataToSend);
clientStream.Dispose();
myClient.Dispose();
我应该注意我正在使用 BinaryFormatter,因为我似乎找不到一种方法来序列化一个对象,而不是在一个套接字上使用普通的 .Write 操作来序列化一个对象。
解决方案
感谢 Hans 的指导,我能够找到一个很好的解决方案。我现在收到这样的数据:
try
{
StateObject state = (StateObject) ar.AsyncState;
Socket client = state.workSocket;
int bytesRead = client.EndReceive(ar);
if (bytesRead > 0)
{
stream.Write(state.buffer, 0, bytesRead);
client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(BeginDictionaryRecieve), state);
}
else
{
if (stream.Length > 1)
{
BinaryFormatter formatter = new BinaryFormatter();
stream.Position = 0;
this.recievedListForRackDisplay =(List<string>)formatter.Deserialize(stream);
OnDataRecieved.Invoke();
client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
new AsyncCallback(BeginDictionaryRecieve), state);
}
}
}
catch (Exception e)
{
throw e;
}
还应注意,此解决方案仅在客户端 Socket 在发送其数据后被处理时才有效。
推荐阅读
- mysql - 如何形成正确的 SQL 语句?
- javascript - 如何从useState中的不同字符串合并到一个对象中?
- ruby-on-rails - 将补丁与 rspec 测试一起使用
- python - Pytorch 中的向量张量元素乘法
- python - 谷歌云函数在 Python 中设置实时数据库触发器
- java - 如何将 Dictionary 项目序列化为类的平面属性?
- json - 无法从 openweathermap api 获取值
- nikola - Nikola 的 markdown 目录
- amazon-web-services - 使用 CloudFormation 模板更新 AWS Athena 工作组
- javascript - 如何从 https://covid19.mathdro.id/api 获取数据 api?我试图在我的 app.js 中显示这些数据