farina/COO-farina-vincent
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Connections TCP fonctionnelles

Browse source
This commit is contained in:
Louis Farina 2021-01-11 20:04:10 +01:00
parent 7e9db0d86d
commit b99a346766
1 changed files with 5 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/chat/NetworkClient.java
View file

@ -72,9 +72,7 @@ class ReceiveThread extends Thread {
{ {
while(!exit) while(!exit)
{ {
System.out.println("Waiting for a message");
ObjectInputStream in = new ObjectInputStream(socket.getInputStream()); ObjectInputStream in = new ObjectInputStream(socket.getInputStream());
System.out.println("Received a message");
Message message = (Message) in.readObject(); Message message = (Message) in.readObject();
if(message.getText() != null) if(message.getText() != null)
{ {
@ -83,7 +81,11 @@ class ReceiveThread extends Thread {
else else
{ {
displayArea.append(message.getAuthor() + " has left the chat.\n"); displayArea.append(message.getAuthor() + " has left the chat.\n");
known_users.remove(new User(message.getAuthor())); for(int i = 0;i < known_users.size();i ++)
{
if (known_users.get(i).getName().equals(message.getAuthor()))
known_users.remove(i);
}
knownUsersPanel.setText(""); knownUsersPanel.setText("");
knownUsersPanel.append("Online:\n"); knownUsersPanel.append("Online:\n");
for(User u:known_users) for(User u:known_users)
@ -302,8 +304,6 @@ public class NetworkClient {
} }
for(String a:addressList) for(String a:addressList)
{ {
System.out.println("Connecting to " + a);
System.out.println(" on port " + String.valueOf((1237+usernameList.length)));
Socket s = new Socket(a, (1237+usernameList.length)); Socket s = new Socket(a, (1237+usernameList.length));
dest_sockets.add(s); dest_sockets.add(s);
(new ReceiveThread(s, chatText, known_users, knownUsersPanel, dest_sockets)).start(); (new ReceiveThread(s, chatText, known_users, knownUsersPanel, dest_sockets)).start();
@ -377,7 +377,6 @@ public class NetworkClient {
{ {
try try
{ {
System.out.println(s);
ObjectOutputStream out = new ObjectOutputStream(s.getOutputStream()); ObjectOutputStream out = new ObjectOutputStream(s.getOutputStream());
out.writeObject(new Message(user.getName(), message)); out.writeObject(new Message(user.getName(), message));
} }