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 创建时间：2015年6月1日 下午6:28:05 
 * @version 
 * @parameter  
 * @since  
 * @return  */
public class Server {
	public static void main(String[] args) {
		try {
			//1.创建服务器DatagramSocket
			DatagramSocket socket=new DatagramSocket(8800);
			System.out.println("****服务器已经启动，等待客户端连接");
			//2.创建数据包，用于接收客户端发送的数据
			while(true){
				byte [] data= new byte[1024];
				DatagramPacket packet=new DatagramPacket(data, data.length);
				//3.接收客户端发送的数据
				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 创建时间：2015年6月1日 下午7:16:08 
 * @version 
 * @parameter  
 * @since  
 * @return  */
public class ServerThread extends Thread {
	private DatagramSocket socket;
	private DatagramPacket packet;
	/*
	 * 通过构造方法把套接字和数据包传过来，不要传byte [] data，
	 * 用packet.getData()体现数据是通过数据包传送过来的 
	 */
	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();//返回数据缓冲区
			String info=new String(data,0,packet.getLength());
			System.out.println("我是服务器"+Thread.currentThread()+"，客户端说："+info);
			InetAddress address =packet.getAddress();//得到主机的地址
			int port=packet.getPort();//返回某台远程主机的端口号
			byte []data2="欢迎您！".getBytes();
			DatagramPacket packet2=new DatagramPacket(data2, data2.length,address,port);//发送data2到主机
			socket.send(packet2);
		} catch (SocketException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}			catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
}