序挂在ObjectInputStream中的readObject

序挂在ObjectInputStream中的readObject

本文介绍了程序挂在ObjectInputStream中的readObject方法。的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我想分享当连接的是,我的code挂在ObjectInputStream中的readObject()函数后成立的类型的东西,其中包含的对象(字符串名称,地址,职务,......和字节[]图片)。不会发生流。任何人都可以请找出其中我做错了事情。

 私有类ConnectedThread继承Thread {
        私人最终的BluetoothSocket mmSocket;
        私人最终的InputStream mmInStream;
        私人最终的OutputStream mmOutStream;
        私人的ObjectOutputStream OOS = NULL;
        私人ObjectInputStream的OIS = NULL;        公共ConnectedThread(插座的BluetoothSocket){
            Log.d(TAG,创造ConnectedThread);
            mmSocket =插座;
            Log.d(TAG,创造);
            InputStream的tmpIn = NULL;
            Log.d(TAG,打造B);
            OutputStream的tmpOut = NULL;            //获取的BluetoothSocket输入和输出流
            尝试{
                Log.d(之前的InputStream连接线构造,);
                tmpIn = socket.getInputStream();
                Log.d(连接线构造的InputStream
                        tmpIn.toString());
                tmpOut = socket.getOutputStream();
                Log.d(连接线构造的OutputStream
                        tmpOut.toString());
            }赶上(IOException异常五){
                Log.e(TAG,临时插座没有创造,E);
            }            mmInStream = tmpIn;
            mmOutStream = tmpOut;            最终的BufferedOutputStream蟾蜍=新的BufferedOutputStream(
                    mmOutStream);
            最终的BufferedInputStream bufi =新的BufferedInputStream(mmInStream);            Log.d(TAG,试图创建OOS);            // ********* **********的ObjectOutputStream            尝试{
                OOS =新的ObjectOutputStream(蟾蜍);            }赶上(StreamCorruptedException E){
                Log.d(TAG,中招损坏流异常);
                Log.w(TAG,E);            }赶上(IOException异常五){
                Log.d(TAG,捕获到IOException);
                Log.w(TAG,E);
            }            // ********* ********** ObjectInputStream的            螺纹s =新的Thread(){
                公共无效的run(){
                    Log.d(TAG,试图创建OIS);
                    尝试{
                        OIS =新的ObjectInputStream(bufi);
                    }赶上(StreamCorruptedException E){
                        // TODO自动生成catch块
                        e.printStackTrace();
                    }赶上(IOException异常五){
                        // TODO自动生成catch块
                        e.printStackTrace();
                    }
                    Log.d(TAG,完成了OIS);
                    如果(OIS == NULL){
                        Log.d(TAG,OIS为空);
                    }
                }            };
            s.start();        }        公共无效的run(){
            Log.i(TAG,BEGIN mConnectedThread);

我的code挂在这一点上,永远向前。

 `//继续听InputStream的同时连接
        而(真){
            尝试{
                Log.d(连接线运行,开始时);                尝试{                    东西obj_rcv =(东西)ois.readObject();
                    Log.d(BTS,RCV对象+ obj_rcv.getName());                    消息MSG 2 = mHandler
                            .obtainMessage(RemoteBusinessCard.MESSAGE_READ);
                    束束=新包();
                    bundle.putSerializable(人,obj_rcv);
                    msg2.setData(包);
                    mHandler.sendMessage(MSG 2);                }赶上(ClassNotFoundException的E1){
                    // TODO自动生成catch块
                    e1.printStackTrace();
                }
            }赶上(IOException异常五){
                Log.e(TAG,断开,E);
                失去连接();
                打破;
            }
        }
    }    / **
     *写到所连接的OutStream。
     *
     * @参数缓冲区
     *将要写入的字节
     * /
    公共无效写入(东西对象){
        尝试{
            Log.d(BTS,里面写前的+ object.getName());
            oos.writeObject(对象);
            Log.d(BTS,内写入后+ object.getName());
            oos.flush();
            oos.close();        }赶上(IOException异常五){
            Log.e(TAG,写在异常,E);
        }
    }    公共无效取消(){
        尝试{
            mmSocket.close();
        }赶上(IOException异常五){
            Log.e(无法连接插座的close()标签,电子);
        }
    }
}`


解决方案

当你创建一个的ObjectOutputStream 您必须确保的ObjectInputStream 在插座的另一端也适当地创建,因为OutputStream的总发送确认包的InputStream和块,直到它得到一个答案。

I want to share object of type Stuff which contains ( String name,address,title, ... and byte[] picture ) when connection is established after that my code hangs on objectinputstream readObject() function . No streaming occurs. Can anyone please figure out where i am doing wrong thing.

private class ConnectedThread extends Thread {
        private final BluetoothSocket mmSocket;
        private final InputStream mmInStream;
        private final OutputStream mmOutStream;
        private ObjectOutputStream oos = null;
        private ObjectInputStream ois = null;

        public ConnectedThread(BluetoothSocket socket) {
            Log.d(TAG, "create ConnectedThread");
            mmSocket = socket;
            Log.d(TAG, "create a");
            InputStream tmpIn = null;
            Log.d(TAG, "create b");
            OutputStream tmpOut = null;

            // Get the BluetoothSocket input and output streams
            try {
                Log.d("connected thread constructor  before inputstream", "");
                tmpIn = socket.getInputStream();
                Log.d("connected thread constructor  inputstream",
                        tmpIn.toString());
                tmpOut = socket.getOutputStream();
                Log.d("connected thread constructor outputstream",
                        tmpOut.toString());
            } catch (IOException e) {
                Log.e(TAG, "temp sockets not created", e);
            }

            mmInStream = tmpIn;
            mmOutStream = tmpOut;

            final BufferedOutputStream bufo = new BufferedOutputStream(
                    mmOutStream);
            final BufferedInputStream bufi = new BufferedInputStream(mmInStream);

            Log.d(TAG, "attempting to create OOS");

            // ********* ObjectOutputStream **********

            try {
                oos = new ObjectOutputStream(bufo);

            } catch (StreamCorruptedException e) {
                Log.d(TAG, "Caught Corrupted Stream Exception");
                Log.w(TAG, e);

            } catch (IOException e) {
                Log.d(TAG, "Caught IOException");
                Log.w(TAG, e);
            }

            // ********* ObjectInputStream **********

            Thread s = new Thread() {
                public void run() {
                    Log.d(TAG, "attempting to create OIS");
                    try {
                        ois = new ObjectInputStream(bufi);
                    } catch (StreamCorruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    Log.d(TAG, "completed OIS");
                    if (ois == null) {
                        Log.d(TAG, "OIS is null");
                    }
                }

            };
            s.start();

        }

        public void run() {
            Log.i(TAG, "BEGIN mConnectedThread");

My code hang at this point , never move forward .

        `// Keep listening to the InputStream while connected
        while (true) {
            try {
                Log.d("Connected thread run ", "start while");

                try {

                    Stuff obj_rcv = (Stuff) ois.readObject();
                    Log.d("BTS", "rcv object " + obj_rcv.getName());

                    Message msg2 = mHandler
                            .obtainMessage(RemoteBusinessCard.MESSAGE_READ);
                    Bundle bundle = new Bundle();
                    bundle.putSerializable("person", obj_rcv);
                    msg2.setData(bundle);
                    mHandler.sendMessage(msg2);

                } catch (ClassNotFoundException e1) {
                    // TODO Auto-generated catch block
                    e1.printStackTrace();
                }
            } catch (IOException e) {
                Log.e(TAG, "disconnected", e);
                connectionLost();
                break;
            }
        }
    }

    /**
     * Write to the connected OutStream.
     *
     * @param buffer
     *            The bytes to write
     */
    public void write(Stuff object) {
        try {
            Log.d("BTS", "inside write before" + object.getName());
            oos.writeObject(object);
            Log.d("BTS", "inside write after" + object.getName());
            oos.flush();
            oos.close();

        } catch (IOException e) {
            Log.e(TAG, "Exception during write", e);
        }
    }

    public void cancel() {
        try {
            mmSocket.close();
        } catch (IOException e) {
            Log.e(TAG, "close() of connect socket failed", e);
        }
    }
}`
解决方案

When you create an ObjectOutputStream you must ensure that the ObjectInputStream at the other end of the socket is also appropriately created because the outputStream always sends a confirmation packet to the inputStream and blocks until it gets an answer.

这篇关于程序挂在ObjectInputStream中的readObject方法。的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!

08-06 02:52