2

我正在尝试序列化HttpHandler类中的对象。

我有2个文件，Server3.java：

package server3;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.io.OutputStream;
import java.io.Serializable;
import java.net.InetSocketAddress;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.HttpServer;

public class Server3 {
public static void main(String[] args) throws Exception {

HttpServer server = HttpServer.create(new InetSocketAddress(3333), 0);
server.createContext("/", new MyHandler());
server.setExecutor(null); // creates a default executor
server.start();
}

static class MyHandler implements HttpHandler {
public void handle(HttpExchange t) throws IOException {
        String response = "Kjo eshte nje pergjigje nga serveri! n";

        t.sendResponseHeaders(200, response.length());
        OutputStream os = t.getResponseBody();
        os.write(response.getBytes());
        os.close();

        Personat obj = new Personat();
        ObjectOutputStream objOut = new     ObjectOutputStream(t.getResponseBody());
        objOut.writeObject(obj);
        objOut.close();
}
}
}
class Personat implements Serializable{
private static final long serialVersionUID = 1L;
int ID=3;
String Name="Andi";
}

和Client3.java：

package server3;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.net.HttpURLConnection;
import java.net.URL;
//te gjithe personat qe jan ne database me nej objekt 
public class Client3 {
public static void main(String[] args) throws Exception {
    try {
        URL url = new URL("http://localhost:3333");
        HttpURLConnection s = (HttpURLConnection) url.openConnection();
        s.setDoOutput(true);
        s.setDoInput(true);
        s.setRequestMethod("POST");
        s.setUseCaches(false);

        InputStream in = s.getInputStream();
        InputStreamReader isr = new InputStreamReader(in);
        BufferedReader br = new BufferedReader(isr);
        int c;
        while ((c = br.read()) != -1) {
            System.out.print((char) c);
        }
        ObjectInputStream ios = new ObjectInputStream(s.getInputStream());
        Personat oin = (Personat) ios.readObject();
        String emri=oin.Name;
        System.out.println(emri);
        ios.close();
        s.disconnect();
    } catch (IOException ex) {
        System.err.println(ex);
        System.out.print(ex);
    }
}
  }

但是当我运行它时，eclipse向我展示了

java.io.EOFException Kjo eshte nje pergjigje nga serveri! njava.io.EOFException`

我不明白为什么。

4

2 回答 2

2

问题是您试图将字符串response和对象都放入response.length()字节中。发生的情况是只response.length()发送字节，所以如果你尝试阅读更多内容，你会得到EOFException.

如果您将responseLength参数设置为 0，它将允许您传输任意数量的数据

t.sendResponseHeaders(200, 0);

如果要向其中写入更多数据，也不应关闭流。os.close()在所有的写作完成之前不要打电话。

于 2012-11-02T13:12:30.673 回答
1

来自 java 文档EOFException

表示输入期间意外到达文件结尾或流结尾。

此异常主要由数据输入流用来表示流结束。请注意，许多其他输入操作在流结束时返回一个特殊值，而不是引发异常。

EOFException是 的子类IOException。如果您尝试从流中读取并且没有更多数据要读取，它将被抛出。

我认为InputStream阅读以下内容后什么都没有了：

InputStream in = s.getInputStream();
InputStreamReader isr = new InputStreamReader(in);
BufferedReader br = new BufferedReader(isr);
int c;
while ((c = br.read()) != -1) {
    System.out.print((char) c);
 }
于 2012-11-02T12:07:40.787 回答