Уже и в сервере и в клиенте покупался, все тщетно. Код, работающий у других у меня не идет
package com.javarush.task.task30.task3008;
import java.io.*;
import java.net.*;
import java.util.*;
import java.util.concurrent.*;
public class Server {
private static Map<String, Connection> connectionMap = new ConcurrentHashMap<>();
public static void sendBroadcastMessage(Message message){
connectionMap.forEach((name, connection) -> {
try{
connection.send(message);
} catch (IOException e) {
System.err.println("Broadcast send error on " + name);
}
});
}
public static void main(String[] args) {
ServerSocket serverSocket=null;
Socket socket=null;
try{
serverSocket = new ServerSocket(ConsoleHelper.readInt());
System.out.println("Server start");
while(true){
socket = serverSocket.accept();
Handler handler = new Handler(socket);
handler.start();
}
} catch (IOException e){
e.printStackTrace();
}
}
private static class Handler extends Thread{
private Socket socket;
public Handler(Socket socket){
this.socket=socket;
}
private String serverHandshake(Connection connection) throws IOException, ClassNotFoundException{
String userName=null;
Message answer=null;
while(true){
connection.send(new Message(MessageType.NAME_REQUEST));
answer = connection.receive();
if(answer.getType()!=MessageType.USER_NAME) continue;
userName = answer.getData();
if(userName==null||userName.isEmpty()) continue;
if(connectionMap.containsKey(userName)) continue;
connectionMap.put(userName, connection);
connection.send(new Message(MessageType.NAME_ACCEPTED));
return userName;
}
}
private void notifyUsers(Connection connection, String userName) throws IOException{
for (String name: connectionMap.keySet())
{
try{
if(!userName.equals(name)) connection.send(new Message(MessageType.USER_ADDED,name));
} catch (IOException e) {
System.err.println("notifyUsers error on " + name);
}
}
}
private void serverMainLoop(Connection connection, String userName) throws IOException, ClassNotFoundException{
while(true){
Message inputMessage = connection.receive();
if(inputMessage.getType()==MessageType.TEXT)
{sendBroadcastMessage(new Message(MessageType.TEXT,userName+": "+inputMessage.getData()));}
else {ConsoleHelper.writeMessage("SendBrodcast not TEXT in");}
}
}
public void run (){
ConsoleHelper.writeMessage("run connection with"+socket.getRemoteSocketAddress());
try{
Connection conn = new Connection (socket);
String userName = serverHandshake(conn);
sendBroadcastMessage(new Message (MessageType.USER_ADDED,userName));
notifyUsers(conn,userName);
serverMainLoop(conn,userName);
connectionMap.remove(userName);
sendBroadcastMessage(new Message (MessageType.USER_REMOVED, userName));
ConsoleHelper.writeMessage("user was deleted");
}
catch(IOException | ClassNotFoundException e) {
}
}
}
}