package?com.guoke2;

import?java.io.IOException;
import?java.net.DatagramPacket;
import?java.net.DatagramSocket;
import?java.net.InetAddress;
import?java.net.Socket;
import?java.net.SocketException;

/**?*?@author??guokewind?
?*?@date?創(chuàng)建時(shí)間：2015年6月1日?下午6:28:05?
?*?@version?
?*?@parameter??
?*?@since??
?*?@return??*/
public?class?Server?{
	public?static?void?main(String[]?args)?{
		try?{
			//1.創(chuàng)建服務(wù)器DatagramSocket
			DatagramSocket?socket=new?DatagramSocket(8800);
			System.out.println("****服務(wù)器已經(jīng)啟動(dòng)，等待客戶(hù)端連接");
			//2.創(chuàng)建數(shù)據(jù)包，用于接收客戶(hù)端發(fā)送的數(shù)據(jù)
			while(true){
				byte?[]?data=?new?byte[1024];
				DatagramPacket?packet=new?DatagramPacket(data,?data.length);
				//3.接收客戶(hù)端發(fā)送的數(shù)據(jù)
				socket.receive(packet);
				ServerThread?serverThread=new?ServerThread(socket,packet);
				serverThread.start();
				}
		}?
		catch?(SocketException?e)?{
			//?TODO?Auto-generated?catch?block
			e.printStackTrace();
		}			catch?(IOException?e)?{
			//?TODO?Auto-generated?catch?block
			e.printStackTrace();
		}
	}
}

package?com.guoke2;

import?java.io.IOException;
import?java.net.DatagramPacket;
import?java.net.DatagramSocket;
import?java.net.InetAddress;
import?java.net.SocketException;

/**?*?@author??guokewind?
?*?@date?創(chuàng)建時(shí)間：2015年6月1日?下午7:16:08?
?*?@version?
?*?@parameter??
?*?@since??
?*?@return??*/
public?class?ServerThread?extends?Thread?{
	private?DatagramSocket?socket;
	private?DatagramPacket?packet;
	/*
	?*?通過(guò)構(gòu)造方法把套接字和數(shù)據(jù)包傳過(guò)來(lái)，不要傳byte?[]?data，
	?*?用packet.getData()體現(xiàn)數(shù)據(jù)是通過(guò)數(shù)據(jù)包傳送過(guò)來(lái)的?
	?*/
	public?ServerThread(DatagramSocket?socket,DatagramPacket?packet){
		this.socket=socket;
		this.packet=packet;
	}
	@Override
	public?void?run()?{
		//?TODO?Auto-generated?method?stub
		super.run();
		try{
			byte?[]?data=packet.getData();//返回?cái)?shù)據(jù)緩沖區(qū)
			String?info=new?String(data,0,packet.getLength());
			System.out.println("我是服務(wù)器"+Thread.currentThread()+"，客戶(hù)端說(shuō)："+info);
			InetAddress?address?=packet.getAddress();//得到主機(jī)的地址
			int?port=packet.getPort();//返回某臺(tái)遠(yuǎn)程主機(jī)的端口號(hào)
			byte?[]data2="歡迎您！".getBytes();
			DatagramPacket?packet2=new?DatagramPacket(data2,?data2.length,address,port);//發(fā)送data2到主機(jī)
			socket.send(packet2);
		}?catch?(SocketException?e)?{
			//?TODO?Auto-generated?catch?block
			e.printStackTrace();
		}			catch?(IOException?e)?{
			//?TODO?Auto-generated?catch?block
			e.printStackTrace();
		}
		
	}
}