运用了Socket编程，gui，流的读入和写出，线程控制等
思路：
1、首先是在客户端中先建立好聊天的GUI
2、建立服务器端，设置好端口号（用SocketServer），其中需要两个boolean变量来分别表示服务器是否已经开启和是否有客户端连接进来，
利用while循环来让服务器在开启的情况下不断接收客户端的信息。利用DataOutputStream来进行通讯
3、客户端连接服务器（Socket）
首先是客户端的类
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException; import javax.swing.JFrame;
import javax.swing.JTextArea;
import javax.swing.JTextField; /**
* 完成图形界面
* @author Administrator
*
*/
public class ChatClient extends JFrame{
JTextField jTextField = new JTextField();
JTextArea jTextArea = new JTextArea();
Socket s;
DataOutputStream bo;
public static void main(String[] args) {
new ChatClient().launchFrame();
} public void launchFrame() {
setLocation(200, 150);
this.setSize(450, 450);
this.add(jTextArea,BorderLayout.NORTH);
this.add(jTextField,BorderLayout.SOUTH);
jTextField.addActionListener(new TFListener());
//pack();
this.addWindowListener(new WindowAdapter() {
@Override
public void windowClosing(WindowEvent arg0) {
disConnect();
System.exit(0);
}
});; setVisible(true);
connect();
} /**
* 建立连接的方法
* @throws IOException
* @throws UnknownHostException
*/
public void connect() {
try {
s = new Socket("127.0.0.1",8888);
bo = new DataOutputStream(s.getOutputStream());
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
System.out.println("连接成功");
}
/**
* 断开连接，关闭资源的方法
*/
public void disConnect() {
try {
s.close();
bo.close();
} catch (IOException e1) {
e1.printStackTrace();
} } /**
* 内部类，实现监听
* 将文本框中的输入打印到文本域中
*
*/
private class TFListener implements ActionListener{ @Override
public void actionPerformed(ActionEvent e) {
String content = jTextField.getText().trim();
jTextArea.setText(content);
jTextField.setText("");
//将文本发送到服务器
try {
System.out.println(s);
bo.writeUTF(content);
bo.flush();
} catch (IOException e1) {
e1.printStackTrace();
}
} }
}
然后是服务器的类
import java.io.DataInputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket; public class ChatSever {
public static void main(String[] args) {
// 布尔类型变量表示服务器是否开着
boolean started = false;
ServerSocket ss = null;
Socket s = null;
DataInputStream bi = null;
// 建立服务端,8888为端口号
try {
ss = new ServerSocket(8888);
}
catch (BindException e) {
System.out.println("Socket has been used !");
System.out.println("请重启服务器 !");
System.exit(0);
}catch (IOException e) {
e.printStackTrace();
}
// 服务器开启后，started变为true
try {
started = true;
// 接受客户端的连接
while (started) {
// 布尔类型变量bConnected表示有没有用户连接
boolean bConnected = false;
s = ss.accept();
// 服务器连接后bConnected为true
bConnected = true;
System.out.println("一个客户连接");
bi = new DataInputStream(s.getInputStream());
while (bConnected) {
String str = bi.readUTF();
System.out.println(str);
//bi.close();
}
}
} catch (EOFException e) {
System.out.println("Client close!");
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (bi != null)
bi.close();
if (s != null)
s.close();
} catch (IOException e1) {
e1.printStackTrace();
} }
} }