Comment fermer correctement un canal de socket non bloquant?

Question

J'écris un programme serveur en utilisant Java SocketChannel non bloquant. Parfois, je veux envoyer un message de réponse, puis fermez le canal, comme le code suivant.

Cependant, la méthode close() interrompt la méthode write(), j'obtiens une exception java.nio.channels.ClosedChannelException et le message n'est pas envoyé.

Je peux faire apparaître un thread et attendre 1 à 2 secondes avant de fermer le canal, mais je pense qu'il est inutile de faire un autre thread.

Quelle est la bonne façon de fermer un SocketChannel alors qu'il y a des opérations en attente?

String msg = "Wrong password!"; 
channel.write(ByteBuffer.wrap(msg.getBytes())); 
channel.close(); 

Answer 1

canal. socket(). setSoLinger (true, MAX_SECONDS_FOR_OUTPUT_TO_DRAIN);

Voir info sur le linger option. Comme mentionné, il provoquera le blocage de close() jusqu'à MAX_SECONDS_FOR_OUTPUT_TO_DRAIN secondes.