聊天Demo

import java.net.*;
import java.io.*;
class Send implements Runnable 
    {
        private DatagramSocket ds;
        public Send(DatagramSocket ds)
        {
            this.ds=ds;
        }
        
        public void run()
        {
            try{
                BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
                String line = null;
                while((line=bufr.readLine())!=null){
                if("886".equals(line))    
                    break;
                byte[] buf = line.getBytes();
                DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.3.255"),10000);
                ds.send(dp);
                    
                }
                
            }
            catch(Exception e){
                throw new RuntimeException("fasong");
                
            }
        }
    }
    
    
class Rece implements Runnable
    {
        private DatagramSocket ds;
        public Rece(DatagramSocket ds)
        {
            this.ds=ds;
        }
        
        public void run()
        {
            try{
            while(true){
                byte[] buf =new byte[1024];
                DatagramPacket dp =  new DatagramPacket(buf,buf.length);
                ds.receive(dp);
                String ip = dp.getAddress().getHostName();
                String data = new String(dp.getData(),0,dp.getLength());
                System.out.println(ip+": "+data);
            }}
            catch(Exception e){
                throw new RuntimeException("jieshou");
                
            }
        }
    }
    
class ChatDemo 
{
        public static void main(String[] args)throws Exception
        {
            DatagramSocket sendSocket = new DatagramSocket();
            DatagramSocket receSocket = new DatagramSocket(10000);
            new Thread(new Send(sendSocket)).start();
            new Thread(new Rece(receSocket)).start();
        }
    }