Форум программистов [Powered by Invision Power Board]

Код

import java.awt.FlowLayout;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import java.util.ArrayList;
import java.util.Scanner;
import javax.swing.*;


public class ServerTest {
    ServerTest(){
        JFrame frame = new JFrame("сервер");
        JPanel panel = new JPanel();
        
        JButton button1 = new JButton("одному");
        JButton button2 = new JButton("всем");
        
        button1.addActionListener( new ActionListener(){
        public void actionPerformed(ActionEvent arg0) {
            for(Chat client: clientList){
                System.out.println(client.sock.getPort());
            }
            int port = Integer.parseInt(
                    JOptionPane.showInputDialog(
                            "Введите порт i-го клиента!"));
            for(Chat client:clientList){
                if(client.sock.getPort()==port){
                    client.out.println("Server! massege");
                }
            }
            }});
        button2.addActionListener(new ActionListener(){
        int i = 0;
        public void actionPerformed(ActionEvent arg0) {
            i++;
            System.out.println("Server!{massege №"+i+"}\n");
            for(Chat client: clientList){
                client.out.println("Server! massege №"+i);
            }
        }});
        panel.setLayout(new FlowLayout(FlowLayout.LEFT));
        panel.add(button1);
        panel.add(button2);
        frame.add(panel);
        frame.pack();
        frame.setVisible(true);
        
        try {
            
            ServerSocket sock = new ServerSocket(9999);
            int i=0;
            while(true){
                Socket s = sock.accept();
                t = new Chat(s,(++i));
                clientList.add((Chat) t);
                t.start();
                System.out.println("Вход. Клиент "+i+": "+s.getPort());
            }
        } catch (IOException e) {e.printStackTrace();}
    }

    public static void main(String[] args) {
        new ServerTest();
    }
    
    static ArrayList<Chat> clientList =  new ArrayList<Chat>();
    static Thread t;
}
class Chat extends Thread{
    Chat(Socket sock,int i){
        this.sock = sock;
        this.i = i;
    }
    Socket getSocket(){
        return sock;
    }
    int getIndex(){
        return i;
    }
    
    public void run() {
        try {
            in = new Scanner(sock.getInputStream());
            out = new PrintWriter(sock.getOutputStream(),true);
            
            out.println( "Hello! Enter BYE to exit." );
            
            while (true)
            { 
                String str = in.nextLine();
                if (str != null) 
                {
                    out.println("Echo (" + i + "): " + str);
                    System.out.println("Клиент " + i + ": " + str);
                    if (str.trim().equals("BYE"))
                     break;
                }
            }
        } catch (IOException e) {e.printStackTrace();}
        finally{
            
            in.close();
            out.close();
            try {
                Disconnect(sock.getPort());
                sock.close();
            } catch (IOException e) {e.printStackTrace();}
        }
    }
    
    void Disconnect(int port){
        
        ArrayList<Chat> newList =  new ArrayList<Chat>();
        for(Chat client: ServerTest.clientList){
            if(client.sock.getPort() != port){
                newList.add(client);
            }
        }
        ServerTest.clientList = newList;
        ServerTest.t.stop();
    }
    private Scanner in;
    private int i = 0;
    Socket sock;
    PrintWriter out;
}