在unity应用程序中,我每秒通过tcp接收大约160个json对象。我下面的阅读代码似乎很难达到这样的速度,而且有几次它们并不是单个消息。当我试图创建一个
不正确的json
格式:right,“data”:{“type”:“flex”,“gesture”:“open”,“data”:[0.11425240454677936,0.11582253631723596,0.0947054436987323,0]}{“type”:“right”,“data”:{“type”:“sensor”,“data”:[0.98638916015625,-0.0802001953125,0.0888061234375,-0.11248779296875,null]}{“type”:“right”,“data”:{“type”:“flex”,“gesture“:”open“,”data“:[0.11192072282133489,0.11739301138594425,0.09271687795177729,0]type“:”right“,”data“:”type“:”sensor“,”data“:[0.98638916015625,-0.0802001953125,0.08880615234375,-0.11248779296875,空]type“:”right“,
这是我的数据处理功能:

bool ProcessData()
{
    string temp = System.Text.Encoding.Default.GetString(readBuffer);
    //Debug.Log(string.Format("Client recv: '{0}'", temp));

    JSONObject obj = new JSONObject(temp);
}

这是我的TCP代码:
void connectToHub () {
    readBuffer = new byte[512];
    EndPoint endpoint;
    if (this.useUnixSocket == true) {
        endpoint = new UnixEndPoint(SOCKET_LOCATION);
    } else {
        endpoint = new IPEndPoint(this.ipAdress, this.port);
    }

    client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

    try {
        IAsyncResult result = client.BeginConnect(endpoint,
                                    new AsyncCallback(this.EndConnect),
                                    null);
        bool connectSuccess = result.AsyncWaitHandle.WaitOne(System.TimeSpan.FromSeconds(10));

        if (!connectSuccess){
            client.Close();
            Debug.LogError(string.Format("Client unable to connect. Failed"));
        }

    }
    catch(SystemException e) {
        Debug.LogError(string.Format("Client exception on beginconnect: {0}", e.Message));
    }

}

void EndConnect(IAsyncResult iar)
{
    client.EndConnect(iar);
    client.NoDelay = true;
    ReceiveData();
}


void ReceiveData()
{
    client.BeginReceive(readBuffer, 0, readBuffer.Length, SocketFlags.None, EndReceiveData, client);
}

void EndReceiveData(System.IAsyncResult iar)
{
    int numBytesReceived = client.EndReceive(iar);
    if (numBytesReceived > 0){
        this.ProcessData();

    }
    // Continue receiving data
    ReceiveData();
}

最佳答案

在我看来,有时你在数据到达之前就开始处理它。当您通过TCP接收到一些数据时,您正在调用EndReceiveData。如果所有的数据都装进了刚刚到达的包中,你就没问题了。但是,如果数据大于数据包,那么在开始解析之前,您应该读取该json对象的所有数据包。

关于c# - TCP客户端有时会合并数据包,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/34779135/

10-12 12:43
查看更多