黑马程序员-JAVA学习之用多线程实现简单UDP聊天程序

--------android培训、java培训、期待与你交流！--------

一般的聊天程序由于追求快捷的数据传输速度，而又不是比较关注数据的完整性，都是用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编程和多线程，就只好怎么简单怎么来了。