Linux教程網 >> Linux編程 >> Linux編程 >> JAVA 多線程實現聊天（UDP通信）

JAVA 多線程實現聊天（UDP通信）

日期：2017/3/1 11:16:35 编辑：Linux編程

JAVA 多線程實現聊天（UDP通信）

/*
* UDP實現相互傳遞消息
*
*/
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
/*
* 客服端/發送端
*/
class Send implements Runnable{
private DatagramPacket dPacket;
private DatagramSocket dSocket;
public Send(DatagramSocket dSocket)
{
this.dSocket=dSocket;
}
@Override
public void run() {
// TODO Auto-generated method stub
try {
BufferedReader bufferedReader=new BufferedReader(new InputStreamReader(System.in));//從鍵盤讀取數據
String string;
while ((string=bufferedReader.readLine())!=null) {//循環讀取
if (string.equals("Bye"))
{
System.err.println("我下線了");
System.exit(0);
}
byte []buf=string.getBytes();//將輸入的字符串轉換為字節數組
/*
* 獲取本機ＩＰ(外網ＩＰ，我是發送到本機IP,也可以試試其它IP)，然後從本機端口號為18888的端口發送出去
*/
String IP=InetAddress.getLocalHost().getHostAddress().toString();
dPacket=new DatagramPacket(buf, buf.length, InetAddress.getByName(IP), 18888);
dSocket.send(dPacket);
}
} catch (Exception e) {
// TODO: handle exception
System.err.println("發送數據失敗");
e.printStackTrace();
}
}
}
/*
*服務器/ 接受端
*/
class Recive implements Runnable{
private DatagramPacket dPacket;
private DatagramSocket dSocket;
public Recive(DatagramSocket dSocket)
{
this.dSocket=dSocket;
}
@Override
public void run() {
// TODO Auto-generated method stub
while (true) {
byte[] buf=new byte[1024];
dPacket=new DatagramPacket(buf, buf.length);
try {
dSocket.receive(dPacket);
String IP=dPacket.getAddress().getHostAddress();
String data=new String(dPacket.getData(), 0, dPacket.getLength());
int portString=dPacket.getPort();
System.out.println("IP:"+IP+"端口:"+portString+"\n"+data);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
public class test {
/**
* @param args
*/
public static void main(String[] args) throws Exception{
// TODO Auto-generated method stub
new Thread(new Send(new DatagramSocket())).start();
new Thread(new Recive(new DatagramSocket(18888))).start();
}
}