使用 Tcpclinet c# 发送对象的最简单方法

Question

我是 c# 新手，我想知道，使用 tcpClient 发送对象的最简单方法是什么，尝试了以下代码，但它抛出了一个奇怪的错误 客户端代码：

TcpClient client = new TcpClient(ip, port);
StreamWriter writer = new StreamWriter(client.GetStream());
NetworkStream strm = client.GetStream();
BinaryFormatter formatter = new BinaryFormatter();
Transaction tx = new transaction();

string msg = string.Empty;

msg = "transaction";
writer.WriteLine(msg);
writer.Flush();

formatter.Serialize(strm,tx);

在接收端

服务器代码：

while(true){
TcpClient client = server.AcceptTcpClient();
IFormatter formatter = new BinaryFormatter();
NetworkStream strm = client.GetStream();
StreamReader reader = new StreamReader(client.GetStream());
string msg = string.Empty;
while (!((msg = reader.ReadLine()).Equals("exit"))){

Transaction tx = (Transaction)formatter.Deserialize(strm);

}

它在服务器上产生这个错误

input stream is not a valid ibinary format intital content is :0c-02-00-00 .....

那么有人可以帮我吗，或者是否有另一种使用 tcpclient 发送对象的简单而干净的方法？

Answer 1

这里的根本问题与您混合两种不同机制来读取和写入流的方式有关，特别是：使用StreamReader 和一个单独的基于流的解析器。 也使用StreamWriter 来做这件事是个坏主意，但是……我认为你会侥幸逃脱，尽管这仍然是个坏主意。

这里的问题是StreamReader是贪婪。当您向它询问一行时，它不会从流中逐字节读取以查找 \r 或 \n - 它会从流中获取 缓冲区 数据，并且然后按照您的要求进行处理。通过这种方式，它假定它现在是流的唯一所有者。

所以;当你这样做时：

while (!((msg = reader.ReadLine()).Equals("exit"))){
   Transaction tx = (Transaction)formatter.Deserialize(strm);
}

阅读器消耗超过只是"transaction\r\n" - 它消耗该行以及来自后面的一些未定义的字节数。然后，当BinaryFormatter尝试阅读信息流时，它发现自己读到一半，并在一阵火花中爆炸。

理想情况下，将自己限制为一种序列化机制。含义：在这里完全输掉StreamReader/StreamWriter。

如果我可以提出使用 protobuf-net 和继承的替代机制：

[ProtoContract]
[ProtoInclude(1, typeof(ShutdownMessage))]
[ProtoInclude(2, typeof(TransactionMessage))]
public abstract class MessageBase {} 

[ProtoContract]
public sealed class ShutdownMessage : MessageBase {}

[ProtoContract]
public sealed class TransactionMessage : MessageBase {
    // your data here
}

现在您可以发送任意数量的消息：

public void Send(MessageBase message) {
    Serializer.SerializeWithLengthPrefix(strm, message, PrefixStyle.Base128);
}

并且接收任意数量的消息：

while (true) {
    var msg = Serializer.DeserializeWithLengthPrefix<MessageBase>(strm, PrefixStyle.Base128);
    if (msg is null || msg is ShutdownMessage) break; // all done
    switch (msg)
    {
        case TransactionMessage tx: ProcessTransaction(tx); break;
        // etc
    }
}

Answer 2

不使用BinaryFormatter 的原因有很多。 如果这是我（我对此有偏见），我会改用 protobuf-net 之类的东西，它与 BinaryFormatter 没有同样的问题，但是：它确实需要一些调整你的类型——通常用一些属性来注释它们以帮助库，例如：

public class Transaction {
    public int Id {get;set;}
    public string Name {get;set;}
}

可能变成

[ProtoContract]
public class Transaction {
    [ProtoMember(1)]
    public int Id {get;set;}
    [ProtoMember(2)]
    public string Name {get;set;}
}

在那之后，代码应该是简单的：

Serializer.Serialize(strm, tx); // this is ProtoBuf.Serializer
// and now close the "send" pipe; fine to leave the "receive" pipe, though

和

Serializer.Deserialize<Transaction>(strm); // again, ProtoBuf.Serializer

但是！ 据我所知，问题中显示的代码应该可以工作，除非发生了一些奇怪的事情。

---

注意：如果您发送多个有效载荷（即您需要将其划分为帧），或者您不想担心关闭发送管道，那么：

Serializer.SerializeWithLengthPrefix(strm, tx, PrefixStyle.Base128);

和

Serializer.DeserializeWithLengthPrefix<Transaction>(strm, PrefixStyle.Base128);