PHP Lang
  1. PHP Lang
  3. Как сохранить Node.js от разделения сообщений сокетов на более мелкие куски
Intereting Posts
Почему я получаю 500 ошибок при использовании file_get_contents (), но работает в браузере? Меню иерархической рекурсии с PHP / MySQL как вернуть json закодированные ошибки формы в symfony Yii: Формирование dataProvider в CGridView Каков наилучший способ обработки сеансов для PHP-сайта на нескольких хостах? Curl errno = 6 после примерно одного дня работы Как HTML-ссылка «href» вызывает один и тот же файл из разных папок? Добавить элементы в отношение Phalcon Many-to-Many В Symfony2, что означает \ DateTime? Формирование даты и фильтров Yii AJAX PHP функция onchange select box Ошибка mysql: не удалось запустить службу mysql на ошибке локального компьютера 193: oxc1 Mod_rewrite .htaccess для веб-перевода Простой HTML DOM str_replace в текстовом виде Список всех объектов определенного класса

Как сохранить Node.js от разделения сообщений сокетов на более мелкие куски

У меня есть чат-программа, которая толкает данные JSON из Apache / PHP в Node.js через сокет TCP: 

// Node.js (Javascript) phpListener = net.createServer(function(stream) { stream.setEncoding("utf8"); stream.on("data", function(txt) { var json = JSON.parse(txt); // do stuff with json } } phpListener.listen("8887", 'localhost'); // Apache (PHP) $sock = stream_socket_client("tcp://localhost:8887"); $written = fwrite($sock, $json_string); fclose($sock);

Проблема в том, что если строка JSON достаточно велика (около 8 тыс.), Выходное сообщение делится на несколько фрагментов, и синтаксический анализатор JSON терпит неудачу. PHP возвращает значение $ write как правильную длину строки, но обработчик события данных срабатывает дважды или более.

Должен ли я прикреплять функцию к другому событию или есть способ кэшировать текст во время пожаров событий, таким образом, чтобы не поддаваться условиям гонки при большой нагрузке? Или какое-то другое решение, о котором я не думал?

Благодаря!