readObject() 之后的代码不运行

Question

我正在开发一个 UI，它从 zookeeper 读取序列化对象，对其进行反序列化，然后将其转换为 JSON。由于某种原因，我无法反序列化 MQTopic 对象。但我可以对其他对象做同样的事情。

这是将 byte[] 转换为 MQTopic 对象的部分。

if (tester != null && tester.contains("com.ibm.mq.jms.MQTopic")) {
                System.out.println(getValue());
                ByteArrayInputStream in = new ByteArrayInputStream(this.value);
                ObjectInputStream is = new ObjectInputStream(in);
                System.out.println("after deserializing..");
                topic = (MQTopic) is.readObject();
                System.out.println("after typecasting..");
                System.out.println(topic.getTopicName());
                System.out.println(topic.toString());

                is.close();
                in.close();

            }

这里的value是对象序列化后的字节数组。 topic = (MQTopic) is.readObject(); 之后没有任何内容。甚至没有打印语句。程序既不会终止，也不会抛出或捕获异常。

编辑：整个方法

public String getStrValue() {
    FtpConnectionInfo ftp = null;
    MQTopic topic = null;
    try {
        String tester = new String(this.value, "UTF-8");
        if (tester != null && tester.contains("FtpConnectionInfo")) {
            ByteArrayInputStream in = new ByteArrayInputStream(this.value);
            ObjectInputStream is = new ObjectInputStream(in);
            ftp = (FtpConnectionInfo) is.readObject();
            in.close();
            is.close();
            Gson gson = new Gson();
            return gson.toJson(ftp);

        } else if (tester != null
                && tester.contains("com.ibm.mq.jms.MQTopic")) {
            ByteArrayInputStream in = new ByteArrayInputStream(this.value);
            ObjectInputStream is = new ObjectInputStream(in);
            System.out.println("after deserializing..");
            topic = (MQTopic) is.readObject();
            System.out.println("after typecasting..");
            System.out.println(topic.getTopicName());
            System.out.println(topic.toString());
            is.close();
            in.close();

        } else {
            return new String(this.value, "UTF-8");
        }
    } catch (UnsupportedEncodingException ex) {
        System.out.println("unsupported error ");
        ex.printStackTrace();
        //logger.error(Arrays.toString(ex.getStackTrace()));
    } catch (Exception e) {
        System.out.println("Exception in new logic.");
        e.printStackTrace();
    }
    System.out.println("im out of try");

    return null;
}

FTP if 循环可以正常工作，但 Topic 循环不能在类型转换之外工作。

编辑 2：这是其他团队将对象存储到 Zookeeper 中的方式

public static byte[] serialize(Object obj) throws IOException {
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        ObjectOutputStream os = new ObjectOutputStream(out);
        os.writeObject(obj);
        return out.toByteArray();
    }

byte[] 存储在 Zookeeper 中，这就是我在 UI 中检索的内容。

编辑 3： 我对进程进行了调试，在调用 is 时，这些是值。谁能告诉我这个对象是否正确？

Answer 1

你做错了。您应该先反序列化对象，然后使用instanceof 来查看它是什么类型。在最好的情况下，将二进制数据转换为 String 是不好的做法。

您的实际症状不可信。必须抛出异常，否则您会提前阻塞。

Answer 2

ObjectInputStream 的 readObject 是一个阻塞方法。首先使用available方法检查是否有内容可以读取而不阻塞。

available 在这种情况下很可能会返回 0。

这可能只是您正在寻找的解决方案的一半，但我认为这会让您知道您是否有任何要阅读的内容。