Требуется помощь сервера и связанного списка

Question

По сути, я построил сокет-сервер, к которому могут подключаться несколько клиентов, и когда они отправляют сообщение на сервер, оно отправляется каждому другому клиенту. Проблема в том, что он еще не работает. Мне нужно отсортировать «SingletonClients» и «getClients», чтобы они возвращали всех подключенных пользователей, готовых для меня, чтобы отправлять им сообщения. Это только основная проблема, но я понятия не имею, как это сделать, и это самая последняя часть студенческого проекта, которую я делаю (основная часть - это клиент Obj-C, а не Java-сервер). Если бы кто-нибудь мог сделать это для меня, я был бы вечно благодарен.

Вот код на данный момент:

import java.awt.Color;
import java.awt.BorderLayout;
import java.awt.event.*;
import javax.swing.*;
import java.util.LinkedList;
import java.io.*;
import java.net.*;

class ClientWorker implements Runnable {
    private Socket client;
    private JTextArea textArea;
    BufferedReader in = null;
    PrintWriter out;

    ClientWorker(Socket client, JTextArea textArea) {
        this.client = client;
        this.textArea = textArea;  

        String line = in.readLine();
        LinkedList<ClientWorker> clients = SingletonClients.getClients();
        for(int i = 0; i < clients.size(); i++) {
            ClientWorker c = clients.get(i);
            //The client doesn't need to get it's own data back.
            if(c == this){
                continue;
            }
            c.writeString(line);
        }

    }

    public void writeString(String s) {
        try {
            out.println(s);
        } catch(IOException ex) {
        }
    }

    public void run(){
        String line;
        out = null;
        try{
            in = new BufferedReader(new InputStreamReader(client.getInputStream()));
            out = new PrintWriter(client.getOutputStream(), true);
        } catch (IOException e) {
            System.out.println("in or out failed");
            System.exit(-1);
        }

        while(true){
            try{
                line = in.readLine();
                //Send data back to client
                out.println(line);
                textArea.append(line);
            } catch (IOException e) {
                System.out.println("Read failed");
                System.exit(-1);
            }
        }
    }
}

class SocketThrdServer extends JFrame{

    JLabel label = new JLabel("Text received over socket:");
    JPanel panel;
    JTextArea textArea = new JTextArea();
    ServerSocket server = null;

    SocketThrdServer(){ //Begin Constructor
        panel = new JPanel();
        panel.setLayout(new BorderLayout());
        panel.setBackground(Color.white);
        getContentPane().add(panel);
        panel.add("North", label);
        panel.add("Center", textArea);
    } //End Constructor

    public void listenSocket(){
        try{
            server = new ServerSocket(4444); 
        } catch (IOException e) {
            System.out.println("Could not listen on port 4444");
            System.exit(-1);
        }
        while(true){
            ClientWorker w;
            try{
                w = new ClientWorker(server.accept(), textArea);
                Thread t = new Thread(w);
                t.start();
            } catch (IOException e) {
                System.out.println("Accept failed: 4444");
                System.exit(-1);
            }
        }
    }

    protected void finalize(){
        //Objects created in run method are finalized when 
        //program terminates and thread exits
        try{
            server.close();
        } catch (IOException e) {
            System.out.println("Could not close socket");
            System.exit(-1);
        }
    }

    public static void main(String[] args){
        SocketThrdServer frame = new SocketThrdServer();
        frame.setTitle("Server Program");
        WindowListener l = new WindowAdapter() {
            public void windowClosing(WindowEvent e) {
                System.exit(0);
            }
        };
        frame.addWindowListener(l);
        frame.pack();
        frame.setVisible(true);
        frame.listenSocket();
    }
}

Заранее спасибо!

Answer 1

LinkedList<ClientWorker> clients = SingletonClients.getClients();

Поскольку кажется, что вам нужно что-то, что возвращает коллекцию ClientWorker, я предлагаю вам просмотреть свой код и найти место, где вы создаете ClientWorkers, и попробовать поместить их в коллекцию.

Имеет ли это смысл?

Answer 2

Вы хотите обратить внимание на начало вашего ClientWorker класса. В разделе объявления ваших полей вы объявляете некоторые элементы экземпляра, например, так:

BufferedReader in = null;
PrintWriter out;

но затем в вашем конструкторе вы пытаетесь использовать их без предварительной инициализации:

    String line = in.readLine(); //will throw a NullPointerException
    LinkedList<ClientWorker> clients = SingletonClients.getClients();
    for(int i = 0; i < clients.size(); i++) {
        ClientWorker c = clients.get(i);
        //The client doesn't need to get it's own data back.
        if(c == this){
            continue;
        }
        c.writeString(line); //calls out.println, will throw a NullPointerException
    }

Что касается вашего SingletonWorker, если это часть проекта, вас, вероятно, просят сделать синглтон на Java. Это не имеет большого значения, но очевидно, что вам нужно обеспечить одну вещь - разрешить создание только одного экземпляра вашего Singleton в течение всего жизненного цикла. Взгляните здесь за некоторыми идеями. Если, с другой стороны, SingletonWorker является разработанным вами помощником, вам лучше последовать примеру @ willcodejavaforfood и создать безопасный для типов LinkedList.