Estoy haciendo un chat en java que va de un punto a otro y tengo un error al ejecutar ambos. Cuando los ejecuto uno por uno no hay error, pero cuando lo hago simultáneamente me lanza una excepción ´NullPonterException y cuando quiero cerrar el "Peer 2" no me deja y me lanza una excepción de puntero nulo. No sé si tenga que ver el nombre de los objetos DatagramSocket Les agradecería mucho su ayuda :).
Acá el código
import static java.awt.EventQueue.invokeLater;
import java.awt.*;
import javax.swing.*;
import java.awt.event.*;
import java.net.*;
import java.io.*;
public class Peer extends JFrame
{
private final int PUERTO = 8080;
//Etiquetas
private JLabel etiHost;
private JLabel etiPuerto;
private JLabel etiMensaje;
private JLabel etiMensajeRecibido;
//Campos de texto
private JTextField tfHost;
private JTextField tfPuerto;
private JTextField tfmensaje;
private JTextField tfMensajeRecibido;
//Boton de enviar
private JButton btnEnviar;
//Sockets de emision y recepcion
private DatagramSocket miSocket = null;
//buffer para enviar el mensaje
byte[] mensaje;
public Peer(String nombre)
{
super(nombre);
setSize(300, 300);
setLayout(null);
setDefaultCloseOperation(EXIT_ON_CLOSE);
initComponents();
}
private void initComponents()
{
//etiquetas
etiHost = new JLabel("Host");
etiPuerto = new JLabel("Puerto");
etiMensaje = new JLabel("Mensaje");
etiMensajeRecibido = new JLabel("Mensaje recibido");
//campos de texto
tfHost = new JTextField();
tfPuerto = new JTextField();
tfmensaje = new JTextField();
tfMensajeRecibido = new JTextField();
//botton
btnEnviar = new JButton("Enviar");
getContentPane().add(etiHost);
getContentPane().add(etiPuerto);
getContentPane().add(etiMensaje);
getContentPane().add(etiMensajeRecibido);
getContentPane().add(tfHost);
getContentPane().add(tfPuerto);
getContentPane().add(tfmensaje);
getContentPane().add(tfMensajeRecibido);
getContentPane().add(btnEnviar);
etiHost.setBounds(10, 10, 100, 25);
etiPuerto.setBounds(10, 40, 100, 25);
etiMensaje.setBounds(10, 70, 100, 25);
etiMensajeRecibido.setBounds(10, 100, 100, 25);
tfHost.setBounds(110, 10, 100, 25);
tfPuerto.setBounds(110, 40, 100, 25);
tfmensaje.setBounds(110, 70, 100, 25);
tfMensajeRecibido.setBounds(110, 100, 100, 25);
btnEnviar.setBounds(110, 150, 100, 25);
try
{
miSocket = new DatagramSocket(PUERTO);
}
catch(Exception e)
{
;
}
btnEnviar.addActionListener(new ActionListener()
{
@Override
public void actionPerformed(ActionEvent evt)
{
if(tfHost.getText().equals("") || tfPuerto.getText().equals(""))
JOptionPane.showMessageDialog(null, "Debe ingresar host y/o puerto");
else
{
try
{
enviarMensaje();
}
catch(IOException e)
{
JOptionPane.showMessageDialog(null, "Intente de nuevo. Ocurrió un error en " + e.toString());
}
catch(NumberFormatException e)
{
JOptionPane.showMessageDialog(null, "El puerto debe de ser un numero entero");
}
}
}
});
addWindowListener(new WindowAdapter()
{
@Override
public void windowClosing(WindowEvent evt)
{
miSocket.close();
}
});
try
{
miSocket = new DatagramSocket(PUERTO);
}
catch(Exception e) { ; }
Thread d = new Thread(new Runnable()
{
@Override
public synchronized void run()
{
while(true)
{
try
{
while(true)
{
try
{
miSocket = new DatagramSocket(PUERTO);
}
catch(Exception e) { ; }
byte[] buffer = new byte[1024];
DatagramPacket datagrama = new DatagramPacket(buffer, buffer.length);
miSocket.receive(datagrama);
String mensaje = new String(buffer);
tfMensajeRecibido.setText(mensaje); //para ir incrementando el mensaje
}
}
catch(IOException e)
{
}
}
}
});
d.start();
}
private void enviarMensaje() throws IOException, NumberFormatException
{
try
{
InetAddress miHost = InetAddress.getByName(tfHost.getText());
int miPuerto = Integer.parseInt(tfPuerto.getText());
byte[] buffer = tfmensaje.getText().getBytes();
DatagramSocket miSocket = new DatagramSocket();
DatagramPacket datagrama = new DatagramPacket(buffer, buffer.length, miHost, miPuerto);
miSocket.send(datagrama);
miSocket.close();
}catch(Exception e) { ; }
}
public static void main(String[] args)
{
invokeLater(new Runnable()
{
@Override
public void run()
{
new Peer("Un peer1").setVisible(true);
}
});
}
}
El segundo "PEER"
import static java.awt.EventQueue.invokeLater;
import java.awt.*;
import javax.swing.*;
import java.awt.event.*;
import java.net.*;
import java.io.*;
public class Peer2 extends JFrame
{
private final int PUERTO = 8080;
//Etiquetas
private JLabel etiHost;
private JLabel etiPuerto;
private JLabel etiMensaje;
private JLabel etiMensajeRecibido;
//Campos de texto
private JTextField tfHost;
private JTextField tfPuerto;
private JTextField tfmensaje;
private JTextField tfMensajeRecibido;
//Boton de enviar
private JButton btnEnviar;
//Sockets de emision y recepcion
private DatagramSocket miSocket1 = null;
//buffer para enviar el mensaje
byte[] mensaje;
public Peer2(String nombre)
{
super(nombre);
setSize(300, 300);
setLayout(null);
setDefaultCloseOperation(EXIT_ON_CLOSE);
initComponents();
}
private void initComponents()
{
//etiquetas
etiHost = new JLabel("Host");
etiPuerto = new JLabel("Puerto");
etiMensaje = new JLabel("Mensaje");
etiMensajeRecibido = new JLabel("Mensaje recibido");
//campos de texto
tfHost = new JTextField();
tfPuerto = new JTextField();
tfmensaje = new JTextField();
tfMensajeRecibido = new JTextField();
//botton
btnEnviar = new JButton("Enviar");
getContentPane().add(etiHost);
getContentPane().add(etiPuerto);
getContentPane().add(etiMensaje);
getContentPane().add(etiMensajeRecibido);
getContentPane().add(tfHost);
getContentPane().add(tfPuerto);
getContentPane().add(tfmensaje);
getContentPane().add(tfMensajeRecibido);
getContentPane().add(btnEnviar);
etiHost.setBounds(10, 10, 100, 25);
etiPuerto.setBounds(10, 40, 100, 25);
etiMensaje.setBounds(10, 70, 100, 25);
etiMensajeRecibido.setBounds(10, 100, 100, 25);
tfHost.setBounds(110, 10, 100, 25);
tfPuerto.setBounds(110, 40, 100, 25);
tfmensaje.setBounds(110, 70, 100, 25);
tfMensajeRecibido.setBounds(110, 100, 100, 25);
btnEnviar.setBounds(110, 150, 100, 25);
try
{
miSocket1 = new DatagramSocket(PUERTO);
}
catch(Exception e)
{
;
}
btnEnviar.addActionListener(new ActionListener()
{
@Override
public void actionPerformed(ActionEvent evt)
{
if(tfHost.getText().equals("") || tfPuerto.getText().equals(""))
JOptionPane.showMessageDialog(null, "Debe ingresar host y/o puerto");
else
{
try
{
enviarMensaje();
}
catch(IOException e)
{
JOptionPane.showMessageDialog(null, "Intente de nuevo. Ocurrió un error en " + e.toString());
}
catch(NumberFormatException e)
{
JOptionPane.showMessageDialog(null, "El puerto debe de ser un numero entero");
}
}
}
});
addWindowListener(new WindowAdapter()
{
@Override
public void windowClosing(WindowEvent evt)
{
miSocket1.close();
}
});
try
{
miSocket1 = new DatagramSocket(PUERTO);
}
catch(Exception e) { ; }
Thread c = new Thread(new Runnable()
{
@Override
public synchronized void run()
{
while(true)
{
try
{
while(true)
{
try
{
miSocket1 = new DatagramSocket(PUERTO);
}
catch(Exception e) { ; }
byte[] buffer = new byte[1024];
DatagramPacket datagrama = new DatagramPacket(buffer, buffer.length);
miSocket1.receive(datagrama);
String mensaje = new String(buffer);
tfMensajeRecibido.setText(mensaje); //para ir incrementando el mensaje
}
}
catch(IOException e)
{
}
}
}
});
c.start();
}
private void enviarMensaje() throws IOException, NumberFormatException
{
try
{
InetAddress miHost = InetAddress.getByName(tfHost.getText());
int miPuerto = Integer.parseInt(tfPuerto.getText());
byte[] buffer = tfmensaje.getText().getBytes();
DatagramSocket miSocket1 = new DatagramSocket();
DatagramPacket datagrama = new DatagramPacket(buffer, buffer.length, miHost, miPuerto);
miSocket1.send(datagrama);
miSocket1.close();
}catch(Exception e) { ; }
}
public static void main(String[] args)
{
invokeLater(new Runnable()
{
@Override
public void run()
{
new Peer("Un peer2").setVisible(true);
}
});
}
}