1

さて、私は XMLParser から .xml ファイルを読み込もうとしているので、基本的には XML ファイルを読み込んでサーバーからクライアントに出力したいのですが、クライアント コードの実行中に次のようになります。

java.io.StreamCorruptedException: invalid type code: AC

クライアントコードは次のとおりです。

import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.List;

import javax.swing.JComboBox;
import javax.swing.JFrame;

import server.Video;
import server.VideoFile;

@SuppressWarnings("serial")
public class Client extends JFrame{
    Container contentPane;
    @SuppressWarnings("rawtypes")
    JComboBox selectionBox;

    List<Video> video;
    List<VideoFile> videoFile;

    Socket serverSocket;
    String host = "127.0.0.1";
    int port = 1176;
    ObjectInputStream inputFromServer;
    ObjectOutputStream out;

    public Client() throws Exception {
        // line 41 below
            setupGUI();

        System.out.println("Reading the XML File");
        MyXMLReader reader = new MyXMLReader();
        //video = reader.getList("videoList.xml");
        System.out.println("Finished reading");
    }

    public void openSocket() throws UnknownHostException, IOException {
         /** Obtain an address object of the server */
        serverSocket = new Socket("localhost", port);
        System.out.println("Connected to localhost in port: " + port);
        out = new ObjectOutputStream(serverSocket.getOutputStream());
        //out.flush();
        inputFromServer = new ObjectInputStream(serverSocket.getInputStream());

    }

    @SuppressWarnings("unchecked")
    public void getListFromSocket() throws IOException, ClassNotFoundException {
        try{
        video = (List<Video>)inputFromServer.readObject();
        } catch (IOException e) {
            e.printStackTrace();
            System.exit(-1);
        }
        //serverSocket.close();
    }
    public void runClient() throws Exception {

            try {
                openSocket();
                getListFromSocket();
                serverSocket.close();
                setupGUI();
                } catch (UnknownHostException e) {
                System.out.println("Don't know about host : " + host);
                System.exit(-1);
                } catch (IOException e) {
                e.printStackTrace();
                System.out.println("Couldn't open I/O connection : " + host + ":" + port);
                System.exit(-1);
                } catch (ClassNotFoundException e) {
                System.out.println("Class definition not found for incoming object.");
                e.printStackTrace();
                System.exit(-1);
            }

    }

    @SuppressWarnings({ "unchecked", "rawtypes" })
    private void setupGUI() throws Exception{
        setTitle("A Client");
        setSize(600, 400);
        setVisible(true);
        contentPane = getContentPane();
        contentPane.setLayout(new BorderLayout());

            runClient();

        // line 105 below
        String [] selectionListData = new String[video.size()];
        for (int i = 0; i < video.size(); i++) {
        selectionListData[i] = video.get(i).getFilename();
        selectionListData[i] = video.get(i).getID();
        selectionListData[i] = video.get(i).getTitle();
        System.out.println(selectionListData);
        }
        selectionBox = new JComboBox(selectionListData);
        selectionBox.setSelectedIndex(0);
        add(selectionBox, BorderLayout.NORTH);
        selectionBox.addActionListener((ActionListener) this);

        validate();
    }

    public void actionPerformed(ActionEvent e) {
        @SuppressWarnings("rawtypes")
        JComboBox comboBox = (JComboBox)e.getSource();
        String selectedTitle = (String)comboBox.getSelectedItem();
        System.out.println("Selected title : " + selectedTitle);
        }


    public static void main(String[] args) throws IOException, Exception {
            // line 127 below
        new Client();

    }

}

完全なエラーは次のとおりです。

    Connected to localhost in port: 1176
    java.io.StreamCorruptedException: invalid type code: AC
    at java.io.ObjectInputStream.readObject0(Unknown Source)
    at java.io.ObjectInputStream.readObject(Unknown Source)
    at client.Client.getListFromSocket(Client.java:61)
    at client.Client.runClient(Client.java:72)
    at client.Client.<init>(Client.java:40)
    at client.Client.main(Client.java:124)

誰かがこれを修正できますか、それは小さなことだと確信していますが、私はそれを理解できません。

ありがとう

編集: サーバー コードは次のとおりです。

package server;

import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.List;
import java.lang.*;

@SuppressWarnings("unused")
public class Server extends Thread implements Runnable{
    List<Video> video;
    static String TimeStamp;
    //Socket Declerations
    ServerSocket serverSocket;
    int port = 1176;
    //String host = "localhost";
    Socket clientSocket;
    ObjectOutputStream outputToClient;



    public Server() {
        Thread();
        System.out.println("Reading the XML File");
        MyXMLReader reader = new MyXMLReader();
        //video = reader.getList("videoList.xml");
        System.out.println("Finished reading");
    }

    public void openSockets() throws IOException {
        try {
            serverSocket = new ServerSocket(port);
            System.out.println("Socket Connection Established....");
        } catch (IOException e) {
            System.out.println("Could not listen on port : " + port);
            System.exit(-1);
        }
        TimeStamp = new java.util.Date().toString();
        System.out.println("Opened socket on : " + port + ", waiting for client. " + TimeStamp);

        try {
            clientSocket = serverSocket.accept();
            //System.out.println("Sending to Client.....");
            } catch (IOException e) {
            System.out.println("Could not accept client.");
            System.exit(-1);
            }
            outputToClient = new ObjectOutputStream(clientSocket.getOutputStream());
    }
    public void writeToSocket() throws IOException {
        outputToClient = new ObjectOutputStream(clientSocket.getOutputStream());
        outputToClient.writeObject(video);
        System.out.println(outputToClient);
    }

    public void Thread() {
        Thread socketThread;
        socketThread = new Thread("Socket") {
        public void run() {
            try {
                openSockets();
                writeToSocket();
                clientSocket.close();
                serverSocket.close();
            } catch (IOException e) {
                System.out.println("Error on sockets connection.");
                e.printStackTrace();
            }
        }
};
socketThread.start();
}

    public static void main(String[] args) throws IOException {
        new Server();
        //new Thread();


    }

}

編集:重複したエントリを削除した後の新しいエラー:

Exception in thread "main" java.lang.NullPointerException
    at client.Client.setupGUI(Client.java:105)
    at client.Client.<init>(Client.java:41)
    at client.Client.main(Client.java:127)
4

2 に答える 2

2

Server クラスの同じソケットで ObjectOutputStream を二重に開いているため、特別なヘッダーが 2 回送信されます。

1:openSockets最後の行outputToClient = new ObjectOutputStream(clientSocket.getOutputStream());

2:writeToSocket最初の行outputToClient = new ObjectOutputStream(clientSocket.getOutputStream());

必要なものを削除すると、問題なく動作するはずです。

あなたが今受け取っている nullpointer に関しては、クライアントでビデオが null になっているような気がします。あなたが投稿したコードでは、サーバーではビデオ配列を作成することはなく、クライアントはnullを受け取っているだけなので、それは理にかなっています。

于 2012-05-07T02:41:34.683 に答える
2

このエラーはObjectOutputStream、同じソケットで複数のソケットを使用した場合に発生します。ソケットの寿命の間、両端で同じものを使用してくださいObjectOutputstream。ObjectInputStream他のほとんどのストリームおよびリーダー/ライター タイプについても同じことが言えますが、そうしない場合の結果は通常、さらに不可解です。

于 2012-05-07T02:42:39.597 に答える