我基本上想从服务器向我的客户端发送一个arraylist，它必须被序列化，所以我使用的是ObjectI / OStream . 但这是第一次创建客户端/服务器程序，所以我真的不知道该怎么做 . 我甚至无法在客户端程序中构造ObjectInputStream构造函数 . 我收到错误：
线程“main”中的异常java.net.SocketException：由peer重置连接：java.net上的java.net.SocketOutputStream.socketWrite（本机方法）中的套接字写入错误java.net.SocketOutputStream.socketWrite（未知源） . java.io.ObjectOutputStream上的SocketOutputStream.write（未知来源）$ java.io.ObjectOutputStream上的$ BlockDataOutputStream.drain（未知来源）$ SaleDataOutputStream.setBlockDataMode（未知来源），位于SalesServer.main上的java.io.ObjectOutputStream . （未知来源） （SalesServer.java:35）
码：
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
public class SalesClient {
public static void main(String[] args) throws IOException{
Socket ssocket = null;
ObjectOutputStream out = null;
ObjectInputStream inp = null;
Scanner in = null;
try {
ssocket = new Socket("FahadAhmed-PC", 6667);
in = new Scanner(System.in);
inp = new ObjectInputStream();
}catch(UnknownHostException e) {
System.err.println("Don't know about host: FahadAhmed-PC");
System.exit(1);
}catch(IOException e){
System.err.println(e);
System.exit(1);
}
}
}
服务器代码 . 首先，它扫描文本文件，然后将销售对象添加到arraylist：
import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Scanner;
public class SalesServer {
public static void main(String[] args) throws IOException{
ServerSocket serverSocket = null;
try {
serverSocket = new ServerSocket(6667);
} catch (IOException e){
System.out.println("Could not listen on port: 5555.");
System.exit(1);
}
Socket clientSocket = null;
try{
clientSocket = serverSocket.accept();
}catch (IOException e){
System.out.println("Accept failed.");
System.exit(1);
}
ArrayList<Sales> salesList = getSalesList();
ObjectOutputStream out = new ObjectOutputStream(clientSocket.getOutputStream());
}
private static ArrayList<Sales> getSalesList() throws FileNotFoundException {
ArrayList<Sales> list = new ArrayList<Sales>(10);
Scanner in = new Scanner(new BufferedReader(new FileReader("sales.txt")));
while(in.hasNext()){
String state;
int q1, q2, q3, q4;
state = in.nextLine();
q1 = in.nextInt();
q2 = in.nextInt();
q3 = in.nextInt();
q4 = in.nextInt();
in.nextLine();
Sales sale = new Sales(state, q1, q2, q3, q4);
System.out.println(sale.toString());
list.add(sale);
}
return null;
}
}
2 回答
这是关于套接字编程的很好的例子http://www.tutorialspoint.com/java/java_networking.htm .
您的客户端代码无法编译 .
它在执行任何关闭套接字的I / O之前退出，这会导致另一端的异常 .