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); } @Override public void focusGained(FocusEvent e) { //获取焦点时，清空提示内容
            String temp=textField.getText(); if(temp.equals(hintText)){ textField.setText(""); textField.setForeground(Color.BLACK); } } @Override public 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(); } }); } }

 

 

启动的时候要注意先启动服务器端再启动客户端，不然会报错。

 

 

 

 

 

菜鸟还需要不断学习。