0

buenos dias estoy haciendo un chat donde el objetivo es enviar un mensaje de un cliente a un servidor y del servidor a todos los clientes. esta ultima parte es la que no logro hacer.es decir que reenvie el mensaje a todos los clientes.

les dejo el codigo y escucho consejos.

package Cliente;

import java.awt.BorderLayout;
import java.awt.EventQueue;
import java.io.IOException;
import java.net.Socket;

import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.border.EmptyBorder;
import javax.swing.JButton;
import javax.swing.JTextArea;
import javax.swing.JScrollPane;
import javax.swing.JTextField;

public class Cliente extends JFrame {

    private Socket socket;
    private PanelCliente panel;

    public Cliente(int puerto) {

        try {
            panel = new PanelCliente();

            socket = new Socket("localhost", puerto);

            Runnable cliente =  new HiloCliente(socket, panel);
            Thread hilo = new Thread(cliente);
            hilo.start();

        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {

        Cliente frame = new Cliente(10000);

    }
}
------------------------------------------------------------------------

package Cliente;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

import javax.swing.JPanel;

public class HiloCliente implements Runnable {

    private DataInputStream entrada;
    private DataOutputStream salida;
    private PanelCliente panel;
    private Socket socket;

    public HiloCliente(Socket socket, PanelCliente panel) {
        this.socket= socket;
        this.panel = panel;
        try {
            entrada = new DataInputStream(this.socket.getInputStream());
            salida = new DataOutputStream(this.socket.getOutputStream());


            this.panel.getBtnEnviar().addActionListener(new ActionListener() {

                @Override
                public void actionPerformed(ActionEvent arg0) {
                    try {
                        salida.writeUTF(panel.getTexto());
                        HiloCliente.this.panel.setTextField("");
                    } catch (IOException e) {

                        e.printStackTrace();
                    }

                }
            });
        } catch (IOException e) {

            e.printStackTrace();
        }

    }

    @Override
    public void run() {

        while (true) {
            try {

                String texto = entrada.readUTF();
                System.out.println(texto);
                panel.agregarTexto(texto);
                panel.agregarTexto("\n");

            } catch (IOException e) {
                e.printStackTrace();
            }
        }

    }

}
-----------------------------------------------------------------------------
package Cliente;

import java.io.Serializable;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.border.EmptyBorder;

public class PanelCliente extends JFrame implements Serializable {
    private JPanel contentPane;
    private JTextField textField;
    private JTextArea textArea;
    private JButton btnEnviar;
    private JScrollPane scrollPane;

    public PanelCliente() {
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        setBounds(100, 100, 450, 300);
        contentPane = new JPanel();
        contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
        contentPane.setLayout(null);
        setContentPane(contentPane);

        btnEnviar = new JButton("Enviar");
        btnEnviar.setBounds(171, 195, 89, 23);
        contentPane.add(btnEnviar);

        textArea = new JTextArea();


        scrollPane = new JScrollPane(textArea);
        scrollPane.setBounds(40, 11, 350, 151);
        contentPane.add(scrollPane);

        textField = new JTextField();
        textField.setBounds(32, 196, 86, 20);
        contentPane.add(textField);
        textField.setColumns(10);

        setVisible(true);
    }

    public void setTextField(String string) {
        this.textField.setText(string);
    }

    public String getTexto() {
        return textField.getText();

    }

    public JButton getBtnEnviar() {
        return btnEnviar;
    }

    public void agregarTexto(String texto) {
        textArea.append(texto);
    }




}
------------------------------------------------------------------------------
package Servidor;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.LinkedList;

import javax.swing.DefaultListModel;
import javax.swing.JFrame;

public class Servidor {

    private ServerSocket serversocket;
    private int puerto;
    boolean corriendo = true;
    private PanelServidor panel;
    private static int idCliente;
    private LinkedList<HiloServidor> Clientes;

    public Servidor(int puerto) {

        Clientes = new LinkedList<HiloServidor>();
        this.puerto = puerto;
        panel = new PanelServidor();

        Socket conexion = null;

        try {

            serversocket = new ServerSocket(this.puerto);

            while (true) {
                conexion = serversocket.accept();
                //HiloServidor cliente = new HiloServidor(conexion, panel, ++idCliente);
                Runnable hiloNuevoCliente = new HiloServidor(conexion, panel, ++idCliente);
                Thread hilo = new Thread(hiloNuevoCliente);
                hilo.start();
                //Clientes.add(cliente);
            }
        } catch (IOException e) {
            e.printStackTrace();

        }

    }

    public static void main(String[] args) {

        Servidor server = new Servidor(10000);
    }
}
--------------------------------------------------------------------------
package Servidor;

import java.io.DataInputStream;
import java.io.DataOutput;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.LinkedList;

import javax.swing.DefaultListModel;
import javax.swing.event.ListDataEvent;
import javax.swing.event.ListDataListener;

public class HiloServidor implements Runnable {

    private Socket socket;
    private PanelServidor panel;
    private DataInputStream entrada;
    private DataOutputStream salida;
    private int idCliente;
    private Socket socketReenvio;

    public HiloServidor(Socket socket, PanelServidor panel, int idCliente) {
        this.socket = socket;
        this.panel = panel;
        this.idCliente = idCliente;

        try {
            salida = new DataOutputStream(this.socket.getOutputStream());
            entrada = new DataInputStream(this.socket.getInputStream());


        } catch (IOException e) {

            e.printStackTrace();
        }

    }

    @Override
    public void run() {

        while (true) {
            try {
                String texto = entrada.readUTF();

                panel.getTextArea().append("cliente " + idCliente + ": " + texto);
                panel.getTextArea().append("\n");

                salida.writeUTF(texto);

            } catch (IOException e) {

                e.printStackTrace();
            }
        }

    }

}

------------------------------------------------------------------------------
package Servidor;

import java.awt.BorderLayout;
import java.awt.EventQueue;

import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.border.EmptyBorder;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;

public class PanelServidor extends JFrame {

    private JPanel contentPane;
    private JTextArea textArea;
    private JScrollPane scrollPane;

    public PanelServidor() {
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        setBounds(100, 100, 450, 300);
        contentPane = new JPanel();
        contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
        contentPane.setLayout(null);
        setContentPane(contentPane);

        textArea = new JTextArea();

        scrollPane = new JScrollPane(textArea);
        scrollPane.setBounds(68, 41, 257, 142);
        contentPane.add(scrollPane);

        setVisible(true);

    }

    public JTextArea getTextArea() {
        return textArea;
    }


}

1 respuesta 1

1

lo solucione haciendo lo siguiente : public Servidor(int puerto) {

    Clientes = new LinkedList<HiloServidor>();
    this.puerto = puerto;
    panel = new PanelServidor();

    Socket conexion = null;

    try {

        serversocket = new ServerSocket(this.puerto);

        while (true) {
            conexion = serversocket.accept();
            HiloServidor cliente = new HiloServidor(conexion, panel, ++idCliente);
            Clientes.add(cliente);
            cliente.setClientes(Clientes);
            Thread hilo = new Thread(cliente);
            hilo.start();

        }
    } catch (IOException e) {
        e.printStackTrace();

    }

}

public HiloServidor(Socket socket, PanelServidor panel, int idCliente) { this.socket = socket; this.panel = panel; this.idCliente = idCliente;

    try {
        salida = new DataOutputStream(this.socket.getOutputStream());
        entrada = new DataInputStream(this.socket.getInputStream());


    } catch (IOException e) {

        e.printStackTrace();
    }

}


public void setClientes(LinkedList<HiloServidor> clientes) {
    Clientes = clientes;
}


@Override
public void run() {

    while (true) {
        try {
            String texto = entrada.readUTF();

            panel.getTextArea().append("cliente " + idCliente + ": " + texto);
            panel.getTextArea().append("\n");

            for(HiloServidor c:Clientes) {
            c.salida.writeUTF(texto);
            }
        } catch (IOException e) {

            e.printStackTrace();
        }
    }

}

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge you have read our privacy policy.

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.