udpthread.java

局域网聊天的小程序

package day16;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class UDPThread extends Thread {

	private DatagramSocket ds;
	public UDPThread(DatagramSocket ds){
		this.ds=ds;
	}
	
	public void run(){
		try {
			while(true){
				byte[] mes=new byte[100];
				DatagramPacket dp=new DatagramPacket(mes,mes.length);
				ds.receive(dp);
				System.out.println(new String(dp.getData(),dp.getOffset(),dp.getLength()));
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}