[socket] probleme lecture

**gorgonite** · 15/09/2006, 14h12

Salut,

Je n'arrive pas à lire ce qui arrive dans ma socket...

nb: je suis obligé de passer par les nio et les bytebuffer

voilà ce que j'ai pour le moment

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
package tp01;
 
import java.io.IOException;
import java.net.*;
import java.nio.*;
import java.nio.channels.*;
import java.util.*;
 
 
public class ServeurFTP {
	public static int DEFAULT_PORT = 4000;
 
	protected ServerSocketChannel serverChannel;
	protected Selector selector;
 
	public void openPort() {
		try {
			serverChannel = ServerSocketChannel.open();
			ServerSocket ss = serverChannel.socket();
			InetSocketAddress address = new InetSocketAddress(DEFAULT_PORT);
			ss.bind(address);
			serverChannel.configureBlocking(false);
			selector = Selector.open();
			serverChannel.register(selector, SelectionKey.OP_ACCEPT);
		} catch (IOException ex) {
			ex.printStackTrace();
			return;
		}
	}
 
	protected void processIfAcceptable(SelectionKey key) {
		try {		
			ServerSocketChannel server = (ServerSocketChannel) key.channel();
			SocketChannel client = server.accept();
			System.out.println("Accepted connection from " + client);
			client.configureBlocking(false);
			SelectionKey clientKey = client.register( selector, SelectionKey.OP_WRITE | SelectionKey.OP_READ);
			ByteBuffer buffer = ByteBuffer.allocate(100);
			clientKey.attach(buffer);
		} catch (IOException ex) {
			key.cancel();
			try {
				key.channel().close();
			} catch (IOException cex) { }
		}
	}
 
	protected ByteBuffer processIfReadable(SelectionKey key) {
		try {			
			SocketChannel client = (SocketChannel) key.channel();
			ByteBuffer output = (ByteBuffer) key.attachment();
			client.read(output);
			return output;
		} catch (IOException ex) {
			key.cancel();
			try {
				key.channel().close();
			} catch (IOException cex) { }
			return (ByteBuffer) null;
		}
	}
 
	public void startProcess() {
		while (true) {
			try {
				selector.select();
			} catch (IOException ex) {
				ex.printStackTrace();
				break;
			}
 
			Set readyKeys = selector.selectedKeys();
			Iterator iterator = readyKeys.iterator();
			while (iterator.hasNext()) {
				SelectionKey key = (SelectionKey) iterator.next();
				iterator.remove();
 
				if (key.isAcceptable()) {
					processIfAcceptable(key);
				}
 
				if (key.isReadable()) {
					CharBuffer buf = processIfReadable(key).asCharBuffer();
					System.out.println(buf.length() + " " + buf.capacity() + " " + buf.remaining());
					buf.flip();
					char[] tmp = new char[buf.length()];
					buf.get(tmp);
					String msg = new String(tmp);
 
					if (msg.equals("")) {
						System.out.println("string vide");
						System.out.flush();
					} else {
						System.out.println(msg);
						System.out.flush();						
					}
				}					
			}
		}		
	}
 
	public static void main(String[] args) {
		ServeurFTP myServer = new ServeurFTP();
		myServer.openPort();
		myServer.startProcess();
	}
}

si quelqu'un voit où j'ai faux... ça m'arrangerait beaucoup

**gorgonite** · 15/09/2006, 19h36

vraiment pas inspiré

**gorgonite** · 16/09/2006, 14h14

Envoyé par gorgonite

vraiment pas inspiré

toujours pas... de mon côté, je reste toujours bloqué sur l'extraction du contenu du ByteBuffer en String

**bouye** · 18/09/2006, 03h49

Hello, j'avoue que je n'ai jamais utilise les nio sur les socket reseau, uniquement (et encore tres peu) sur des flux locaux.

Sinon, new String(buffer.array()) ou buffer.toString() ne fonctionnent pas ?

**gorgonite** · 18/09/2006, 20h53

nan ça ne veut pas...

j'ai une solution, mais elle est moche
je lis par blocs de 1 caractère et je concatène

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
package tp01;
 
import java.io.*;
 
 
public class ServeurFTP {
	public static int DEFAULT_PORT = 4000;
 
	protected ServerSocketChannel serverChannel;
	protected Selector selector;
	protected String pwd;
 
	public ServeurFTP() {
		refreshPWD(".");
	}
 
	public void refreshPWD(String str) {
		String tempStr = (new File(str)).getAbsolutePath();
		if (!tempStr.equals("/")) {
			pwd = tempStr.substring(0, tempStr.length()-2);
		}		
	}
 
	public void openPort() {
		try {
			serverChannel = ServerSocketChannel.open();
			ServerSocket ss = serverChannel.socket();
			InetSocketAddress address = new InetSocketAddress(DEFAULT_PORT);
			ss.bind(address);
			serverChannel.configureBlocking(false);
			selector = Selector.open();
			serverChannel.register(selector, SelectionKey.OP_ACCEPT);
		} catch (IOException ex) {
			ex.printStackTrace();
			return;
		}
	}
 
	protected void processIfAcceptable(SelectionKey key) {
		try {		
			ServerSocketChannel server = (ServerSocketChannel) key.channel();
			SocketChannel client = server.accept();
			System.out.println("Accepted connection from " + client);
			client.configureBlocking(false);
			SelectionKey clientKey = client.register( selector, SelectionKey.OP_WRITE | SelectionKey.OP_READ);
			ByteBuffer buffer = ByteBuffer.allocate(100);
			clientKey.attach(buffer);
		} catch (IOException ex) {
			key.cancel();
			try {
				key.channel().close();
			} catch (IOException cex) { }
		}
	}
 
	protected ReponseBuffer processIfReadable(SelectionKey key) {
		try {			
			SocketChannel client = (SocketChannel) key.channel();
			ByteBuffer output = (ByteBuffer) key.attachment();
			int len = client.read(output);
			return new ReponseBuffer(len, output);
		} catch (IOException ex) {
			key.cancel();
			try {
				key.channel().close();
			} catch (IOException cex) { }
			return new ReponseBuffer(0, null);
		}
	}
 
	protected void sendAnswer(SelectionKey key, String str) {
		try {			
			SocketChannel client = (SocketChannel) key.channel();
			ByteBuffer output = ByteBuffer.wrap(str.getBytes());
			client.write(output);
		} catch (IOException ex) {
			key.cancel();
			try {
				key.channel().close();
			} catch (IOException cex) { }
		}		
	}
 
	public void startProcess() {
		while (true) {
			try {
				selector.select();
			} catch (IOException ex) {
				ex.printStackTrace();
				break;
			}
 
			Set readyKeys = selector.selectedKeys();
			Iterator iterator = readyKeys.iterator();
			while (iterator.hasNext()) {
				SelectionKey key = (SelectionKey) iterator.next();
				iterator.remove();
 
				if (key.isAcceptable()) {
					processIfAcceptable(key);
				}
 
				if (key.isReadable()) {
					ByteBuffer buf = processIfReadable(key).getBuf();
					buf.flip();
					byte[] tmp = new byte[1];
					String temp = new String();
					while (buf.hasRemaining()) {
						buf.get(tmp);
						temp += new String(tmp);
					}
 
					String msg;
					if (temp.length() > 2) {
						msg = temp.substring(0, temp.length()-2);
					} else {
						break;
					}
					System.out.println(msg.length() + "\t" + msg);
 
					String answer = new String();
					boolean hasSwitched = false;
 
					if (msg.equals("bye")) {
						key.cancel();
					}
 
					if (msg.equals("pwd")) {
						hasSwitched = true;
						answer = pwd;
 
					}
 
					if (msg.startsWith("cd")) {
						hasSwitched = true;
						String oldPwd = pwd;
 
						int i = 2;
						while (msg.charAt(i) == ' ') {
							i++;
						}
						String mesg = msg.substring(i);
 
						if (mesg.startsWith("..")) {
							if (pwd != "/") {
								int lastSlashAt = pwd.lastIndexOf("/");
								pwd = pwd.substring(0, lastSlashAt);
 
								int firstSlashAt = mesg.indexOf("/");
								if (firstSlashAt != -1) {
									pwd += "/" + mesg.substring(firstSlashAt+1);
								}
							}
						} else {
							pwd += "/" + mesg;
						}
						answer = "Nouveau répertoire de travail " + pwd;
 
						if (!(new File(pwd)).exists()) {
							answer = "Répertoire " + pwd + " inexistant";
							pwd = oldPwd;
						}
					}
 
					if (!hasSwitched) {
							answer = "Commande inconnue";
					}
 
					if (key.isValid() && key.isWritable()) {
						System.out.println(answer);						
						sendAnswer(key, answer+"\n");
					}
 
					buf.clear();
				}				
			}
		}		
	}
 
	public static void main(String[] args) {
		ServeurFTP myServer = new ServeurFTP();
		myServer.openPort();
		try {
			myServer.startProcess();
		} catch (Exception ex) {
			ex.printStackTrace();
		}
	}
}

j'ai tout mis pour que vous puissiez tester...

**gorgonite** · 21/09/2006, 11h16

vraiment personne ?

**gorgonite** · 22/09/2006, 22h23

j'ai une réponse...

il faut remplacer

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
ByteBuffer buf = processIfReadable(key).getBuf();
buf.flip();
byte[] tmp = new byte[1];
String temp = new String();
while (buf.hasRemaining()) {
	buf.get(tmp);
	temp += new String(tmp);
}

par

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
ByteBuffer buf = processIfReadable(key).getBuf();
buf.flip();
String temp = Charset.forName("UTF-8").decode(buf).toString();

**daedric** · 22/09/2006, 22h30

que veux tu lire dans tes sockets ?
as tu pensé a utiliser la classe Scanner ?

**gorgonite** · 22/09/2006, 22h36

Envoyé par daedric

que veux tu lire dans tes sockets ?
as tu pensé a utiliser la classe Scanner ?

ben je veux lire ce qui y transite... ça peut aller d'une commande texte à un fichier en binaire

Scanner... connais pas, sert à quoi ?

**daedric** · 22/09/2006, 22h45

va voir la javadoc pour la classe Scanner , elle permet de lire n'importe quel flux

sinon moi ce que je fais pour mes Socket je passe un int en premier parametre quand j'envoi la commande et je taite le reste suivant ce int .
ensuite pour lire les byte je repasse la main a un InputStream

voila la classe que jutilise en general pour lire :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
package com.daedric.net;
 
 
 
import java.io.IOException;
 
import java.io.InputStream;
 
import java.io.ObjectOutputStream;
 
import java.io.OutputStream;
 
import java.io.PrintWriter;
 
import java.net.Socket;
 
import java.util.Scanner;
 
import java.util.concurrent.locks.Lock;
 
import java.util.concurrent.locks.ReentrantLock;
 
 
 
public class Connection {
 
	private InputStream		in;
 
 
 
	private Lock			lock;
 
 
 
	private PrintWriter		out;
 
 
 
	private OutputStream	outstream;
 
 
 
	private Scanner			sc;
 
 
 
	public Socket			sock;
 
 
 
	public Connection(Socket i) throws IOException {
 
 
 
		sock = i;
 
		in = sock.getInputStream();
 
		outstream = sock.getOutputStream();
 
		out = new PrintWriter(outstream, true);
 
		sc = new Scanner(in);
 
		lock = new ReentrantLock();
 
 
 
	}
 
 
 
	public void flush() throws IOException {
 
		lock.lock();
 
		getOutputStream().flush();
 
		this.out.flush();
 
		lock.unlock();
 
	}
 
 
 
	public InputStream getInputStream() {
 
		return in;
 
	}
 
 
 
	/**
 
         * @return the outstream
 
         */
 
	public OutputStream getOutputStream() {
 
		return outstream;
 
	}
 
 
 
	public PrintWriter getPrintWriterStream() {
 
		return out;
 
	}
 
 
 
	/**
 
         * @return the sc
 
         */
 
	public Scanner getScan() {
 
		return sc;
 
	}
 
 
 
	public Socket getSock() {
 
		return sock;
 
	}
 
 
 
	public void sendMes(Object Mess) {
 
		lock.lock();
 
		System.out.println("message envoyé => " + Mess);
 
		this.out.println(Mess);
 
		this.out.flush();
 
		lock.unlock();
 
	}
 
 
 
	public void sendObj(Object Mess) {
 
		lock.lock();
 
		try {
 
			ObjectOutputStream out = new ObjectOutputStream(getOutputStream());
 
			out.writeObject(Mess);
 
			out.flush();
 
		} catch (IOException e) {
 
			// TODO Auto-generated catch block
 
			e.printStackTrace();
 
		} finally {
 
			lock.unlock();
 
		}
 
	}
 
 
 
	public void setSock(Socket sock) {
 
		this.sock = sock;
 
	}
 
 
 
	public String toString() {
 
		return "" + sock.getInetAddress();
 
	}
 
 
 
	public boolean is(String ip) {
 
		String localIp = this.toString();
 
		// vive l'operateur ternaire
 
		return ip.compareTo(localIp = localIp.indexOf('/') > 0 ? localIp
 
				.substring(localIp.indexOf('/') + 1) : localIp) == 0 ? true
 
				: false;
 
	}
 
 
 
	/**
 
         * ferme toutes les connections
 
         * 
 
         */
 
	public void close() {
 
		try {
 
			this.flush();
 
			this.getInputStream().close();
 
			this.getOutputStream().close();
 
			this.getSock().close();
 
		} catch (IOException e) {
 
			// TODO Auto-generated catch block
 
			e.printStackTrace();
 
		}
 
 
 
	}
 
}

je l'ai fourni tel quel a toi d'adapter

tien par exemple pour recuperer un fichier a partir de la meme socket :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
	private void readFile(InputStream in) throws IOException {
 
		byte[] buf = new byte[8192];
 
		FileOutputStream out = new FileOutputStream(".\\map\\map.zmap");
 
		int lu = 0;
 
		do {
 
			lu = in.read(buf);
 
			if (lu > 0) {
 
				out.write(buf, 0, lu);
 
				if (lu < 8192)
 
					break;
 
			}
 
 
 
		} while (lu > 0);
 
 
 
		out.flush();
 
		out.close();
 
			}