JavaUDP簡單的聊天實現(xiàn)

1、Java UDP簡單的聊天軟件用UDP進行通訊，不分客戶端還是服務器，因此一個文件即可搞定。并顯示在文件中主線程用于從控制臺接受輸入，并新開一個線程，用于接受發(fā)送來的消息,控制臺上。第一個客戶端的啟動如下：D:XubuntuMJdpTestXsrcjaua SendClient 127,0-0-1 12345 54321第二個類似，將發(fā)送端口和接收端口反一下就可以了 之后就可以進行通訊了。sendClient.javaimport java.io.BufferedReader;import java.i o.I OExcepti on;import java.i o.ln putStreamR

2、eader;import java .n et.*;public class Sen dClie nt impleme nts Runn ableDatagramSocket sen dSocket, receiveSocket;DatagramPacket sen dPack,receivePack; private In etAddress sen dIP;private int sen dPort,receivePort;private byte in Buf,outBuf;public static final int BUFSIZE = 1024;II無參構(gòu)造函數(shù)，在此函數(shù)中給出了I

3、P,端口的默認值public SendClient() super();try this.se ndIP = In etAddress.getByName(127.0.0.1); catch (UnknownH ostExcepti on e) II TODO Auto-ge nerated catch blocke.pri ntStackTrace(); this.sendPort = 12345; this.receivePort = 54321; this.inBuf = new byteBUFSIZE;/ 構(gòu)造函數(shù)public SendClient(String sendIP, int

4、 sendPort, int receivePort) super();try this.sendIP = InetAddress.getByName(sendIP); catch (UnknownHostException e) / TODO Auto-generated catch block e.printStackTrace(); this.sendPort = sendPort; this.receivePort = receivePort; this.inBuf = new byteBUFSIZE;/ 創(chuàng)建的新的線程用于不停的接收信息，如果有新的信息來到，則顯示在控制臺上 Over

5、ridepublic void run() String msg ;/ TODO Auto-generated method stubtry this.receiveSocket = new DatagramSocket(receivePort);this.receivePack = new DatagramPacket(inBuf,BUFSIZE); catch (SocketException e) / TODO Auto-generated catch blocke.printStackTrace();while(true)try receiveSocket.receive(receiv

6、ePack); catch (IOException e) / TODO Auto-generated catch block e.printStackTrace();msg = new String(receivePack.getData(),0,receivePack.getLength();System.out.println(nreceive message:+msg);newpublic void sendMessage(String msg) this.outBuf = msg.getBytes(); this.sendPack = DatagramPacket(this.outB

7、uf,this.outBuf.length,this.sendIP ,this.sendPort); try this.sendSocket = new DatagramSocket(); sendSocket.send(sendPack); catch (SocketException e) / TODO Auto-generated catch block e.printStackTrace(); catch(IOException e) e.printStackTrace();/ 從控制臺接受三個參數(shù)/ 第一個參數(shù)為需要連接的主機的 IP/ 第二個參數(shù)為向主機發(fā)送的端口號/ 第三個參數(shù)為

8、本機接受信息的端口號 public static void main(String args) if(args.length=0) return ;String ip = args0;int sendPort = Integer.parseInt(args1);int receivePort = Integer.parseInt(args2);/ 創(chuàng)建通訊類，并啟動線程/ 創(chuàng)建的新的線程用于不停的接收信息，如果有新的信息來到，則顯示在控制臺 上/ 主線程用于接收輸入 SendClient sc = new SendClient(ip,sendPort,receivePort); (new Thread(sc).start();BufferedReader br=new BufferedReader(new InputStreamReader(System.in); System.out.println(press the enter to send message:);while(true) /System.out.print(write in:); String msg=; try msg = br.readLine();if(msg.equ