BytesEntry entry = bytesEntryQueue.poll(5,TimeUnit.SECONDS); //等待五秒,如果没有元素也返回
if(entry!=null) {
writer.writeBytes(entry.getBytes(), entry.getOffset(), entry.getLength()); //
while(bytesEntryQueue.size()>0) {
entry = bytesEntryQueue.poll();
writer.writeBytes(entry.getBytes(), entry.getOffset(), entry.getLength());
}
}
writer.write("SIPP".getBytes());
//尝试发送这个请求,如果超过指定次数,传递传输异常