import java.net.*;
import java.io.*;
import java.util.*;
/**
 * <p>Title: 網(wǎng)絡(luò)聊天吧</p>
 * <p>Description: 使用數(shù)據(jù)報(bào)創(chuàng)建的聊天服務(wù)器</p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Filename: ChatServer.java</p>
 * @author 杜江
 * @version 1.0
 */
public class ChatServer{
 static final int PORT = 4000;//設(shè)置服務(wù)端口
 private byte[] buf = new byte[1000];
 private DatagramPacket dgp =new  DatagramPacket(buf,buf.length);
 private DatagramSocket sk;
/**
 *<br>方法說明：服務(wù)端構(gòu)造器，實(shí)現(xiàn)讀取用戶輸入和通訊
 *<br>輸入?yún)?shù)：
 *<br>返回類型：
 */
 public ChatServer(){
   try{
     //實(shí)例化數(shù)據(jù)報(bào)
     sk = new DatagramSocket(PORT);
     System.out.println("Server start.................");
     while(true){
       //等待接收
       sk.receive(dgp);
       //獲取接收信息
       String rcvd = new String(dgp.getData(),0,dgp.getLength())+ 
          ", from address: "+ dgp.getAddress()+
          ", port: "+ dgp.getPort();
       System.out.println(rcvd);
       String outMessage ="";  
        //讀取輸入
         BufferedReader stdin  = new BufferedReader(new InputStreamReader(System.in));
         try{
           outMessage = stdin.readLine();
         }catch(IOException ie){
           System.err.println("IO error!");
         }
       String outString = "Server say: "+ outMessage;
       //拷貝字符到緩存
       byte[] buf = outString.getBytes();
       //打包數(shù)據(jù)，發(fā)送回信息。
       DatagramPacket out = new DatagramPacket(buf,buf.length,dgp.getAddress(),dgp.getPort());
       sk.send(out);
     }
    }catch(SocketException e){
      System.err.println("Can't open socket");
      System.exit(1);
    }catch(IOException e){
     System.err.println("Communication error");
     e.printStackTrace();
     System.exit(1);
    }
 }
 public static void main(String[] args){
   new ChatServer();
 }
}