不能在两个实例中运行相同的类

Question

我正在尝试使用线程将 2 个或更多客户端连接到 java 服务器，但是当我尝试多次运行我的类客户端时，它说

“客户端”不允许并行运行。 要停止正在运行的吗？

我想要这样的东西

编辑：

我注意到如果我在 cmd 中运行这个程序一切正常，我可以毫无问题地连接 2 个或更多客户端。

问题是由于“并行”错误，我无法在 intelliJ 中执行此操作。

我的代码是这样的

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();
            }
        }
    }


}

我一直试图找出问题所在，但对此无能为力。有什么想法吗？

Answer 1

我正在运行你的代码，但我没有收到错误，可能你需要增加java虚拟机。因为我的默认值是 12000 mb

增加java内存，可以做下

Java memory

如果没有功能，需要检查ide，我用的是netbeans