Socket non bloccante

[Sethi]

Ciao! Una parte della mia app contiene un socket tcp/ip. questo socket deve connettersi in remoto ad un serve e scambiare dei dati. L'invio dei dati funziona, ma la ricezione mi da problemi. Il socket è contenuto in un thread ed ho bisogno che la ricezione non sia di tipo "bloccante". Ho provato con questo cercando un po' in rete:

<br /> ByteBuffer incomingLengthInBytes = ByteBuffer.allocate(4); // size of an 'int' <br /> <br /> socketChannel.read(incomingLengthInBytes); <br /> <br /> incomingLengthInBytes.rewind(); <br /> <br /> int incomingLength = incomingLengthInBytes.getInt(); <br /> <br /> if (incomingLength > 0)<br /> {<br /> inviaToast("G<span class="forTooltip">ot</span> Incoming Length as: " + incomingLength + " bytes"); <br /> <br /> // now allocate the correct size for the message... <br /> ByteBuffer incomingData = ByteBuffer.allocate(incomingLength); <br /> <br /> socketChannel.read(incomingData); <br /> <br /> incomingData.rewind(); <br /> <br /> incomingData.get(bustaRicevuta.pacchetto);<br /> bustaRicevuta.lenPacchetto = incomingLength;<br /> }<br />

 

1

​

2

                    ByteBuffer incomingLengthInBytes = ByteBuffer.allocate(4); // size of an 'int' 

3

4

                    socketChannel.read(incomingLengthInBytes); 

5

6

                    incomingLengthInBytes.rewind(); 

7

8

                    int incomingLength = incomingLengthInBytes.getInt(); 

9

10

                    if (incomingLength > 0)

11

                    {

12

                        inviaToast("Got Incoming Length as: " + incomingLength + " bytes"); 

13

14

                        // now allocate the correct size for the message... 

15

                        ByteBuffer incomingData = ByteBuffer.allocate(incomingLength); 

16

17

                        socketChannel.read(incomingData); 

18

19

                        incomingData.rewind(); 

20

21

                        incomingData.get(bustaRicevuta.pacchetto);

22

                        bustaRicevuta.lenPacchetto = incomingLength;

23

                    }

24

​

Il socket non è bloccante e tutto sembra funzionare, ma quando arrivano effettivamente dei dati, la variabile incomingLenght contiene un numero da fantascienza invece che la vera quantità di dati nel socket...

Qualche suggerimento? Alternative per un metodo non bloccante che funzioni? Bye bye