java实现简单socket通信

package cn.yan.chat; import java.awt.BorderLayout; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.KeyEvent; import java.awt.event.KeyListener; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.FileReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.ServerSocket; import java.net.Socket; import java.util.Properties; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTextArea; import javax.swing.JTextField; public class SeverChatMain extends JFrame implements ActionListener,KeyListener { public static void main(String[] args) { new SeverChatMain(); } private JTextArea jta; private JScrollPane jsp; private JPanel jp; private JTextField jtf; private JButton jb; private BufferedWriter bw = null; private static int serverPort; static { Properties pro=new Properties(); try { pro.load(new FileReader("chat.properties")); serverPort=Integer.parseInt(pro.getProperty("serverPort")); } catch (IOException e) { e.printStackTrace(); } } public SeverChatMain() { jta = new JTextArea(); jta.setEditable(false); jsp = new JScrollPane(jta); jp = new JPanel(); jtf = new JTextField(10); jb = new JButton("发送"); jp.add(jtf); jp.add(jb); this.add(jsp, BorderLayout.CENTER); this.add(jp, BorderLayout.SOUTH); this.setTitle("QQ聊天服务端"); this.setSize(300, 300); this.setLocation(600, 600); this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); this.setVisible(true); jb.addActionListener(this); jtf.addKeyListener(this); try { ServerSocket serverSocket = new ServerSocket(serverPort); Socket socket = serverSocket.accept(); // 读取socket输入流 BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream())); // 将内容写入socket bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); String line = null; while ((line = br.readLine()) != null) { jta.append(line+System.lineSeparator()); } serverSocket.close(); } catch (IOException e) { e.printStackTrace(); } } @Override public void actionPerformed(ActionEvent e) { sendDataToSocket(); } private void sendDataToSocket() { String text = jtf.getText(); text = "服务端对客户端说：" + text; jta.append(text + System.lineSeparator()); try { bw.write(text); bw.newLine(); bw.flush(); jtf.setText(""); } catch (IOException e1) { e1.printStackTrace(); } } @Override public void keyReleased(KeyEvent e) { if (e.getKeyCode() == KeyEvent.VK_ENTER) { sendDataToSocket(); } } @Override public void keyPressed(KeyEvent e) { } @Override public void keyTyped(KeyEvent e) { } }