本文最后更新于446 天前，其中的信息可能已经过时，如有错误请发送邮件到echobydq@gmail.com
Java实现聊天室功能
前提
1. UDP(用户数据报协议)
使用UDP协议时，在客户和服务器程序都可以放置一个DatagramSocket(数据报套接字)，DatagramSocket 用于收发数据包，而DaragramPacket包含了具体的信息。准备接收一个数据报时，只需提供一个缓冲区，以便安置接收到的数据。数据包抵达时，通过DatagramSocket，作为信息起源地的因特网地址以及端口编号会自动得到
2. IntAddress类
用于描述和包装一个Internet IP 地址，通过三个方法返回 InetAddress 实例
3. Swing类 和 AWT
构建图形界面
服务器端
1. 发送/接收消息
创建 DatagramSocket 对象用于打开指定端口并监听，然后用创建一个 DatagramPacket，利用 DatagramSocket 中的 receive（ds）方法接收数据并放到刚创建的 DatagramPacket 对象中
2. 客户端和服务器端聊天
编写一个简单的聊天图形界面，并在构造函数中用已经创建好的DatagramSocket对象打开特点的端口监听，并用Thread开启Runnable线程。重写run（）函数，将接受数据的receive函数写在这里，使程序在任何时候都能够接收客户端发送的数据， 注意数据中包含客户端的IP地址，将它保存起来。另外加一个按钮实现服务器端发送数据，过程和上述客户端发送数据差不多，区别在于上述客户端和服务器端已经connect而现在没有，所以创建DatagramPacket对象使需要在后面加上已经保存的客户端IP地址，然后用send发送数据
3. 客户端和客户端聊天
服务器端不需要知道有多少客户端要连接，所以就不需要多个线程负责接收客户端连接。服务器端不知道客户端什么时候需要连接，所以就需要开启一个线程来接受客户端发送的消息，注意只需要一个线程即可。服务器端收到消息后，需要发给各个客户端，这就需要发送客户端的IP地址，我们知道用receive（）方法可以接受数据，DatagramPacket中就包含了IP地址，由于是多个客户端就需要一个集合专门保存各个客户端的IP地址
代码
/**
*@author big_fw
*@version 1.0
*/
package group;
import java.net.DatagramPacket;//实现无连接分组传送服务。 仅基于该数据包中包含的信息，每个消息从一台机器路由到另一台机器
import java.net.DatagramSocket;//用于发送和接收数据报数据包的套接字
import java.net.SocketAddress;
import java.util.ArrayList;
public class gServer implements Runnable{
private DatagramSocket DS;
private int Port = 9998;
private ArrayList<SocketAddress> clients = new ArrayList<SocketAddress>(); //保存客户端IP地址
public gServer() throws Exception{
try {
DS = new DatagramSocket(Port);
new Thread(this).start();
} catch (Exception ex) {
}
}
public void run(){
try{
while(true){
byte[] data = new byte[255];
DatagramPacket DP = new DatagramPacket(data,data.length);
DS.receive(DP);
SocketAddress clientip = DP.getSocketAddress();
if(!clients.contains(clientip)){
clients.add(clientip);
}
this.sendAll(DP);
}
}catch(Exception ex){
}
}
private void sendAll(DatagramPacket dp) throws Exception {
for(SocketAddress sa : clients){
DatagramPacket dd = new DatagramPacket(dp.getData(),dp.getLength(),sa);
DS.send(dd);
}
}
public static void main(String[] args) throws Exception{
new gServer();
}
}
客户端
1. 发送/接收消息
创建DatagramSocket对象，创建好IP地址和端口号后，利用DatagramSocket中的connect（ip,port）方法和服务端建立连接，然后利用DatagramSocket中的send（dp）方法发送早已准备好的数据。
2. 客户端和服务器端
客户端和服务器端都差不多，区别在于，客户端需要在构造函数中先和服务器端建立连接，给服务器端发送一个数据包，表示已经建立连接（其实是告诉服务器端自己的IP地址）然后再打开线程。在run（）函数中不用保存服务器地址。在发送消息按钮处不需要给DatagramPacket对象加IP地址，因为客户端早已和服务器端建立连接
3. 客户端和客户端
因为是多个客户端之间进行聊天，所以就需要一个name来区别每一个客户端，打开客户端需要输入昵称。连接服务器、发送消息、接收服务器传来的消息，这些操作和上述的类似，这里不在介绍。（ 彩蛋）在客户端GUI中我实现了用回车发送消息，并清空输入框的效果。
代码
客户端1
package group;
import java.awt.BorderLayout; //边界布局设置了一个容器，安排和调整其组件，以适应五个区域：北，南，东，西和中心
import java.awt.event.ActionEvent;//指示组件定义的动作发生的语义事件，当事件发生时，实现ActionListener接口的对象获得此ActionEvent
import java.awt.event.ActionListener;//用于接收动作事件的侦听器界面
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import javax.swing.JFrame;
import javax.swing.JOptionPane;//可以轻松地弹出一个标准对话框，提示用户获取值或通知他们某些东西
import javax.swing.JTextArea;//显示纯文本的多行区域
import javax.swing.JTextField;//一个轻量级组件，允许编辑单行文本
public class gClient extends JFrame implements Runnable,ActionListener {
private JTextField field = new JTextField();
private JTextArea area = new JTextArea("聊天内容：\n");
private String name = null;
private int Port = 9998;
private DatagramSocket DS;
public gClient(){
this.setTitle("客户端");
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.add(area, BorderLayout.CENTER); //private JTextArea area = new JTextArea("聊天内容：\n");
this.add(field, BorderLayout.SOUTH); //private JTextField field = new JTextField();
field.addActionListener(this);
this.setSize(220, 290);
this.setVisible(true);
name = JOptionPane.showInputDialog("输入昵称"); //标准对话框
try {
DS = new DatagramSocket();
InetAddress address = InetAddress.getByName("Localhost");
DS.connect(address,Port);
String str = name + "登录!";
byte[] data = str.getBytes();
DatagramPacket DP = new DatagramPacket(data,data.length);
DS.send(DP);
new Thread(this).start();
} catch (Exception e) {
}
}
public void run(){
try{
while(true){
byte[] data = new byte[255];
DatagramPacket DP = new DatagramPacket(data,data.length);
DS.receive(DP);
String str = new String(DP.getData(),0,DP.getLength());
area.append(str + '\n');
}
}catch(Exception ex){
}
}
public void actionPerformed(ActionEvent e){
try{
String str = name + "说：" + field.getText();
byte[] dd = str.getBytes();
DatagramPacket Data = new DatagramPacket(dd,dd.length);
DS.send(Data);
field.setText("");
}catch(Exception ex){
}
}
public static void main(String[] args){
new gClient();
}
}
客户端2
package group;
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
public class gClient2 extends JFrame implements Runnable,ActionListener {
private JTextField field = new JTextField();
private JTextArea area = new JTextArea("聊天内容：\n");
private String name = null;
private int Port = 9998;
private DatagramSocket DS;
public gClient2(){
this.setTitle("客户端");
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.add(area, BorderLayout.CENTER);
this.add(field, BorderLayout.SOUTH);
field.addActionListener(this);
this.setSize(220, 290);
this.setVisible(true);
name = JOptionPane.showInputDialog("输入昵称");
try {
DS = new DatagramSocket();
InetAddress address = InetAddress.getByName("Localhost");
DS.connect(address,Port);
String str = name + "登录!";
byte[] data = str.getBytes();
DatagramPacket DP = new DatagramPacket(data,data.length);
DS.send(DP);
new Thread(this).start();
} catch (Exception e) {
}
}
public void run(){
try{
while(true){
byte[] data = new byte[255];
DatagramPacket DP = new DatagramPacket(data,data.length);
DS.receive(DP);
String str = new String(DP.getData(),0,DP.getLength());
area.append(str + '\n');
}
}catch(Exception ex){
}
}
public void actionPerformed(ActionEvent e){
try{
String str = name + "说：" + field.getText();
byte[] dd = str.getBytes();
DatagramPacket Data = new DatagramPacket(dd,dd.length);
DS.send(Data);
field.setText("");
}catch(Exception ex){
}
}
public static void main(String[] args){
new group.gClient();
}
}
