JAVA學習之用多線程實現簡單UDP聊天程序

 

一般的聊天程序由於追求快捷的數據傳輸速度，而又不是比較關注數據的完整性，都是用UDP協議來傳遞數據，

而且聊天程序在發送信息的時候，也可以同時進行信息的接收功能，就好像QQ一樣，我們可以在下面的輸入框慢慢打字發信息，但是上面的信息框卻是在同時接收信息，

要在一個程序里面實現這種功能，就要用到了多線程了，其中一個線程用來專門接收數據，一個純種用來專門發送數據，像QQ一樣的估計還有線程專門用來處理視頻和文件傳輸等。

下面利用JAVA的多線程和UDP網絡功能實現一個簡單的聊天程序，其中主要涉及到四個類，一個是接收信息的類，一個是發送信息的類，這兩個類我們到時在主函數中用多線程來執行，

還有兩個類，也就是兩個具有main函數的聊天窗口程序，兩個簡單的控制台程序。

其中全部的代碼如下：

//
import java.io.*;
import java.net.*;
//發送的類
class Send implements Runnable
{
private DatagramSocket ds;
private int recePort;// 接收端的端口。即要把數據發送到那個端口
public Send(DatagramSocket ds, int port)
{
this.ds = ds;
this.recePort = port;
}
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("127.0.0.1"), this.recePort);
ds.send(dp);
}
} catch (Exception e)
{
throw new RuntimeException("send failure");
}
}
}
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().getHostAddress();
int port = dp.getPort();
String data = new String(dp.getData(), 0, dp.getLength());
System.out.println("來自ip為：" + ip + " 端口為：" + port + "的信息為：" + data);
}
} catch (Exception e)
{
throw new RuntimeException("Rece failure");
}
}
}
class ChatDemoA
{
public static void main(String[] args) throws Exception
{
DatagramSocket sendSocket = new DatagramSocket();
DatagramSocket receSocket = new DatagramSocket(10000);// 偵聽10000端口
new Thread(new Send(sendSocket, 10001)).start();// 把數據發往10001端口
new Thread(new Rece(receSocket)).start();
}
}
class ChatDemoB
{
public static void main(String[] args) throws Exception
{
DatagramSocket sendSocket = new DatagramSocket();
DatagramSocket receSocket = new DatagramSocket(10001);// 偵聽10001端口
new Thread(new Send(sendSocket, 10000)).start();// 把數據發住10000商品
new Thread(new Rece(receSocket)).start();
}
}

在這里，一個程序偵聽10000端口，如果有信息就發往10001端口，

另一個程序就偵聽10001端口，然后把信息回發10000端口，以實現數據交流的功能，

其中兩個程序的接收信息和發送信息都用新的分別線程執行

當ChatDemoA把信息發送到10001端口的時候，偵聽端口10001的ChatDemoB就接收到了信息，並顯示出來，

同樣，當ChatDemoB把信息發送到10000端口的時候，偵聽端口10000的ChatDemoA也會接收到信息，也顯示出來，

由於兩個程序發送信息的DatagramSocket沒有綁定端口，所以發送的信息的端口是隨機的。

以下是程序執行時候的截圖：

 

另一個程序ChatDemoB執行時候的截圖

 

如果想要有更好的體驗，其實不應該把端口寫死的，應該是運行時獲取到的，不過為了簡單體現UDP編程和多線程，就只好怎么簡單怎么來了。