Java 线程对象如何调用原始 class 中的方法？

Question

我有一个客户端-服务器聊天程序，其中服务器将为每个接受的连接创建一个新线程，其中 NewClient 扩展 Thread 以处理来自特定客户端的请求。

这是服务器代码的片段：

public void startServer() {
    // thread to handle requests
    new Thread(() -> {
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("Server started at " + new Date());

            while (true) {
                // listen for connection request
                Socket socket = serverSocket.accept();

                // increment total clients connected
                clientCount++;

                // create new client
                NewClient newClient = new NewClient(socket, clientCount);

                // add client to active client list
                activeClientList.add(newClient);

                // start thread
                newClient.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }).start();
}

在NewClient中，线程会循环检查输入流。如果检测到输入流，我希望它向所有客户端广播输入流中的消息。

这里是NewClient的运行方法：

public void run() {
    while(true) {
        try {
            // read from client
            Data message = (Data) objectInputStream.readObject();
            System.out.println("Received " + message.text + " from " + message.name);

            // broadcast to all clients
            // broadcastMessage(message)


        } catch (IOException | ClassNotFoundException e) {
            System.out.println("Failed to get input stream");
            e.printStackTrace();
        }
    }
}

回到服务器class，有一个名为 broadcastMessage(Data data) 的方法，它将遍历数组列表中的所有连接的客户端，并使用输出流将数据发送到每个客户端.

方法如下：

public synchronized void broadcastMessage(Data data) {
    Integer size = activeClientList.size();

    // loop through all clients
    for(int i=size-1;i>=0;i--) {
        NewClient client = activeClientList.get(i);

        if(!client.writeToClient(data)) {
            activeClientList.remove(i);

            // notify users of disconnect
            Data update = new Data(data.name, data.name + " has disconnected.");
            broadcastMessage(update);
        }
    }
}

我知道如果这是一个匿名线程，我可以从服务器内部调用广播方法。如何在线程中调用此方法 class?

在此先感谢您的反馈。

Answer 1

// create new client
NewClient newClient = new NewClient(socket, clientCount, this);

感谢 Johannes Kuhn 指出服务器可以传入线程构造函数调用方法。

Java 线程对象如何调用原始 class 中的方法？

How can a Java thread object call a method from the original class?

java

client

multithreading

client-server

server