[nio] Transfert non bloquants d'objets par SocketChannel

Bonsoir tout le monde,

je suis à la recherche d'un bout de code qui montre comment transférer des objets en utilisant les NIO (E/S hautes perfs.)

J'arrive à envoyer des tableaux de bytes et même des strings, en faisant comme ça :

Code:

---

1 2	((SocketChannel)maSelectionKey.channel()).write(ByteBuffer.wrap("toto".getBytes()));

---

mais je n'ai rien trouvé pour des objets quelconques. quand je fais

Code:

---

1 2	new ObjectOutputStream(aSocketChannel.socket().getOutputStream()).writeObject("Test")

---

je me prend une "java.nio.channels.IllegalBlockingModeException", ce qui est normal dès lors que le SocketChannel est en mode non-bloquant...

Quelqu'un aurait un ptit exemple sous la main ? Ou bien est-ce seulement possible ?


Merci ;)

alors j'ai trouvé la parade: je construis un ByteArrayOutputStream pour stocker les données de l'objet sérialisé, puis je le transfert en un bloc

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13

... ServerSocketChannel server = (ServerSocketChannel) selectionKey.channel();   SocketChannel client = server.accept(); client.configureBlocking(false); client.register(selector, SelectionKey.OP_READ | SelectionKey.OP_WRITE);   ByteArrayOutputStream baos = new ByteArrayOutputStream(); ObjectOutputStream oos = new ObjectOutputStream(baos); oos.writeObject(toSend);   client.write(ByteBuffer.wrap(baos.toByteArray()));

---

et de l'autre côté je désérialise de la manière suivante:

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12

... SocketChannel sc = SocketChannel.open(new InetSocketAddress(InetAddress.getLocalHost(), 80)); ByteBuffer bb = ByteBuffer.allocate(1024); sc.read(bb); System.out.println("building object...");   ByteArrayInputStream bais = new ByteArrayInputStream(bb.array()); ObjectInputStream iis = new ObjectInputStream(bais); Object o = iis.readObject(); System.out.println("object build ! toString: "+o.toString());

---

Ce code fonctionne pas trop mal, mais le problème maintenant vient du fait que je ne sais pas exactement combien de bytes sont occupé par mon objet, ce qui fait que s'il est plus grand qu'un Ko, il ne pourra pas tenir dans mon ByteBuffer et je ne pourrai pas le reconstruire. ou pire, s'il y a deux objets qui sont envoyés successivement, je risque de ne pas pouvoir les distinguer.....


Une idée ?

:wink: