如何在grpc雙向rpc中發送消息，而不從grpc節點客戶端緩衝

Question

RouteChat example這是一個雙向rpc，似乎是在write上緩衝消息。有沒有辦法強制寫入輸出流立即沒有緩衝？

Answer 1

您看到此緩衝行爲的原因是因爲寫入實際上是異步完成的，所以服務器代碼需要定期在寫入之間進行其他異步操作，以確保在計算後儘快發送它們。您可以利用write的可選回調參數在發送最後一個消息後立即發送每條消息。該示例中的代碼可以改爲使用async.each：

async.each(notes, function(note, next) { 
    console.log('Sending message "' + note.message + '" at ' + 
     note.location.latitude + ', ' + note.location.longitude); 
    var noteMsg = new messages.RouteNote(); 
    noteMsg.setMessage(note.message); 
    var location = new messages.Point(); 
    location.setLatitude(note.location.latitude); 
    location.setLongitude(note.location.longitude); 
    noteMsg.setLocation(location); 
    // Note the use of the next callback here 
    call.write(noteMsg, next); 
}, function() { 
    // End the stream after all messages have been sent 
    call.end(); 
});