关于java网络编程client端提示SocketException

Question

ChatClient

import java.awt.*;
import java.awt.event.*;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.*;
public class ChatClient extends Frame {

TextField txtf = new TextField();
TextArea txta = new TextArea();
Socket s = null; 

public static void main(String[] args) {
    new ChatClient().launchFrame();        
}

public void launchFrame() {
    setSize(300,300);
    setLocation(400,400);
    add(txtf,BorderLayout.SOUTH);
    add(txta,BorderLayout.NORTH);
    pack();
    setVisible(true);
    this.addWindowListener(new WindowAdapter() {

        @Override
        public void windowClosing(WindowEvent e) {
            System.exit(0);
        }
    });
    txtf.addActionListener(new TFListener());
    connect();
}

public void connect() {
    try {
        s = new Socket("127.0.0.1" , 7000);
        System.out.println("Connect");
    } catch (UnknownHostException e) {
        e.printStackTrace();
    } catch(IOException e) {
        e.printStackTrace();
    }
}

private class TFListener implements ActionListener {   //内部类
    @Override
    public void actionPerformed(ActionEvent e) {
        String str = txtf.getText().trim();
        txta.setText(str);
        txtf.setText("");
        try {
            DataOutputStream dos = new DataOutputStream(s.getOutputStream());
            dos.writeUTF(str);
            dos.flush();
            dos.close();
        }catch (IOException e1) {
            e1.printStackTrace();
        }
    }
}

}

ChatServer

import java.net.*;
import java.io.*;

public class ChatServer {

public static void main(String[] args) {
    try {
        ServerSocket ss = new ServerSocket(7000);
        while(true) {
            Socket s = ss.accept();

System.out.println("a client connected");

            DataInputStream dis = new DataInputStream(s.getInputStream());
            String str = dis.readUTF();
            System.out.println(str);
            dis.close();
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
}

}

我的问题是，当TextField中输入第二次时，Client端会报错，SocketException：Socket is closed，我知道可能是Client TFListener类中的try有问题，但是我觉得每一次回车后，都应该执行try，建立DataOutputStream，然后writeUTF，然后关闭，不应该存在报错啊，不知道自己哪里理解错了。

Answer 1

请指正：
问题可能的关键点：一个客户端，只做一次 accept()，不关闭输出流

1.客户端保持了一个 clientSocket 实例（只调用了一次connect），服务器保持了一个 ServerSocket 实例。只保持一个客户端socket并且希望有第二次输入处理，这似乎是准备用长连接。

当关闭输出流时，该输出流对应的socket也将随之关闭 —— 《疯狂java讲义（第三版）》 p786

2.再往下看服务端。ss.accept() 放在了循环里，这是要处理多个客户连接；顺便对每个客户端有一次读取操作，然后这里并没有后续多次的读取操作，这可能是问题所在。

短连接 or 长连接？对于希望连续的多次通讯，可以使用一个连接，多次读写（长连接），也可以多次连接，每个连接一次读写（短连接）
你的客户端想搞长连接，服务器似乎想搞短连接。建议：

长连接：客户端不变，服务器对这一个客户端，只做一次 accept()，循环处理多次输入通讯，监听流，但不关闭socket。

短连接：客户端每次发起新 socket 连接（建立新socket实例），每次操作完成，关闭流，关闭socket。服务器循环体不变，在循环体里关闭流，关闭每次accept()返回的socket。

因为不清楚您的业务，所以不知道代码的真实意图。另外还值得拓展的关注点是：

多客户端连接，多次连接，会话管理，并发等等。

Answer 2

可以好好看看你的代码，你在while循环里面每次都进行了关闭。