Зависание сцены во время получения сообщения с сервера, что делать?

Question

[Senture]

Здравствуйте! Есть вот такой скрипт в Unity:

Script

internal bool connected = false;
    internal Socket socket;
    internal Dictionary<string, string> data= new Dictionary<string, string>();

    void FixedUpdate()
    {
        if (!connected)
            return;

        try
        {
            int bytes = 0; // Счетчик полученных байт с сервера
            byte[] buffer = new byte[1024]; // Массив байт, для данных полученых с сервера

            StringBuilder builder = new StringBuilder();

            do
            {
                bytes = socket.Receive(buffer); // Прием данных от сервера !!! вот из за этой строчки вся сцена виснет, и я не знаю, как сделать получение сообщений с сервера асинхронным, что бы, сцена не висла.
                builder.Append(Encoding.UTF8.GetString(buffer, 0, bytes)); // Строим сообщение из полученных данных ( массива байт )
            }
            while (socket.Available > 0);

            string[] allInfo = builder.ToString().Split(';');
            for (int i = 0; i < allInfo.Length; i++)
            {
                string[] info = allInfo[i].Split('|');
                data.Add(info[0], info[1] + '|' + info[2] + '|' + info[3]);
            }
        }
        catch (Exception ex)
        {
            Debug.Log("Error in Helper.FixedUpdate: " + ex.Message);
        }
    }

Вот на этой строчке виснет вся сцена.

bytes = socket.Receive(buffer); // Прием данных от сервера !!! вот из за этой строчки вся сцена виснет, и я не знаю, как сделать получение сообщений с сервера асинхронным, что бы, сцена не висла.

Кто знает, что с этим можно сделать, подскажите пожалуйста как решить данную задачу.
P.S. Всем огромное спасибо!!

Answer 1

[Senture]

Решил проблему так:

void Start()
    {
        Thread t = new Thread(ReceiveData);
        t.Start();
    }

    private void ReceiveData()
    {
        while (true)
        {
            if (connected)
            {
                Debug.Log("Run");
                try
                {
                    int bytes = 0; // Счетчик полученных байт с сервера
                    byte[] buffer = new byte[1024]; // Массив байт, для данных полученных с сервера

                    StringBuilder builder = new StringBuilder();

                    do
                    {
                        bytes = socket.Receive(buffer); // Прием данных от сервера
                        builder.Append(Encoding.UTF8.GetString(buffer, 0, bytes)); // Строим сообщение из полученных данных ( массива байт )
                    }
                    while (socket.Available > 0);

                    string[] allInfo = builder.ToString().Split(';');
                    for (int i = 0; i < allInfo.Length; i++)
                    {
                        string[] info = allInfo[i].Split('|');

                        Action action = () => { data.Add(info[0], info[1] + '|' + info[2] + '|' + info[3]); };
                        action.Invoke(); 
                    }
                }
                catch (Exception ex)
                {
                    Debug.Log("Error in Helper.FixedUpdate: " + ex.Message);
                }
            }
        }
    }

Все прекрасно работает =)
Всем огромное спасибо!

Answer 2

[freeExec]

Где вы взяли этот скрипт, там просто букет классических ошибок
1) Какое отношение имеет сетевой стек в физическим тикам, чтобы его запускать в FixedUpdate
2) Зачем каждый update создавать буфер и StringBuilder

Асинхронные методы начинаются с Begin*.

Comments

[Senture]

По поводу запуска сетевого стека в FixedUpdate - хорошо, вызову я через метод Start->метод c while(true) и пускай он крутится, но все равно сцена виснет.
А по поводу буфера и буилдера, то это легко поправимо.

А с BeginReceive не могу разобраться как мне необходимо это реализовать, вот как то так.

[freeExec]

Senture, Изучите Corutine

[Senture]

freeExec, сижу и учу все, только еще сложнее все становится -_-

Answer 3

[p4p]

Сцена зависает так как ждет поступления данных. Такие операции не выполняют в основном потоке.

Comments

[Senture]

Так причину зависания, я понял, но не могу перенести этот код в другой поток. Так как если я буду использовать Thread, то код:

string[] allInfo = builder.ToString().Split(';');
            for (int i = 0; i < allInfo.Length; i++)
            {
                string[] info = allInfo[i].Split('|');
                data.Add(info[0], info[1] + '|' + info[2] + '|' + info[3]); // Вот тут не получиться добавить данные в словарь, так как он создан в другом потоке.
            }

И что тогда делать со следующей проблемой?
P.S. Спасибо)

[freeExec]

Senture, Сохраняйте его в свой словарь и возвращайте его как результат работы таска.

[Senture]

freeExec, а вот так, это работать будет?

void Start()
    {
        Thread t = new Thread(ReceiveData);
        t.Start();
    }

    private void ReceiveData()
    {
        while (true)
        {
            if (connected)
            {
                Debug.Log("Run");
                try
                {
                    int bytes = 0; // Счетчик полученных байт с сервера
                    byte[] buffer = new byte[1024]; // Массив байт, для данных полученных с сервера

                    StringBuilder builder = new StringBuilder();

                    do
                    {
                        bytes = socket.Receive(buffer); // Прием данных от сервера
                        builder.Append(Encoding.UTF8.GetString(buffer, 0, bytes)); // Строим сообщение из полученных данных ( массива байт )
                    }
                    while (socket.Available > 0);

                    string[] allInfo = builder.ToString().Split(';');
                    for (int i = 0; i < allInfo.Length; i++)
                    {
                        string[] info = allInfo[i].Split('|');

                        Action action = () => { data.Add(info[0], info[1] + '|' + info[2] + '|' + info[3]); };
                        Invoke("action", 0f);
                    }
                }
                catch (Exception ex)
                {
                    Debug.Log("Error in Helper.FixedUpdate: " + ex.Message);
                }
            }
        }
    }

[freeExec]

Senture, Не будет. Ищите как сделать колбек в главный тред.

[Senture]

freeExec, а вы подсказать сможете? Хотя бы как класс называется? =) Спасибо)

[Senture]

freeExec, а так:

Action action = () => { data.Add(info[0], info[1] + '|' + info[2] + '|' + info[3]); };
                        action.Invoke();

?

[p4p]

Может jobs попробовать? Я не использовал пока, помочь не могу.

[freeExec]

Senture, Встроенного удобного нет, но полно разных реализаций, выбирайте на свой вкус.
https://github.com/PimDeWitte/UnityMainThreadDispatcher

[Senture]

freeExec, спасибо, сейчас изучу) Как решу свою задачу, обязательно отпишусь!