socketchannel.write() становится очень медленным, когда размер сообщения большой.

Question

В моей программе, использующей java nio, socketchannel.write() становится очень медленным, когда он пытается последовательно писать сообщения 10 КБ. Измеренное время для записи полного сообщения 10 КБ составляет от 160 мс до 200 мс. Но время для написания полного сообщения размером 5 КБ составляет всего 0,8 мс.

В селекторе у меня есть только Selection.OP_READ и не обрабатывать Selection.OP_WRITE. Когда получено большое полное сообщение, оно записывается в другой приемник 4 раза.

Есть ли у кого-то такая же проблема? Есть сообщение о socketchannel.write() медленно. Мой вопрос заключается в том, как чередовать изменения между OP_READ и OP_WRITE?

Если я добавляю inerval, например 150 мс, время отклика уменьшается. Есть ли способ найти, когда буфер заполнен, поэтому я могу позволить программе ждать. Моя операционная система - Windows XP.

Спасибо.

Я следую примеру EPJ, проверяя количество записанных байтов. Но время ответа все еще велико. Я размещаю часть своего кода здесь и хочу проверить, неясно ли с моим кодом.

// это WriteData() часть с использованием NiO:

 while (buffer.hasRemaining()) { 
     try {   
       buffer.flip();     
       n = socket.write(buffer);   
       if(n == 0) {     
        key.interestOps(SelectionKey.OP_WRITE); 
        key.attach(buffer);    
        break; 
       }        
     } catch (IOException e) {    
      e.printStackTrace(); 
     } finally { 
      buffer.compact(); 
     } 
    } 

    if(buffer.position()==0) {     
     key.interestOps(SelectionKey.OP_READ); 
    } 

Answer 1

Если запись занимает более 20 микро секунд, я хотел бы предложить вам иметь буферную полный вопрос. Я предполагаю, что вы используете блокировку NIO. Когда буфер отправки не заполнен, обычно требуется от 5 до 20 микросекунд. В прошлом я настроил свой сервер, чтобы убить любого медленного потребителя, который занимает 2 мс для записи. (Возможно, немного агрессивный.;)

Вы можете попробовать увеличить размер буфера отправки (Socket.setSendBufferSize (int), который также доступен для SocketChannels), но, похоже, вы пытаетесь отправить больше данных, чем ваша пропускная способность позволяет.

10 КБ не является большим сообщением, типичный размер буфера отправки составляет 64 КБ, поэтому для его заполнения вам нужно будет иметь 6-7 сообщений, не имеющих значения. Это может объяснить способ 5KB относительно быстро.

Answer 2

Я предлагаю, чтобы ваш процесс чтения был медленным, и это вызывает резервное копирование буфера приема, что вызывает резервное копирование вашего буфера отправки, что задерживает ваши отправления.

Или иначе вы неправильно написали код для неблокирующего режима. Если вы получаете нулевой результат из метода write(), вы должны (a) изменить interestOps на OP_WRITE и (b) вернуться к вашему циклу выбора. Когда вы получите OP_WRITE, вы должны повторить запись; если вы написали все данные, измените interestOps обратно на OP_READ, иначе оставьте все как есть и дождитесь следующего OP_WRITE. Если вы пытаетесь выполнить цикл во время записи в неблокирующем режиме даже при наличии записей с нулевой длиной, вы просто начнете вращаться, теряя процессорные циклы и время.

Modulo ошибки:

while (buffer.position() > 0) 
{ 
    try 
    { 
    buffer.flip(); 
    int count = ch.write(buffer); 
    if (count == 0) 
    { 
     key.interestOps(SelectionKey.OP_WRITE); 
     break; 
    } 
    } 
    finally 
    { 
    buffer.compact(); 
    } 
} 
if (buffer.position() == 0) 
{ 
    key.interestOps(SelectionKey.OP_READ); 
}