class ThreadServer extends Thread {
private UDPProjektNeu udp;
public boolean running;
public ThreadServer(UDPProjektNeu udp){
this.udp = udp;
}
public void shutDown(){
running = false;
}
public void run(){
running = true;
DatagramSocket socket = null;
try {
socket = new DatagramSocket(5001);
}
catch (SocketException e) {
try {
socket = new DatagramSocket();
}
catch (SocketException e1) {
}
}
while(running==true){
byte[] inData = new byte[1024];
String message;
DatagramPacket in = new DatagramPacket(inData, inData.length);
try {
socket.receive(in);
} catch (IOException e) {
running = false;
socket.close();
udp.chatArea.append("Packet konnte nicht empfangen werden");
}
String senderName = in.getAddress().getHostName();
message = new String(in.getData(),0,in.getLength());
SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
String uhrzeit = sdf.format(new Date());
udp.chatArea.append(uhrzeit +" "+ senderName+":"+"\r\n" +message+"\r\n");
}
socket.close();
}
