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
| while(socketLocal.isConnected()){
try {
message=fluxEntree.readLine();
if (message!=null) {
if (message.equals("SERVER_PASSWORD")) {
client.setAvancement(20 ,"Set server password",1);
log.info("Server ask for id");
fluxSortie.println(PropertiesManager.getExpansionKey("server_pwd"));
}
if (message.equals("WRONG_SERVER_PASSWORD")) {
client.setAvancement(10 ,LanguageManager.getAnInternationalizeString("faux_pwd"),1);
log.info("The server password is wrong");
client.setClientDisable();
}
if (message.equals("WRONG_CLIENT_VERSION")) {
client.setAvancement(20 ,"Your client version is not supported",1);
log.info("The client version is not supported");
client.setClientDisable();
}
if (message.equals("CLIENT_VERSION")) {
client.setAvancement(20 ,"Set client version",1);
log.info("Server ask for version");
fluxSortie.println("0.1");
}
if (message.equals("PING")) {
log.info("Server ping me");
fluxSortie.println("PONG");
}
if (message.equals("LOGIN")) {
fluxSortie.println(PropertiesManager.getExpansionKey("login")+":"+PropertiesManager.getExpansionKey("login_pwd")+":"+PropertiesManager.getExpansionKey("univer"));
client.setAvancement(0 ,"OK!",1);
client.setAvancement(50 ,"Send login/password",2);
log.info("Server ask for login");
}
if (message.equals("OK")) {
client.setAvancement(50 ,LanguageManager.getAnInternationalizeString("bienvenue"),2);
log.info("ok, waiting for univer...");
}
if (message.equals("WRONG_PASSWORD")) {
client.setAvancement(40 ,LanguageManager.getAnInternationalizeString("faux_pwd"),2);
log.info("The login password is wrong");
client.setClientDisable();
}
if (message.equals("WRONG_UNIVERS")) {
client.setAvancement(40 ,LanguageManager.getAnInternationalizeString("faux_univers"),2);
log.info("The univers is wrong");
client.setClientDisable();
}
if (message.equals("NULL")) {
client.setAvancement(0 ,"Login/password can not be null",2);
log.info("The login/password is null");
client.setClientDisable();
}
if (message.equals("UNIVERS")) {
client.setAvancement(10 ,"Loading Univers...",3);
log.info("Loading Univers...");
//recuperation de l'univers
InputStream is = socketLocal.getInputStream();
client.setAvancement(10 ,"Loading Univers...",3);
ObjectInputStream ois = new ObjectInputStream(is);
//BufferedInputStream fis=new BufferedInputStream(is);
client.setAvancement(10 ,"Loading Univers...",3);
try {
log.info("Univers Object incomming...");
Object temp= ois.readObject();
//Object temp=((ObjectInput) fis).readObject();
client.setAvancement(50 ,"Loading Univers...",3);
client.setClientEnable();
Univers mainUniver=(Univers) temp;
System.out.println(mainUniver.getName());
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
log.info("Reday to play");
client.setClientEnable();
}
message="";
}
} catch (IOException e) {
e.printStackTrace();
log.error("Error between Client and Server");
log.info("Deconnected from server");
client.setClientDisable();
return;
} |
[Serialisation]Transfert d'objet(s) par un socket
Répondre avec citation
Envoyé par Yan17
grand merci, en gros j'avais plusieurs flux que ce soit entrants ou sortants du cote client et meme serveur , donc on peut suposer que parfois certaines donnees etaient manger par les autres.
Partager