[socket] Récupération d'images à intervalle régulier
Salut.
J'essaie de récupérer pour mon client et par socket des images contenues sur un serveur. Lorsque je réécris les images sur le disque, ça fonctionne assez bien (mais a un côté aléatoire : des fois ça en passe 4, des fois 10...), et quand j'essaie de les afficher dans un JPanel ça bloque à 1 ou 2 images.
le Client:
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
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
| public class Client {
static final int port = 3334;
static final String host = "aluminod";
public static final double STEP = 2000.0;
public static final int DELAY = 0;
private Socket socket;
private PrintWriter printWriter;
private BufferedReader input;
private int imgNumber = 0;
private static MoviePanel pane;
private Timer timer;
public Client() throws UnknownHostException, IOException{
this.socket = new Socket(host, port);
System.out.println("SOCKET = " + socket);
this.printWriter = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
this.input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
start();
}
public static void main(String[] args){
JFrame frame = new JFrame("test");
pane = new MoviePanel();
frame.setPreferredSize(new Dimension(600,400));
frame.setSize(new Dimension(600,400));
frame.setVisible(true);
frame.setLocation(Toolkit.getDefaultToolkit().getScreenSize().width/2-300, Toolkit.getDefaultToolkit().getScreenSize().height/2-200);
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
frame.getContentPane().setLayout(new BorderLayout());
frame.getContentPane().add(pane, BorderLayout.CENTER);
frame.add(pane);
try {
new Client();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
private void start(){
this.timer = new Timer();
timer.scheduleAtFixedRate(new TimerTask() {
public void run() {
try {
sendParamsToVC();
} catch (IOException e) {
e.printStackTrace();
}
}
}, DELAY, (long) STEP);
}
private void sendParamsToVC() throws IOException {
System.out.println("---sending---");
String mess = buildMessage();
//envoi du message au serveur
printWriter.println(mess);
// lecture de la réponse du serveur
InputStream is = socket.getInputStream();
int taille = Integer.parseInt(input.readLine());
byte[] mybytearray = new byte[taille];
is.read(mybytearray, 0, taille);
BufferedImage img = ImageIO.read(new ByteArrayInputStream(mybytearray));
pane.change(img);
imgNumber++;
}
private String buildMessage(){
String mess;
if(imgNumber <10)mess = "000"+imgNumber;
else if(imgNumber<=13)mess = "00"+imgNumber;
else {
mess = "NO_IMG";
timer.cancel();
}
return mess;
}
} |
Le Serveur:
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
62
63
64
65
66
67
68
69
| public class Server {
static final int port = 3334;
public static void main(String[] args) throws Exception {
ServerSocket servsocket = new ServerSocket(port);
while (true) {
Socket client = servsocket.accept();
System.out.println("connection accepted");
BufferedReader reader = new BufferedReader(new InputStreamReader(client.getInputStream()));
BufferedOutputStream output = new BufferedOutputStream(client.getOutputStream());
while (true) {
String str = reader.readLine(); // lecture du message
if (str.equals("NO_IMG")){
System.out.println("ECHO = " + str);
System.out.println("fermeture");
break;
}
System.out.println("ECHO = " + str); // trace locale
//renvoi de l'image
OutputStream os = client.getOutputStream();
byte[]data = getByteFromImage(str);
PrintWriter writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(client.getOutputStream())),true);
writer.println(data.length);
writer.flush();
os.write(data, 0, data.length);
os.flush();
}
output.close();
reader.close();
client.close();
}
}
public static byte[] getByteFromImage(String numImage) {
BufferedImage img = ImageLoader.createBufferedImage(numImage);
/** On crée la nouvelle image */
BufferedImage bufferedImage = new BufferedImage(
img.getWidth(null),
img.getHeight(null),
BufferedImage.TYPE_INT_BGR );
Graphics g = bufferedImage.createGraphics();
g.drawImage(img,0,0,null);
g.dispose();
ByteArrayOutputStream out = new ByteArrayOutputStream();
try {
ImageIO.write(bufferedImage, "jpeg", out);
out.flush();
} catch (IOException e) {
e.printStackTrace();
}
byte buffer[] = out.toByteArray();
try {
out.close();
} catch (IOException e) {
e.printStackTrace();
}
return (buffer);
}
} |
Voilà, je pense que je ne gère pas très bien mes stream d'entrée/sortie, et me demande si un traitement par UDP / flux ne serait pas meilleur, mais je ne sais absolument pas faire cela.
