- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
下面是我现在如何从我的流中读取数据:
public List<ServerClient> clients = new List<ServerClient>();
while (true)
{
Update();
}
private void Update()
{
//Console.WriteLine("Call");
if (!serverStarted)
{
return;
}
foreach (ServerClient c in clients.ToList())
{
// Is the client still connected?
if (!IsConnected(c.tcp))
{
c.tcp.Close();
disconnectList.Add(c);
Console.WriteLine(c.connectionId + " has disconnected.");
CharacterLogout(c.connectionId);
continue;
//Console.WriteLine("Check for connection?\n");
}
else
{
// Check for message from Client.
NetworkStream s = c.tcp.GetStream();
if (s.DataAvailable)
{
string data = c.streamReader.ReadLine();
if (data != null)
{
OnIncomingData(c, data);
}
}
//continue;
}
}
for (int i = 0; i < disconnectList.Count - 1; i++)
{
clients.Remove(disconnectList[i]);
disconnectList.RemoveAt(i);
}
}
当读取数据时,它被发送到处理数据的 OnIncomingData
函数。我在那里没有问题。
下面是我如何将数据发送到流:
public void Send(字符串头,字典数据){
if (stream.CanRead)
{
socketReady = true;
}
if (!socketReady)
{
return;
}
JsonData SendData = new JsonData();
SendData.header = "1x" + header;
foreach (var item in data)
{
SendData.data.Add(item.Key.ToString(), item.Value.ToString());
}
SendData.connectionId = connectionId;
string json = JsonConvert.SerializeObject(SendData);
var howManyBytes = json.Length * sizeof(Char);
writer.WriteLine(json);
writer.Flush();
Debug.Log("Client World:" + json);
这是我的:
public class ServerClient
{
public TcpClient tcp;
public int accountId;
public StreamReader streamReader;
public int connectionId;
public ServerClient(TcpClient clientSocket)
{
tcp = clientSocket;
}
}
这是我的 OnConnection
函数:
private void OnConnection(IAsyncResult ar)
{
connectionIncrementor++;
TcpListener listener = (TcpListener)ar.AsyncState;
NetworkStream s = clients[clients.Count - 1].tcp.GetStream();
clients.Add(new ServerClient(listener.EndAcceptTcpClient(ar)));
clients[clients.Count - 1].connectionId = connectionIncrementor;
clients[clients.Count - 1].streamReader = new StreamReader(s, true);
StartListening();
//Send a message to everyone, say someone has connected!
Dictionary<string, string> SendDataBroadcast = new Dictionary<string, string>();
SendDataBroadcast.Add("connectionId", clients[clients.Count - 1].connectionId.ToString());
Broadcast("001", SendDataBroadcast, clients, clients[clients.Count - 1].connectionId);
Console.WriteLine(clients[clients.Count - 1].connectionId + " has connected.");
}
通常一切正常。但是,如果我尝试每 1 秒发送更多请求,就会出现问题。收到的消息不完整。它只接收发送的消息的一部分。
从 Debug.Log("Client World:"+ json);
我可以看到消息是完整且完整的,但在服务器上我看到它不是。
如果我发送较少的请求,就不会发生这种情况。
因此,出于这个原因,我认为我应该创建一个 MemoryStream
并将一条消息放在那里,然后再阅读它。但是我真的不确定我该怎么做。你能帮忙吗?
最佳答案
整个代码不是很好,但我会专注于您的具体问题。这很可能与 StreamReader
的数据缓冲有关。 StreamReader
的缓冲区大小(您可以将其传递给构造函数)默认为 1024 字节。当您调用 ReadLine
时 - 流读取器完全有可能从底层流中读取多行。在你的情况下 - 你有 while 循环,在其中枚举连接的客户端,并且在循环的每次迭代中你创建新的 StreamReader
并从中读取一行。当消息率低时 - 一切看起来都很好,因为在你的循环迭代之间只有一行到达。现在假设客户端快速发送了 2 条 json 消息,每条 800 字节,并且它们都到达了您的套接字。现在调用 StreamReader.ReadLine
。因为缓冲区大小是 1024 - 它将从套接字 (NetworkStream
) 读取 1024 字节并返回前 800 字节给你(作为一行)。您处理该行并丢弃 StreamReader
以进入 while 循环的下一次迭代。通过这样做,您还丢弃了部分消息(下一条消息的 224 字节),因为它们已经从套接字读取到 StreamReader 缓冲区中。我认为应该清楚如何解决这个问题 - 不要每次都创建新的 StreamReader
而是为每个客户端创建一个(例如存储为 ServerClient
的成员) 并使用它。
关于c# - 如果发送了很多消息,如何写入 MemoryStream,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47386798/
我有一个返回 MemoryStream? 的函数。如果发生错误,则为 null。然后发现不能声明变量MemoryStream? public MemoryStream? GetResponseStre
我正在将一个结构序列化到 MemoryStream 中,我想保存和加载序列化的结构。 那么,如何将 MemoryStream 保存到文件中并从文件中加载它呢? 最佳答案 您可以使用MemoryStre
我应该调用哪个? 有必要两者都调用吗? 如果我已经调用了其中一个,另一个会抛出异常吗? 最佳答案 Close() 和 Dispose() 在 MemoryStream 上调用时,仅用于做两件事: 将对
今天我注意到 MemoryStream 有点奇怪类(class)。 .Length属性是一个 long,但是 .Capacity属性,大概应该总是 >= .Length 只是一个 int。 我知道需要
我有这样的方法: public DataObject GetClipboardData() { var result = new DataObject(); result.SetTex
好的,我看过一些文章here和 here ,但他们没有做我需要做的事情,我遇到了一些麻烦。 我正在接收一段作为内存流的加密数据。我需要以某种方式将内存流写入文件(我编写模型的方式,最好是字符串),然后
我确实看到了“PDF to Image using GhostScript. No image file has to be created”,但这只是(某种程度上)回答了我一半的问题。是否可以使用
这个问题在这里已经有了答案: Stream.Seek(0, SeekOrigin.Begin) or Position = 0 (3 个答案) 关闭 9 年前。 使用的优点或缺点是什么(或区别) m
我在一些开源代码中发现了以下结构: var mstream = new MemoryStream(); // ... write some data to mstream mstream.Close(
由于 MemoryStream 是非托管资源,它是否总是需要被处理? 鉴于: 1) A method is invoked. 2) A MemoryStream object is created (
我正在尝试使用 dotMemory 进行一个简单的测试。我希望以下测试能够通过: [Test] public void MemoryStream_is_disposed() { using (
多次使用 MemoryStream 时遇到问题。 例子: For Each XImage As XImage In pdfDocument.Pages(pageCount).Resources.Ima
在使用 MemoryStream 时,我发现自己经常将数据复制(因此复制)到临时字节数组。 我认为这有点浪费资源,因为 MemoryStream 不允许您直接访问底层字节数组。 在这种情况下,Memo
如何在 Delphi 中将“Hello World”字符串、clrf 和一些随机 10 个字节写入内存流? 最佳答案 我会考虑使用二进制编写器来完成此任务。这是一个更高级别的类,负责处理将数据获取到流
我正在使用 MemoryStream 构造一个需要发送到服务器的字节数组。我有三个问题: 1) 有没有比这更好的方法来构造字节数组? 2)为什么这段代码会在我的内存流中写入虚假内容? var se
这可能是一个非常简单的问题,我认为我所追求的只是声明新 MemoryStream 的最佳实践 以下2个样本有什么区别: MemoryStream myStream = new MemoryStream
我正在尝试压缩 XML 树并将其用作电子邮件附件。带附件的电子邮件发送成功,但创建的 zip 文件始终损坏 - 它不是有效的 zip 文件,但包含二进制数据。 问题重现如下,具体参见BuildAtta
使用sharpPDF库,我生成了一个pdf内存流,并且我想直接通过电子邮件发送它。但是 ms.Seek(.... 行给出了一个 ObjectDisposeException; Cannot acces
我有一台 2 GB 的机器。在运行我的 exe 之前,我有 1.1 GB 的可用内存。当我运行下面只有一行的 exe 时,出现内存不足异常。 我预计以下行将使用大约 6 亿字节。 MemoryStre
当您从字节数组构造 MemoryStream 时,该流是否会创建自己的副本?如果,与直接从原始数组中读取字节相比,这是否是高性能场景中的性能问题? 最佳答案 它似乎没有在文档中明确提及,但请记住,您可
我是一名优秀的程序员,十分优秀!