Java实现简易聊天室

在学习《Java从入门到精通》这本书，网络通信，基于TCP实现的简易聊天室，我这里对书中的代码略做了修改，做个记录。

这里先放一下运行效果图，代码放在最后。

运行效果：

先启动服务器端：

启动客户端：

发送数据：

主要的功能就是上面那些，在代码中我还添加一些功能，比如说给JTextField添加了焦点监听器，以及输入框为空的检查和提示，但总的来说还是比较简单，如果要实现健壮的聊天室程序还需要再做些修改。

下面放下代码，比较简单，就服务器端和客户端两个代码。

服务器端代码：

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import static java.lang.System.out;public class MyTcp {private BufferedReader reader;private ServerSocket server;private Socket socket;void getServer(){try {server=new ServerSocket(8998);        //实例化Socket对象out.println("服务器套接字已创建成功");while(true) {out.println("等待客户机的连接");socket=server.accept();           //accept()方法会返回一个和客户端Socket对象相连的Socket对象reader=new BufferedReader(new InputStreamReader(socket.getInputStream()));getClientMessage();}}catch(Exception e) {e.printStackTrace();}}//读取客户端发送过来的信息private void getClientMessage() {try {while(true) {//获得客户端信息out.println("客户机："+reader.readLine());}}catch(Exception e) {e.printStackTrace();}try {if(reader!=null) {reader.close();}if(socket!=null) {socket.close();}}catch(Exception e) {e.printStackTrace();}}public static void main(String[] args) {MyTcp tcp=new  MyTcp();tcp.getServer();}}

客户端代码：

import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.Container;
import java.awt.EventQueue;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.FocusEvent;
import java.awt.event.FocusListener;
import java.io.PrintWriter;
import java.net.Socket;import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.border.BevelBorder;public class MyClient extends JFrame{private PrintWriter writer;Socket socket;private JTextArea ta=new JTextArea();private JTextField tf=new JTextField();Container cc;public MyClient(String title) {super(title);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);cc=this.getContentPane();final JScrollPane scrollPane=new JScrollPane();scrollPane.setBorder(new BevelBorder(BevelBorder.RAISED));getContentPane().add(scrollPane,BorderLayout.CENTER);scrollPane.setViewportView(ta);cc.add(tf,"South");tf.addFocusListener(new JTextFieldListener(tf,"请在此输入内容"));tf.addActionListener(new ActionListener() {public void actionPerformed(ActionEvent e) {if(tf.getText().isEmpty()) {JOptionPane.showMessageDialog(MyClient.this, "请输入内容！");}else {writer.println(tf.getText());ta.append(tf.getText()+"\n");ta.setSelectionEnd(ta.getText().length());tf.setText("");}}});}//焦点监听器class JTextFieldListener implements FocusListener{private String hintText;          //提示文字private JTextField textField;public JTextFieldListener(JTextField textField,String hintText) {this.textField=textField;this.hintText=hintText;textField.setText(hintText);   //默认直接显示
            textField.setForeground(Color.GRAY);}@Overridepublic void focusGained(FocusEvent e) {//获取焦点时，清空提示内容String temp=textField.getText();if(temp.equals(hintText)){textField.setText("");textField.setForeground(Color.BLACK);}}@Overridepublic void focusLost(FocusEvent e) {//失去焦点时，没有输入内容，显示提示内容String temp=textField.getText();if(temp.equals("")) {textField.setForeground(Color.GRAY);textField.setText(hintText);}}}private void connect() {ta.append("尝试连接\n");try {socket=new Socket("127.0.0.1",8998);writer=new PrintWriter(socket.getOutputStream(),true);ta.append("完成连接\n");}catch(Exception e) {e.printStackTrace();}}public static void main(String[] args) {//EventQueue事件队列，封装了异步事件指派机制EventQueue.invokeLater(new Runnable(){public void run() {MyClient client=new MyClient("向服务器发送数据");client.setSize(400,400);client.setVisible(true);client.connect();}});}}