Я пытаюсь подключить 2 или более клиентов к java серверу, используя потоки, но когда я пытаюсь запустить мой классный клиент несколько раз, он говорит:
«Клиент» не может работать параллельно. Хотели бы вы остановить запущенную?
Я хотел бы получить что-то вроде этого
edit:
Я заметил, что если я запустите эту программу в cmd все работает нормально, я могу без проблем подключиться к 2 или более клиентам.
Проблема заключается в том, что я не могу сделать это в intelliJ из-за ошибки 'Parallel'.
И мой код выглядит так
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Server {
private static String[] names = {"Willy", "Felix", "Piotr"};
private static String[] adjs = {"the gentle", "the un-gentle", "the urbane"};
private static final int PORT = 9090 ;
private static ArrayList<ClientHandler> clients = new ArrayList<>();
private static ExecutorService pool = Executors.newFixedThreadPool(5);
public static void main(String[] args) throws IOException {
//utworzenie nowego socketu
ServerSocket listener = new ServerSocket(PORT);
while(true)
{
System.out.println("Serwer czeka na polaczenie...");
//akceptowanie polaczenia
Socket client = listener.accept();
System.out.println("S: Polaczono z klientem");
ClientHandler clientThread = new ClientHandler(client);
clients.add(clientThread);
pool.execute(clientThread);
}
}
public static String getRandomName()
{
String name = names[(int)(Math.random()*names.length)];
String adj = adjs[(int)(Math.random()*adjs.length)];
return name + " " + adj;
}
}
import javax.swing.*;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
public class Client {
private static final String SERVER_IP = "127.0.0.1";
private static final int SERVER_PORT = 9090;
public static void main(String[] args) throws IOException {
//tworzenie socketu
Socket socket = new Socket(SERVER_IP, SERVER_PORT);
//buffer za pomoca ktorego client odbiera cos od servera
BufferedReader input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//buffer pobierajacy z klawiatury
BufferedReader keyboard = new BufferedReader(new InputStreamReader(System.in));
//buffer wysylajacy do servera
PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
while(true) {
//czytanie z klawiatury do zmiennej command
System.out.println("> ");
String command = keyboard.readLine();
//wyslanie zawartosci command do servera
if(command.equals("quit")) break;
out.println(command);
String serverResponse = input.readLine();
System.out.println("Server mowi: " + serverResponse);
}
//zamkniecie socketow i buffera
//socket.close();
//input.close();
}
}
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
public class ClientHandler implements Runnable{
//zmienne dla socketa i bufferow z dateserver
private Socket client;
private BufferedReader in;
private PrintWriter out;
public ClientHandler(Socket clientSocket) throws IOException {
this.client = clientSocket;
in = new BufferedReader(new InputStreamReader(client.getInputStream()));
out = new PrintWriter(client.getOutputStream(), true);
}
@Override
public void run() {
try{
while (true) {
String request = in.readLine();
if (request.contains("name")) {
out.println(Server.getRandomName());
} else {
out.println("Type 'tell me a name' to get random name");
}
}
} catch (IOException e) {
System.err.println("IO exception in client handler");
System.err.println(e.getStackTrace());
}finally {
out.close();
try {
in.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
Я пытался понять, что не так, но ничего не могу сделать об этом. Есть мысли?