problème Sockets JAVA

Version imprimable

Bonjour à tous

je travaille avec les sockets (je suis débutant dans cette technologie) mon problème et le suivant

j'envois une demande au serveur, si la réponse du serveur est un seul message c'est bon mais lorsque j'attends que le serveur me renvoit deux messages je ne reçois qu'un seul
pour bien préciser, en mode débuggage tout ca marche bien
au fait l'idée que j'ai c'est qu'il s'agit de problème de synchronistation

mon code est le suivant :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 private Socket skt; private InputStream is; private OutputStream os; //connexion skt = new Socket(host, port); is = skt.getInputStream(); os = skt.getOutputStream(); //Envois os.write(bytes); //bytes : bytes à écrire //reception len = is.read(buf); //buf:le buffer qui sera rempli par la réponse du serveur et len c'est la longueur lue retournée
mon problème se situe au niveau de read qui me renvoit un seul message même si je devais avoir deux
est ce qu'il y a une possibilité pour que le serveur me renvoie toute la réponse

Merci d'avance

28/11/2008, 17h25
Lucio_

J'imagine que le read doit se terminer a la fin du premier message...

Pourquoi ne pas créer un thread qui écoutera les messages du serveur?
28/11/2008, 17h26
DeathMaker
C'est quoi le serveur ? Un serveur maison ? Web, FTP... ?

Sinon, comme le dit la JavaDoc:
Code:

1 2 read() Reads the next byte of data from the input stream.
Donc si tu veux lire un 2e byte, tu l'appelles encore une fois ^^

Regarde du coté du bufferedReader....
28/11/2008, 18h20
salim_1971

Re Sockets

justement, je dois travailler avec les threads mais je n 'ai pas bcp d'idée la dessus
je sais que je dois créer une classe qui hérite de Thread et implémenter la méthode run mais comment? je ne sais pas
28/11/2008, 18h21
salim_1971

Re Sockets

si vous pouvez terminer mon code je vous serai trés reconnaissant

La comme ca, je dirais:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
 
 new Thread()
          {
            public void run()
            {
             while (conditionADefinir){
              len = is.read(buf);
              // traitement du résultat
 
              }
            }
          }.start();

Re Socket

Merci pour tes réponses
voila ce que j'ai essayé mais ca n a pas marché :(

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
 
private Socket skt;
private InputStream is;
private OutputStream os;
 
1 - connexion
          skt = new Socket(host, port);
          skt.setSoTimeout(timeout);
          is = skt.getInputStream();
          os = skt.getOutputStream();
2 - Envoi
          IoBuffer buffer = ......
          byte[] msg = new byte[buffer.limit() - buffer.position()];
          buffer.get(msg);
          os.write(msg);
3 - Reception
          byte[] buf = new byte[4192];
          int longuer = recevoirReponse(buf);
          //code de la methode recevoirReponse
          public int recevoirReponse(byte[] buf) throws Exception {
                int longuer = 0;
                try {
                     len = is.read(buf);
                } catch (Exception e) {}
                return longuer;
          }
aprés notre discution j'ai modifiée la phase 3 l'impklémentation de la méthode recevoirReponse comme suit
3-bis - Reception
          //déclaration
          BufferedReader in = null;
          SocketListener sl = null; //le thread qui va réagir à la réponse du 
                                           //serveur (l 'implémentation à la fin)
          public int recevoirReponse(byte[] buf) throws Exception {
                in = new BufferedReader(new InputStreamReader(is));
                sl = new SocketListener(in); // creation du thread
                sl.start();
                return sl.len;
          }
 
4 - implémentation du thread
          public class SocketListener extends Thread {
                    private BufferedReader in;
                    private boolean run = true;
                    int len;
                    //constructeur
                    public SocketListener(BufferedReader b) {
                              in=b;
                    }
                    public void finish() {
                              run = false;
                    }
 
                    public void run() {
                              len=0;
                              while (run) {
                                       try {
                                                len = in.read();
                                       } catch (IOException e) {}
                             }
                   }
         }

Voila j'espère que j'ai tout écrit
et Merci une autre fois

Bonjour si ca peu aider j'ai un piti client/server qui trainai dans un coin:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
class Client
	{
	public static void main(String args[])
		{
		try
			{
			int size;
			byte buff[]=new byte[2000];		
			Socket s=new Socket("localhost", 8080);
 
			InputStream is=s.getInputStream();
			OutputStream os=s.getOutputStream();
 
			os.write(new String("Test").getBytes());
			size=is.read(buff);
			System.out.println(new String(buff, 0, size));
			}
		catch(Exception e)
			{
			}
		}
	}

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
class server
	{
	public static void main(String args[])
		{
			try
			{
			ServerSocket sSocket=new ServerSocket(port);
 
			while(true)
				{
				Socket socket=sSocket.accept();
				new Connection(socket);
				}
			}
		catch(Exception e)
			{
			e.printStackTrace();
			}
class Connection extends Thread
	{
	Socket socket;
 
	Connection(Socket s)
		{
		socket=s;
		start();
		}
	public void run()
		{
		try
			{
			String rep="ok";
			byte[] buff=new byte[2000];
			InputStream is=socket.getInputStream();
			int size=is.read(buff);
			//Traiter les donner recu.
			byte mess[]=rep.getBytes();
 
			OutputStream os=socket.getOutputStream();
			os.write(mess);
 
			socket.close();
			}
		catch(Exception e)
			{
			System.out.println(e);
			}
		}
	}