简易聊天工具

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JTextArea;
import javax.swing.JTextField;
public class Person1 extends JFrame{
    private static JTextArea p1ta;
    private JTextField p1tf;
    private JButton p1b;
    
    
    
    //构造方法
    public Person1() {
        super("小明");
    }
    public void init1() {
        this.setLayout(null);
        p1ta = new JTextArea();
        p1tf = new JTextField();
        p1b = new JButton("发送");
        p1ta.setBounds(0, 0, 500, 300);
        p1tf.setBounds(0, 315, 400, 50);
        p1b.setBounds(420, 320, 60, 40);
        buttonLisenter();
        
        this.add(p1ta);
        this.add(p1tf);
        this.add(p1b);
        this.setSize(500, 400);
        this.setLocationRelativeTo(null);
        this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        this.setVisible(true);
    }
    public JTextArea getP1ta() {
        return p1ta;
    }
    //按钮监听器
    private void buttonLisenter() {
        p1b.addActionListener(new ActionListener() {
            
            @Override
            public void actionPerformed(ActionEvent e) {
                String str = p1tf.getText();
                p1tf.setText("");
                p1ta.append("我:"+"\r\n"+str + "\r\n");
                try {
                    Socket soc = new Socket(InetAddress.getLocalHost(),8888);
                    OutputStream ots = soc.getOutputStream();
                    PrintStream ps = new PrintStream(ots);
                    ps.print(str+"\r\n");
                    ps.close();
                    ots.close();
                } catch (UnknownHostException e1) {
                    e1.printStackTrace();
                } catch (IOException e1) {
                    e1.printStackTrace();
                }
            }
        });
    }
    
    
    //测试类
    public static void main(String[] args) {
        Person1 p1 = new Person1();
        p1.init1();
        Thread t1 = new Thread(new RunableP1(p1ta));
        t1.start();
    }
}

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JTextArea;
import javax.swing.JTextField;
public class Person2 extends JFrame{
    private static JTextArea p2ta;
    private JTextField p2tf;
    private JButton p2b;
    
    
    public void init2() {
        
        this.setLayout(null);
        p2ta = new JTextArea();
        p2tf = new JTextField();
        p2b = new JButton("发送");
        p2ta.setBounds(0, 0, 500, 300);
        p2tf.setBounds(0, 315, 400, 50);
        p2b.setBounds(420, 320, 60, 40);
        buttonLisenter();
        this.add(p2ta);
        this.add(p2tf);
        this.add(p2b);
        this.setSize(500, 400);
        this.setLocationRelativeTo(null);
        this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        this.setVisible(true);
        
    }
    public JTextArea getP2ta() {
        return p2ta;
    }
    //无参构造
    public Person2() {
        super("小芳");
    }
    //按钮监听器
        private void buttonLisenter() {
            p2b.addActionListener(new ActionListener() {
                
                @Override
                public void actionPerformed(ActionEvent e) {
                    String str = p2tf.getText();
                    p2tf.setText("");
                    p2ta.append("我:"+"\r\n"+str + "\r\n");
                    try {
                        Socket soc = new Socket(InetAddress.getLocalHost(),9999);
                        OutputStream ots = soc.getOutputStream();
                        PrintStream ps = new PrintStream(ots);
                        ps.print(str+"\r\n");
                        ps.close();
                        ots.close();
                    } catch (UnknownHostException e1) {
                        e1.printStackTrace();
                    } catch (IOException e1) {
                        e1.printStackTrace();
                    }
                }
            });
        }
    
    //测试类
    public static void main(String[] args) {
        Person2 p2 = new Person2();
        p2.init2();
        Thread t2 = new Thread(new RunableP2(p2ta));
        t2.start();
    }
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import javax.swing.JTextArea;
public class RunableP1 implements Runnable{
    private JTextArea p1ta;
    public RunableP1(JTextArea p1ta) {
        this.p1ta = p1ta;
    }
    @Override
    public void run() {
        ServerSocket ss;
        try {
                ss = new ServerSocket(9999);
                while(true){
                Socket sk = ss.accept();
                InputStream is = sk.getInputStream();
                BufferedReader br = new BufferedReader(new InputStreamReader(is));
                p1ta.append("小芳:\r\n"+br.readLine()+ "\r\n");
                br.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import javax.swing.JTextArea;
public class RunableP2 implements Runnable{
    private JTextArea p2ta;
    public RunableP2(JTextArea p2ta) {
        this.p2ta = p2ta;
    }
    @Override
    public void run() {
        ServerSocket ss;
        try {
                ss = new ServerSocket(8888);
                while(true){
                Socket sk = ss.accept();
                InputStream is = sk.getInputStream();
                BufferedReader br = new BufferedReader(new InputStreamReader(is));
                p2ta.append("小明:\r\n"+br.readLine()+ "\r\n");
                br.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
}