Передача сообщения всем подключенным клиентам

package simplenetserver;
 
/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
 
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Scanner;
import java.util.logging.Level;
import java.util.logging.Logger;
 
/**
 *
 * @author Yosido */
public class Main extends Thread {
 
    private static ServerSocket ServSock;
    private ArrayList<InputStream> m_is_is = null;
    private ArrayList<OutputStream> m_ou_out = null;
    private int clientCount = 0;
    public Main()
    {
            m_is_is= new ArrayList<InputStream>();
            m_ou_out=new ArrayList<OutputStream>();
    }
 
    public void spam(String arg) throws IOException
    {
     for(int i=0;i<m_ou_out.size();i++)
        {
           DataOutputStream send= new DataOutputStream(m_ou_out.get(i));
           send.writeUTF(arg);
           System.out.println("send");
           System.out.println(i);
        }
    }
 
public void run(){
        try {
            Socket Sock = ServSock.accept();
            System.out.print("client connectec ");
            clientCount++;
            System.out.println(clientCount);
            System.out.println(Sock.getInetAddress().toString());
            InputStream m_is = Sock.getInputStream();
            OutputStream m_out = Sock.getOutputStream();
            DataInputStream qwe = new DataInputStream(m_is);
            DataOutputStream toClient= new DataOutputStream(m_out);
            m_is_is.add(m_is);
            m_ou_out.add(m_out);
            System.out.println(m_ou_out.size());
            new Main().start();
 
            while(true)
            {
                Scanner in=new Scanner(System.in);
                String send=in.nextLine();
                spam(send);
            }
        } catch (IOException ex) {
            Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
        }
}
    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) {
        try {
            // TODO code application logic here
            ServSock = new ServerSocket(3333);
        } catch (IOException ex) {
            Logger.getLogger(Main.class.getName()).log(Level.SEVERE, null, ex);
        }
        new Main().start();
 
    }
 
}

class SuperServer extends Thread {
  List<ServerWorker> workerList;
  ....
  public void run() {
    while (isRunning) {
      Socket client = serverSocket.accept();
      ServerWorker worker = new ServerWorker(client, this);
      workerList.add(worker);
      worker.start();
    }
  }
  public void sendToAll(String text) {
    for (ServerWorker currentWorker: workerList) {
      currentWorker.sendText(text);
    }
  }
}

class ServerWorker extends Thread {
  private SuperServer superServer;
  private Socket socket;
......
    superServer.sendToAll("test 12345");
}

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
 
package newpackage;
 
/**
 *
 * @author Yosido
 */
/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
 
import java.io.*;
import java.net.*;
 
class SServer extends Thread {
   private Socket socket;
   private DataInputStream in;
   private DataOutputStream out;
 
   public SServer(Socket s) throws IOException {
      socket = s;
      in = new DataInputStream(socket.getInputStream());
      out = new DataOutputStream(socket.getOutputStream());
      start();
   }
 
   public void run() {
      try {
         while (true) {
            String str = in.readLine();
            if (str.equals("END"))
               break;
            System.out.println("Echoing: " + str);
            out.writeUTF(str);
            out.flush();
         }
         System.out.println("closing...");
      }
      catch (IOException e) {
         System.err.println("IO Exception");
      }
      finally {
         try {
            socket.close();
         }
         catch (IOException e) {
            System.err.println("Socket not closed");
         }
      }
   }
}
 
public class MultiServer {
   static final int PORT = 3434 ;
   static int clientCount = 0 ;
   public static void main(String[] args) throws IOException {
      ServerSocket s = new ServerSocket(PORT);
      System.out.println("Server Started");
      try {
         while (true) {
            Socket socket = s.accept();
            try {
               new SServer(socket);
               clientCount++;
               System.out.println(clientCount+" клиентов");
            }
            catch (IOException e) {
               socket.close();
            }
         }
      }
      finally {
         s.close();
      }
   }
}

Socket socket = s.accept();
            try {
               new SServer(socket);
               clientCount++;
               System.out.println(clientCount+" клиентов");
            }

new MultiServer().start();

public class Main {
    public static void main(String[] args) throws IOException {
        MultiServer ms=new MultiServer();
    }
}

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Vector;
 
/**
 *
 * @author Yosido
 */
public class MultiServer {
   static final int PORT = 3434 ;
   static int clientCount = 0 ;
   static Vector<SServer> m_v_theads;
   static SServer m_thread;
 
    public MultiServer() throws IOException
    {
      m_v_theads=new  Vector<SServer>();
      ServerSocket s = new ServerSocket(PORT);
      System.out.println("Server Started");
      try {
         while (true) {
            Socket socket = s.accept();
            try {
               m_thread=new SServer(socket);
               clientCount++;
               System.out.println(clientCount+" клиентов");
               //m_thread.start();
               System.out.println("2");
               m_v_theads.add(m_thread);
               //m_thread.start();
               System.out.println("added"+ m_v_theads.size());
            }
            catch (IOException e) {
               socket.close();
            }
         }
      }
      finally {
         s.close();
      }
   }
}

import java.io.*;
import java.net.*;
import java.util.Vector;
/**
 *
 * @author Yosido
 */
class SServer extends Thread {
   private Socket socket;
   private DataInputStream in;
   private DataOutputStream out;
 
   public SServer(Socket s) throws IOException {
      socket = s;
      in = new DataInputStream(socket.getInputStream());
      out = new DataOutputStream(socket.getOutputStream());
      start();
   }
 
   public void run() {
      try {
         while (true) {
            String str = in.readUTF();
            if (str.equals("END"))
               break;
            System.out.println("Echoing: " + str);
            out.writeUTF(str);
            out.flush();
         }
         System.out.println("closing...");
      }
      catch (IOException e) {
         System.err.println("IO Exception");
      }
      finally {
         try {
            socket.close();
         }
         catch (IOException e) {
            System.err.println("Socket not closed");
         }
      }
   }
}