1
您好我正在一個客戶端服務器程序與包含一些特殊功能，如發送私人消息，顯示在線列表等，所以我知道我必須使用序列化和第一我管理它，但過了一段時間擰了現在我花時間學習序列化。我將只分享有意義的部分以防止共同性。我想知道我犯錯的地方。無論如何感謝您的幫助。這裏是服務器代碼的一部分;java客戶端服務器序列化問題
public class Server {
private ServerSocket ss;
private Socket socket;
private Map<Socket,DataOutputStream> list = new HashMap<Socket,DataOutputStream>();
private LinkedList<Person> client_list = new LinkedList<Person>();
private String socketName;
private Object lockObj = new Object();
public Server(int port_number) throws IOException{
create_Server(port_number);
}
public static void main(String[] args) throws IOException {
int port_number=23;
new Server(port_number);
}
private void create_Server(int port_number) throws IOException{
ss = new ServerSocket(port_number);
System.out.println("Server is ready!");
while(true){
socket=ss.accept();
System.out.println(socket.getLocalAddress().getHostName() + " was connected!");
send_con_mes();
list.put(socket,new DataOutputStream(socket.getOutputStream()));
ServerThread st = new ServerThread(socket,this);
Person per = new Person(socket.getInetAddress().toString());
client_list.add(per);
st.start();
}
}
public LinkedList<Person> send_list(){
return client_list;
}
所以我創建服務器並等待任何套接字的響應。此外，我使用列表保存套接字和它的輸出和clien_list保存對象人（人是一個可序列化的對象）。
這裏是serverthread部分
public class ServerThread extends Thread {
private Socket s;
private Server srv;
private String socketName;
private StringTokenizer str;
private String message = "";
private LinkedList<Person> client_list;
private ObjectOutputStream oos;
private static int i=0;
public ServerThread(Socket s,Server srv){
this.s = s;
this.srv = srv;
try {
oos = new ObjectOutputStream(s.getOutputStream());
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void setList(){
client_list = srv.send_list();
}
private LinkedList<Person> getList(){
return client_list;
}
@Override
public void run() {
String msg;
String token;
DataInputStream dis;
try {
dis = new DataInputStream(s.getInputStream());
while(true){
msg = dis.readUTF();
srv.send_to_All(msg, s);
setList();
oos.writeObject(getList());
oos.flush();
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
try {
srv.remove_Connection(s);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
，所以我送client_list在上ObjectOutputStream oos給客戶。
終於在這裏是客戶端部分這需要列表和反序列化Person對象和讀取信息...
public class Client extends javax.swing.JFrame implements Runnable {
private DataOutputStream dos;
private DataInputStream dis;
private Socket s;
private String Client_name;
private String Ip_addr;
private Font font = new Font("Arial", Font.PLAIN, 13);
private int click_num_b=0;
private int click_num_i=0;
private LinkedList<Person> client_list;
private FileOutputStream fos;
private PrintStream pts;
private ObjectInputStream socketIn;
/** Creates new form Client */
public Client() {
initComponents();
Screen.setEditable(false);
Text_Field.setFont(font);
Screen.setFont(font);
start_Chat();
}
@Override
public void run() {
try {
while(true){
read_list();
String message = dis.readUTF();
Screen.append(message + "\n");
}
} catch (IOException ex) {
Logger.getLogger(Client.class.getName()).log(Level.SEVERE, null, ex);
}
}
private void read_list() throws IOException{
socketIn = new ObjectInputStream(s.getInputStream());
try {
client_list = (LinkedList<Person>) socketIn.readObject();
for (Iterator<Person> itr = client_list.iterator(); itr.hasNext();) {
Person per = itr.next();
pts.println(per.getnickName());
}
socketIn.close();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public void start_Chat() {
try {
Ip_addr = JOptionPane.showInputDialog("Enter the IP number of the server to connect : ");
s = new Socket(Ip_addr, 23);
Client_name = JOptionPane.showInputDialog("Enter your Nickname : ");
dis = new DataInputStream(s.getInputStream());
dos = new DataOutputStream(s.getOutputStream());
fos = new FileOutputStream("personList.txt");
pts = new PrintStream(fos);
new Thread(Client.this).start();
私人ObjectInputStream socketIn;需要的序列化對象，並在文件上寫道。這裏是我面臨的一些錯誤
java.io.EOFException
at java.io.DataInputStream.readUnsignedShort(Unknown Source)
at java.io.DataInputStream.readUTF(Unknown Source)
at java.io.DataInputStream.readUTF(Unknown Source)
at ServerThread.run(ServerThread.java:58)
SEVERE: null
java.io.StreamCorruptedException: invalid type code: 00
at java.io.ObjectInputStream.readObject0(Unknown Source)
at java.io.ObjectInputStream.readObject(Unknown Source)
at Client.read_list(Client.java:81)
at Client.run(Client.java:61)
at java.lang.Thread.run(Unknown Source)
所以我很感激，如果你能幫我處理這個問題。
將套接字聲明爲類變量並僅將其用作方法的本地變量有點難以理解。 – corsiKa
好吧，我會很高興，如果你能更清楚地解釋你的想法:) – quartaela
當然。我將'套接字套接字'移動到'create_Server'中的'while'循環中。這將防止任何東西與套接字對象混淆，並更可靠地保護套接字對象。你永遠不想公開信息不必要的。 – corsiKa