udpserverdemo.java

联系方式 [e-mail]

/*
 * UDPServerDemo.java
 *
 * Created on 2007年12月22日, 上午10:10
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package happychat;
import java.net.*;
import java.io.*;
import java.util.*;
/**
 *基于UDP的服务器端程序
 * @author 范方青
 */
public class UDPServerDemo {
    static final int PORT = 4000;
    private byte[] buf = new byte[1000];
    private DatagramPacket dgp = new DatagramPacket(buf,buf.length);
    private DatagramSocket sk;
    public UDPServerDemo() {
        try{
            sk = new DatagramSocket(PORT);
            System.out.println("server start......");
            while(true){
                sk.receive(dgp);
                String strReceived = "("+dgp.getAddress()+":"+dgp.getPort()+")"+new String(dgp.getData(),0,dgp.getLength());
                System.out.println(strReceived);
                String strOutMess = "";
                BufferedReader stdin = new BufferedReader(new InputStreamReader(System.in));
                try{
                    strOutMess = stdin.readLine();
                }catch(IOException ie){
                    System.err.println("输入输出错误！");
                }
                String strOutput = "[server say]:"+strOutMess;
                byte[] buf = strOutput.getBytes();
                DatagramPacket out = new DatagramPacket(buf,buf.length,dgp.getAddress(),dgp.getPort());
                sk.send(out);
            }
        }catch(SocketException e){
            System.err.println("打开套字节错误！");
            System.exit(1);
        }catch(IOException e){
            System.err.println("数据传输错误！");
            e.printStackTrace();
            System.exit(1);
        }
    }
    public static void main(String [] args){
        new UDPServerDemo();
    }
}