我正在创建简单的点对点游戏。目前我正在服务器/客户端(节点)端工作。我发生了奇怪的问题,我可以ObjectOutputStream
从套接字创建,但程序在创建ObjectInputStream
. 为了存储套接字和创建流,我使用了我自己的类(下面的代码)。我做错了什么?
public void run() {
try {
while (this.listen) {
temp = serverSocket.accept();
sockList.addSocket(temp);
sockList.addObjOutStrm(temp);
sockList.addObjInStrm(temp); // <------------------------ program stops
setChanged();
notifyObservers(temp);
System.out.println("SERVER: Dodalem uzytkownika, oto pelna lista:\n\n"
+ sockList + "\n");
synchronized (sockList) {
for (ObjectOutputStream oos : sockList.getOOSList()) {
oos.writeObject(sockList.extractToString());
}
}
}
} catch (IOException e) {
System.err.println("SERVER: Błąd I/O serwera podczas nasluchu");
//e.printStackTrace();
}
}
我自己的类来存储套接字和流:
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
public class SocketList {
private List<ObjectOutputStream> obOutStrList;
private List<ObjectInputStream> obInStrList;
private List<Socket> sockList;
private int maxUsers;
private int currentUsers;
public SocketList() {
obOutStrList = Collections
.synchronizedList(new ArrayList<ObjectOutputStream>());
obInStrList = Collections
.synchronizedList(new ArrayList<ObjectInputStream>());
sockList = Collections.synchronizedList(new ArrayList<Socket>());
maxUsers = 4;
currentUsers = 0;
}
synchronized public void addSocket(Socket sock) {
if (sockList.size() < 4) {
sockList.add(sock);
currentUsers++;
} else {
System.out.println("sockList: Blad max uzytkownikow");
}
}
synchronized public void addObjOutStrm(Socket sock) {
try {
obOutStrList.add(new ObjectOutputStream(sock.getOutputStream()));
} catch (IOException e) {
System.out.println("Problem z uzyskaniem strumienia wyjsciowego dla " + sock.getInetAddress().getHostAddress().toString());
e.printStackTrace();
}
}
synchronized public void addObjInStrm(Socket sock) {
try {
obInStrList.add(new ObjectInputStream(sock.getInputStream()));
} catch (IOException e) {
System.out.println("Problem z uzyskaniem strumienia wejsciowego dla " + sock.getInetAddress().getHostAddress().toString());
e.printStackTrace();
}
}
synchronized public void removeSock(Socket s) {
if (sockList.contains(s)) {
System.out.println("SOCKETLIST: Usuwam " + s.toString());
sockList.remove((Socket) s);
}
}
synchronized public List<Socket> getSockList() {
return sockList;
}
synchronized public List<ObjectOutputStream> getOOSList() {
return obOutStrList;
}
synchronized public List<ObjectInputStream> getOISList() {
return obInStrList;
}
public String toString() {
return sockList.toString();
}
public String[] extractToString() {
String[] retArr = new String[currentUsers];
for (int i = 0; i < sockList.size(); i++)
retArr[i] = sockList.get(i).getInetAddress().getHostAddress()
.toString();
return retArr;
}
}