Java-Socket（3）全双工模式

系统管理员 2024-02-17 20:35 11阅读 0赞

// 服务器
    package com.test;
    
    import java.awt.event.*;
    import java.io.*;
    import java.net.*;
    
    import javax.swing.*;
    
    public class MyServer extends JFrame implements ActionListener, KeyListener {
        
    
        JPanel jp1 = null;
        JTextArea jta = null;
        JTextField jtf = null;
        JScrollPane jsp = null;
        JButton jb = null;
        PrintWriter pw = null; 
        String chatName = null;
        public MyServer() {
    
            jta = new JTextArea();
            jsp = new JScrollPane(jta);
            jtf = new JTextField(20);
            jb = new JButton("发送");
            jb.addActionListener(this);
            jtf.addKeyListener(this);
    
            jp1 = new JPanel();
            jp1.add(jtf);
            jp1.add(jb);
    
            this.add(jsp, "Center");
            this.add(jp1, "South");
    
            this.setTitle("简易聊天");
            this.setSize(450, 300);
            this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
            this.setVisible(true);
    
            try {
                ServerSocket ss = new ServerSocket(9999);
                Socket s = ss.accept();
                chatName = s.getRemoteSocketAddress().toString();
                System.out.println(chatName);
                // 读取数据
                InputStreamReader isr = new InputStreamReader(s.getInputStream(), "UTF-8");
                BufferedReader br = new BufferedReader(isr);
    
                pw = new PrintWriter(s.getOutputStream(), true);
    
                while(true) {
                    String info = br.readLine();
    
    //              jta.setText(info);
                    if(info.equals("bye")) {
                        s.close();
                        break;
                    }
                    jta.append(chatName + ":" + info + "\r\n");
                }
    
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
    
        }
    
        public void sendMessage() {
            String info = jtf.getText();
            jta.append("我:" + info + "\r\n");
            pw.println(info);
            jtf.setText("");
        }
    
        @Override
        public void actionPerformed(ActionEvent e) {
            // TODO Auto-generated method stub
            if(e.getSource() == jb) {
                sendMessage();
            }
        }
    
        @Override
        public void keyPressed(KeyEvent e) {
            // TODO Auto-generated method stub
            if(e.getKeyCode() == 10) { // 回车发送消息
                sendMessage();
            }
            System.out.println(e.getKeyCode());
        }
    
        @Override
        public void keyReleased(KeyEvent e) {
            // TODO Auto-generated method stub
    
        }
    
        @Override
        public void keyTyped(KeyEvent e) {
            // TODO Auto-generated method stub
    
        }
        public static void main(String[] args) {
            // TODO Auto-generated method stub
            new MyServer();
        }
    }

// 客户端
    package com.test;
    
    
    import java.awt.event.*;
    import java.io.*;
    import java.net.*;
    
    import javax.swing.*;
    
    public class MyClient extends JFrame implements ActionListener, KeyListener{
        
        JPanel jp1 = null;
        JTextArea jta = null;
        JTextField jtf = null;
        JScrollPane jsp = null;
        JButton jb = null;
        PrintWriter pw = null;
        String chatName = null;
        public MyClient() {
            jta = new JTextArea();
            jsp = new JScrollPane(jta);
            jtf = new JTextField(20);
            jb = new JButton("发送");
            jb.addActionListener(this);
            jtf.addKeyListener(this);
    
            jp1 = new JPanel();
            jp1.add(jtf);
            jp1.add(jb);
    
            this.add(jsp, "Center");
            this.add(jp1, "South");
    
            this.setTitle("简易聊天");
            this.setSize(450, 300);
            this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
            this.setVisible(true);
            try {
                // socket用于连接某个服务器
                Socket s = new Socket("localhost", 9999);
                chatName = s.getRemoteSocketAddress().toString();
    
                OutputStreamWriter osw = new OutputStreamWriter(s.getOutputStream(), "UTF-8");
                pw = new PrintWriter(osw, true);                        
                // 接收数据     
                InputStreamReader isr = new InputStreamReader(s.getInputStream(), "UTF-8");             
                BufferedReader br = new BufferedReader(isr);
    
                while(true) {
    
                    String info = br.readLine();
    
    
                    if(info.equals("bye")) {
                        s.close();
                        break;
                    }
    
                    jta.append(chatName + ":" + info + "\r\n");
                }
    
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
    
        }
    
        public void sendMessage() {
            String info = jtf.getText();
            jta.append("我:" + info + "\r\n");
            pw.println(info);
            jtf.setText("");
        }
    
    
        @Override
        public void actionPerformed(ActionEvent e) {
            // TODO Auto-generated method stub
            if(e.getSource()==jb) {
                sendMessage();
            }
        }
    
        @Override
        public void keyPressed(KeyEvent e) {
            if(e.getKeyCode() == 10) { // 回车发送消息
                sendMessage();
            }
        }
    
        @Override
        public void keyReleased(KeyEvent e) {
            // TODO Auto-generated method stub
    
        }
    
        @Override
        public void keyTyped(KeyEvent e) {
            // TODO Auto-generated method stub
    
        }
    
        public static void main(String[] args) {
    
            new MyClient();
        }
    }