基于udp的socket编程小例子之使用多线程进行通信

package udpDemo;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class Send implements Runnable{
	private DatagramSocket ds;
	public Send(DatagramSocket ds)
	{
		this.ds=ds;
	}
	public void run() {
		BufferedReader br=new BufferedReader(new InputStreamReader(System.in)) ;
		String line=null;
		try {
			while( (line=br.readLine())!=null)
			{
				if("886".equals(line))
				{
					break;
				}
			  byte []data=line.getBytes();
			  DatagramPacket dg=new DatagramPacket(data,data.length,InetAddress.getByName("10.5.83.255"),10001);
			  this.ds.send(dg);
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			System.out.println("发送端失败.....");
			e.printStackTrace();
		}
		
	}


}

	

package udpDemo;

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

public class Rece implements Runnable{
	private DatagramSocket ds;
	public Rece(DatagramSocket ds)
	{
		this.ds=ds;
	}
	public void run() {
		  byte []data=new byte[1024];
		  DatagramPacket dp=new DatagramPacket(data,data.length);
		while(true)
		{
		
		 try {
			ds.receive(dp);
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		  String ip= dp.getAddress().getHostAddress();//获取ip地址
		  String line=new String(data,0,dp.getLength());
		  System.out.println("ip:"+ip+",data:"+line);
		}
		
	}
}

package udpDemo;

import java.net.DatagramSocket;
import java.net.SocketException;

/*
编写聊天程序，有收数据的部分， 和发数据的部分。
需要用到多线程技术，一个线程负责收，另外一个线程负责收
因为收和发动作 是不一致的，所以定义两个run方法。
*/
public class chartDemo {
 public static void main(String[] args) {
	try {
		DatagramSocket sendsocket=new DatagramSocket();
		DatagramSocket recesocket=new DatagramSocket(10001);
		new Thread(new Send(sendsocket)).start();
		new Thread(new Rece(recesocket)).start();
	} catch (SocketException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}
}
}