【黑马】程序员————网络编程

/*聊天小程序
 *思路：收发同时执行多线程 
 *
*/
import java.io.*;
import java.net.*;
public class ChatDemo {
    public static void main(String[] args) throws SocketException {
        
        
        new Thread(new Send(new DatagramSocket())).start();
        new Thread(new Receive(new DatagramSocket(10001))).start();
    }

}


class Send implements Runnable { //接收信息线程
    
    private DatagramSocket ds ;  //定义成员变量Socket
    
    Send(DatagramSocket ds) {  //构造方法
        
        this.ds = ds;
    }
    public void run() {  //override run方法
        //键盘输入流
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        String line = null; 
        
        
        try {
            
            while((line = br.readLine()) != null) {  //循环读取键盘输入,readLine方法为阻塞方法
                
                if(line.endsWith("bye"))  //结束标记
                    break; 
                
                byte[] buf = line.getBytes(); //每读一行存入字节数组
                //封包
                DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.1.2"),10001);
                ds.send(dp);//发包
            }
        } catch (Exception e) {
            // TODO Auto-generated catch block
            throw new RuntimeException("send fail");
        }
        
        
        
    }
}

class Receive implements Runnable {
    
private DatagramSocket ds ;
    
    Receive(DatagramSocket ds) {
        
        this.ds = ds;
    }
    
    
    
    public void run() {
        
try {
            
            while(true) {
                
                
                byte[] buf = new byte[1024];  //定义字节数组
                
                DatagramPacket dp = new DatagramPacket(buf, buf.length);//定义接受Packet
                ds.receive(dp);//接收已经存入本方Packet的数据包
                
                String ip = dp.getAddress().getHostAddress();
                String data = new String(dp.getData(),0,dp.getLength());//拆包
                
                System.out.println(ip+"....."+data);
            }
        } catch (Exception e) {
            // TODO Auto-generated catch block
            throw new RuntimeException("send fail");
        }
        
    }
}