我有几种不同的方法可以连接到远程主机,发送消息,获取回复并使用信息。在我在连接类的同一实例中使用两个方法之前,此方法一直很好。在出现错误的示例中,我运行以下方法;
public string sendRequestAccountID(string siteID)
{
//build message
String response = String.Empty;
TcpClient client = new TcpClient();
client.Connect(detailsHere);
NetworkStream stream = client.GetStream();
StreamWriter writer = new StreamWriter(stream);
writer.AutoFlush = false;
writer.WriteLine(sb.ToString());
writer.Flush();
StreamReader reader = new StreamReader(stream);
List<XmlNode> nodeList = new List<XmlNode>();
byte[] responseBytes = new byte[4096];
int bytesRead = 0;
while (true)
{
bytesRead = stream.Read(responseBytes, 0, responseBytes.Length);
if (bytesRead > 0)
{
//handle message
}
if (bytesRead == 0)
{
stream.Flush();
stream.Close();
client.Close();
string finalResponse = stuffHereToSend;
return finalResponse;
}
}
}
这可以正常发送,并按预期返回一条消息。但是,如果我随后使用连接类的相同实例并使用以下方法;
public bool sendNewDevice(IDeviceInterface device)
{
NetworkStream stream;
sb = new StringBuilder();
//build message
String response = String.Empty;
TcpClient client = new TcpClient();
client.Connect(detailsHere);
stream = client.GetStream();
StreamWriter writer = new StreamWriter(stream);
writer.AutoFlush = false;
writer.WriteLine(sb.ToString());
writer.Flush();
StreamReader reader = new StreamReader(stream);
List<XmlNode> nodeList = new List<XmlNode>();
byte[] responseBytes = new byte[4096];
int bytesRead = 0;
while (true)
{
bytesRead = stream.Read(responseBytes, 0, responseBytes.Length);
if (bytesRead > 0)
{
//handle message
}
}
}
我收到一个错误,上面写着“无法访问已处置的对象”;
bytesRead = stream.Read(responseBytes, 0, responseBytes.Length);
尽管我以为我刚刚以最新方法分配了流。是否尝试使用先前关闭的工具?有没有办法解决这个问题或我想念的一些愚蠢的东西?
编辑:这与客户端处理不正确有关吗?这两种方法彼此之间的间隔是一秒钟,也许第二种是在第一种关闭之前试图打开的?
参考方案
关闭StreamWriter
(和阅读器)或调用其Dispose
方法时,它将处置基础流。在.net 4.5之前,除了使用StreamWriter
以外的其他方法或编写类来包装赋予Stream
的StreamWriter
并忽略对Dispose
的调用之外,您实际上无能为力。在.NET 4.5中,您可以使用重载来告诉StreamWriter
不要处理您提供的流。例如:new StreamWriter(stream, StreamWriter.UTF8NoBOM, 1024, false)
您可以尝试使用包装的流忽略关闭(调用new StreamWriter(new NonDisposableStreamWrapper(stream))
):
public class NonDisposableStreamWrapper : Stream
{
private Stream wrappedStream;
public NonDisposableStreamWrapper(Stream wrappedStream)
{
this.wrappedStream = wrappedStream;
}
public override void Flush()
{
wrappedStream.Flush();
}
public override long Seek(long offset, SeekOrigin origin)
{
return wrappedStream.Seek(offset, origin);
}
public override void SetLength(long value)
{
wrappedStream.SetLength(value);
}
public override int Read(byte[] buffer, int offset, int count)
{
return wrappedStream.Read(buffer, offset, count);
}
public override void Write(byte[] buffer, int offset, int count)
{
wrappedStream.Write(buffer, offset, count);
}
public override bool CanRead
{
get { return wrappedStream.CanRead; }
}
public override bool CanSeek
{
get { return wrappedStream.CanSeek; }
}
public override bool CanWrite
{
get { return wrappedStream.CanWrite; }
}
public override long Length
{
get { return wrappedStream.Length; }
}
public override long Position
{
get { return wrappedStream.Position; }
set { wrappedStream.Position = value; }
}
}
检查Optional中是否存在null属性,并返回String Java Stream API - java我有以下class Person private String firstName; private String familyName; // Setters and Getters 我有以下方法public String getFullName(Optional<Person> persons) { return persons .map(p…
如何在ASP.NET Core Web应用程序中增加JSON反序列化MaxDepth限制 - c#我们正在将ASP.NET Core 2.1与.NET Framework 4.6.2结合使用。我们有一个客户需要向我们的Web应用程序发送一个很大程度上嵌套的json结构。当他们进行此调用时,我们将输出以下日志并返回错误: 读取器的MaxDepth超过了32。路径“ super.long.path.to property”,第1行,位置42111。”我浏览了…
ASP.NET MVC 5自定义登录,无需脚手架,数据库优先 - c#我对asp.net和mvc还是很陌生,所以我正在努力学习尽可能多的知识...为此,我从头开始编写博客网站,但是我对身份验证和授权有些困惑。由于我倾向于不真正使用任何脚手架的东西,所以我首先要使用数据库,所以不希望asp.net身份为我创建表。我对散列和加盐密码很酷,并对照数据库检查用户,我遇到的麻烦是将用户设置为登录状态并检查他们应该能够访问什么。我真的很想…
asp.net oledbcommand返回所有行 - c#我正在使用Oledbconnection连接到Microsoft Access数据库,并且正在使用OleDbCommand检索一些信息。我在数据库中有一个名为retrieveInfo的查询,该查询检索3行数据。字段中有一些重复项,但是应该是这样。我的数据如下所示: Name Email A [email protected] B [email protected] B C@gmai…
java.net.URI.create异常 - javajava.net.URI.create("http://adserver.adtech.de/adlink|3.0") 抛出java.net.URISyntaxException: Illegal character in path at index 32: http://adserver.adtech.de/adlink|3.0 虽然n…