多线程聊天

package com.phone.week5.day5;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.InetAddress;

public class UDPSendThread extends Thread{

private DatagramSocket ds;
private InetAddress ia;
private int port;
public UDPSendThread(DatagramSocket ds, InetAddress ia, int port) {
super();
this.ds = ds;
this.ia = ia;
this.port = port;
}

@Override
public void run() {
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
while(true){
try {
String line= br.readLine();
byte b[] = line.getBytes();
DatagramPacket dp = new DatagramPacket(b, b.length, ia, port);
ds.send(dp);
} catch (IOException e) {
e.printStackTrace();
}

}
}

}

package com.phone.week5.day5;

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

public class UDPReceiveThread extends Thread{

private DatagramSocket ds ;

public UDPReceiveThread(DatagramSocket ds) {
super();
this.ds = ds;
}

@Override
public void run() {
//创建一个接收的数组
byte b[] = new byte[1024];
//创建一个接收的数据包
DatagramPacket dp = new DatagramPacket(b, b.length);
while(true){
try {
ds.receive(dp);
String str = new String(dp.getData(), 0, dp.getLength());
System.out.println(str);
} catch (IOException e) {
e.printStackTrace();
}
}
}

}

package com.phone.week5.day5;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.SocketException;

import java.net.UnknownHostException;

public class UDPClient1 {

public static void main(String[] args) {
try {
DatagramSocket ds = new DatagramSocket(9999);
new UDPReceiveThread(ds).start();
new UDPSendThread(ds, InetAddress.getByName("localhost"), 5555).start();
} catch (SocketException e) {
e.printStackTrace();
} catch (UnknownHostException e) {
e.printStackTrace();
}
System.out.println("客户1启动了");
}

}

package com.phone.week5.day5;

import java.net.DatagramSocket;

import java.net.InetAddress;

import java.net.SocketException;

import java.net.UnknownHostException;

public class UDPClient2 {

public static void main(String[] args) {
try {
DatagramSocket ds = new DatagramSocket(5555);
new UDPReceiveThread(ds).start();
new UDPSendThread(ds, InetAddress.getByName("localhost"), 9999).start();
} catch (SocketException e) {
e.printStackTrace();
} catch (UnknownHostException e) {
e.printStackTrace();
}
System.out.println("客户2启动了");
}

}