Discussion :

[xsirvent]

Bonjour,

Je suis confronté à un petit problème avec l'utilisation des Selector sur des sockets.

J'ai un programme qui doit ouvrir des connections sockets vers des serveurs et se mettre en attente de messages sur ces sockets. (ce sont les specs, je ne peux pas changer ce comportement)
Pour faire cela, je crée des SocketChannel comme suit:

SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress(server, port));

Ensuite, je crée un Selector et j'enregistre mes socketChannel avec ce selector pour des événements de type READ.

Selector selector = Selector.open();
socketChannel.configureBlocking(false);
SelectionKey key = socketChannel.register(selector, SelectionKey.OP_READ);

Je suis alors prêt pour attendre des événements sur mes sockets avec:

int n = selector.select();

Cet appel est censé être bloquant or, il sort tout de suite avec n == 0 alors que les serveurs distants n'envoient aucun message.

Dans la littérature, je ne trouve des exemples que pour des ServerSocketChannel et des SocketChannel issus d'un serverSocketChannel.accept(), bref, pour un serveur pur.

Avez vous une idée de la manière de procéder dans mon exemple ?

Merci d'avance.

[adiGuba]

Salut,

Cet appel est censé être bloquant or, il sort tout de suite avec n == 0 alors que les serveurs distants n'envoient aucun message.

Ce ne serait pas lié au fait que tu passes la socket en mode non-bloquant : socketChannel.configureBlocking(false); ?


a++

[xsirvent]

Salut,


Ce ne serait pas lié au fait que tu passes la socket en mode non-bloquant : socketChannel.configureBlocking(false); ?


a++

Ben, si je mets configureBlocking(true), ca pête dans le socketChannel.register(selector, ...)

[adiGuba]

Ben, si je mets configureBlocking(true), ca pête dans le socketChannel.register(selector, ...)

C'est à dire ?

[xsirvent]

Exception in thread "main" java.nio.channels.IllegalBlockingModeException
at java.nio.channels.spi.AbstractSelectableChannel.register(AbstractSelectableChannel.java:198)
at java.nio.channels.SelectableChannel.register(SelectableChannel.java:277)
at SocketSelectorMain.main(SocketSelectorMain.java:28)

On ne peut faire de register d'un selector sur un SocketChannel configuré en mode bloquant.

http://tutorials.jenkov.com/java-nio/selectors.html

[adiGuba]

J'ai recopié ton code tel quel et je ne rencontre pas ce problème.

Tu aurais un exemple de code complet qui reproduit le problème ?
C'est quoi comme serveur en face ?


a++

[xsirvent]

J'ai recopié ton code tel quel et je ne rencontre pas ce problème.

Tu aurais un exemple de code complet qui reproduit le problème ?
C'est quoi comme serveur en face ?


a++

Bon, de mon coté aussi, je suis reparti sur 2 petits programmes de test (1 client et 1 serveur) et je ne rencontre pas le problème. J'ai du me tromper quelque part mais je n'ai plus le code d'origine et j'avais ouvert la question ici sur mon PC perso à la maison en me remémorant le code qui se trouvait sur le PC du boulot.

Merci beaucoup d'avoir passé du temps sur mon petit problème.

Bye
Xavier