使用Socket和ServerSocket实现多人聊天的聊天室程序

package com.szd.chat; import java.awt.EventQueue; import java.awt.Font; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintStream; import java.net.Socket; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JLabel; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTextArea; import javax.swing.JTextField; import javax.swing.border.EmptyBorder; public class ChatClient extends JFrame { private JPanel contentPane; private JTextField txtName; private JTextField txtMsg; JTextArea txtContent; PrintStream ps; BufferedReader br; /** * Launch the application. */ public static void main(String[] args) { EventQueue.invokeLater(new Runnable() { public void run() { try { ChatClient frame = new ChatClient(); frame.setVisible(true); } catch (Exception e) { e.printStackTrace(); } } }); } /** * Create the frame. */ public ChatClient() { setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); setBounds(100, 100, 450, 300); contentPane = new JPanel(); contentPane.setBorder(new EmptyBorder(5, 5, 5, 5)); contentPane.setLayout(null); setContentPane(contentPane); JScrollPane scrollPane = new JScrollPane(); scrollPane.setBounds(10, 10, 414, 212); contentPane.add(scrollPane); txtContent = new JTextArea(); scrollPane.setViewportView(txtContent); JLabel lblName = new JLabel("昵称："); lblName.setFont(new Font("新宋体", Font.PLAIN, 12)); lblName.setBounds(10, 237, 54, 15); contentPane.add(lblName); txtName = new JTextField(); txtName.setBounds(46, 234, 66, 21); contentPane.add(txtName); txtName.setColumns(10); JLabel lblMsg = new JLabel("内容："); lblMsg.setFont(new Font("新宋体", Font.PLAIN, 12)); lblMsg.setBounds(115, 237, 54, 15); contentPane.add(lblMsg); txtMsg = new JTextField(); txtMsg.setBounds(145, 234, 195, 21); contentPane.add(txtMsg); txtMsg.setColumns(10); JButton btnSend = new JButton("发送"); /** * 按钮点击事件 */ btnSend.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { String name = txtName.getText(); String msg = txtMsg.getText(); /** * 判断内容是否为空 */ if (!"".equals(msg)) { ps.println(name + ":" + msg); txtMsg.setText(""); } } }); btnSend.setFont(new Font("新宋体", Font.PLAIN, 12)); btnSend.setBounds(342, 233, 82, 23); contentPane.add(btnSend); /** * Socket */ try { Socket socket = new Socket("192.168.14.38", 28888); ps = new PrintStream(socket.getOutputStream()); br = new BufferedReader(new InputStreamReader(socket.getInputStream())); /** * 新开一个线程用来接收消息 */ new GetMsgFromServerThread(br).start(); } catch (Exception e1) { e1.printStackTrace(); } } /** * 接收消息的线程 * * @author Administrator * */ class GetMsgFromServerThread extends Thread { private BufferedReader br; public GetMsgFromServerThread(BufferedReader br) { this.br = br; } @Override public void run() { String str = ""; while (this.isAlive()) { try { str = br.readLine(); if (!"".equals(str)) { // System.out.println(str); txtContent.append(str + "\n\r"); } } catch (IOException e) { e.printStackTrace(); } } } } }