提问者:小点点

BinaryFormatter反序列化流中的多个对象


我用IPEndpoint创建一个TcpClient,并用打开的连接打开一个NetworkStream。

stream = client.GetStream();

Stream定义为NetworkStream,client定义为TCPClient。我想使用流每秒发送序列化对象。为此,我有一个定时器,它通过BinaryFormatter发送每一秒钟的信息。

formatter.Serialize(stream, object);

对象在本例中是序列化类。在另一边,我使用一个TcPListener并使用

stream = listener.AcceptTcpClient().GetStream();

在那之前,一切都按计划进行。第一个对象有我想要的信息,我甚至能够访问这些信息。只要我想从同一个流中获取第二个对象,我就会收到一个NullReferenceException。

streamObject = deserialiser.Deserialize(stream);

我不反序列化到特定的类型,所以我可以筛选对象并启动不同的方法。*注意,我使用两个不同的类发送和接收,两个类运行在不同的程序中。

我的问题是:有没有可能在相同的流中发送多个对象,中间有一个时间间隔,然后在另一端反序列化它,而不是每次都打开和关闭一个流?

*一些附加信息:

计时器作为线程在Windowsservice中运行。第一个对象将按照上面提到的方式发送,但是第二个对象不会。

这里询问的是我收到的堆栈跟踪。

System.NullReferenceException was not handled by user code.
  HResult=-2147467261
  Message=The Object reference not set to an object instance ..
  Source=App_Web_qtieteli
  StackTrace:
       at _Default.Page_Load(Object sender, EventArgs e) in c:\Users\Documents\Visual Studio 2012\WebSites\System_GUI\Default.aspx.cs:Row 14.
       at System.Web.Util.CalliEventHandlerDelegateProxy.Callback(Object sender, EventArgs e)
       at System.Web.UI.Control.OnLoad(EventArgs e)
       at System.Web.UI.Control.LoadRecursive()
       at System.Web.UI.Page.ProcessRequestMain(Boolean includeStagesBeforeAsyncPoint, Boolean includeStagesAfterAsyncPoint)
  InnerException: 

下面是我的Page_Load方法。

protected void Page_Load(object sender,EventArgs e){recient=new serverrecient();recive.recivestreamobject();firstdate.text=recive.ui.servername;}

一旦我定义recient,连接就会打开。这里是整个类ServerRecient的代码。

  public class ServerRecive
 {
public ObjectTypeUI ui {get; set;}
public ObjectTypeSI si { get; set; }
public ObjectTypeDI di { get; set; }

TcpListener listener;
NetworkStream stream;

BinaryFormatter deserialiser;

public ServerRecive ()
{
 deserialiser = new BinaryFormatter();
 Initialize();
}

private void Initialize ()
{
listener = new TcpListener (IPAddress.Any, *port*);
listener.Start();
stream = listener.AcceptTcpClient().GetStream();
}


public void ReciveStreamObject()
{
object Object = new object();
try
 {
  Object = deserialiser.Deserialize(stream);
 }
 catch (Exception e) {}

 if (Object.GetType() == typeof(ObjectTypeSI))
 {
  si = (ObjectTypeSI)Object;
 }
 else if (Object.GetType() == typeof(ObjectTypeUI))
 {
  ui = (ObjectTypeUI)Object;
 }
 else if(Object.GetType() == typeof(ObjectTypeDI))
 {
  di = (ObjectTypeDI)Object;
 }
}
}

我没有任何具体的大小对象,因为他们包含不同的信息。

@Nelus我做了一些变通方法来获得异常。现在我收到了这个例外

System.Runtime.Serialization.SerializationException was not handled.
HResult=-2146233076
Message=The input stream is not a valid binary format. The start content     
(in     Bytes) is: 1B-65-72-69-61-6C-4F-62-6A-65-63-74-2E-53-65-72-76 ...
Source=mscorlib
StackTrace:
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 System_GUI.ServerRecive.ReciveStreamObject() in c:\Users\rbr\Documents\Visual Studio 2012\WebSites\System_GUI\App_Code\Netzwerk\ServerRecive.cs:Zeile 51.
   at System.Threading.ThreadHelper.ThreadStart_Context(Object state)
   at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)
   at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)
   at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)
   at System.Threading.ThreadHelper.ThreadStart()
InnerException: 

共1个答案

匿名用户

因此,我建立了第二个项目,以测试我的服务器是否甚至recious数据,并使用localhost上的包嗅探器来确认它。我现在用来recient的类没有做其他任何事情。只是它有一个while循环,一次又一次地反序列化流。这解决了我的问题。BinaryFormatter似乎是在不知道对象的实际大小或位置的情况下查找流中的对象并反序列化每个对象。

    class Program
{
    TcpListener listener = new TcpListener(IPAddress.Any, 4456);
    NetworkStream stream;

    ObjectTypeUI ui;
    ObjectTypeDI di;
    ObjectTypeSI si;

    BinaryFormatter deserializer = new BinaryFormatter();

    public Program()
    {

     listener.Start();
     stream = listener.AcceptTcpClient().GetStream();
     while (true)
     {
         object streamObject = deserializer.Deserialize(stream);

         if (streamObject.GetType() == typeof(ObjectTypeSI))
         {
          si = (ObjectTypeSI)streamObject;
          Console.WriteLine(si.Kunde);
         }
         else if (streamObject.GetType() == typeof(ObjectTypeUI))
         {
          ui = (ObjectTypeUI)streamObject;
          Console.WriteLine(ui.CpuUsage);
         }
         else if(streamObject.GetType() == typeof(ObjectTypeDI))
         {
          di = (ObjectTypeDI)streamObject;
         }
     }


    }

    static void Main(string[] args)
    {
     new Program();
     Console.ReadLine();
    }
}

真正的问题不在于我如何约束对象,也不在于我如何反序列化它们。问题是Windowsservice实际上中止了我用来发送对象的线程。

非常感谢@Neleus和@Grumbler85,他们帮我找到了真正的问题。