diff --git a/motan-extension/serialization-extension/src/main/java/com/weibo/api/motan/serialize/HproseSerialization.java b/motan-extension/serialization-extension/src/main/java/com/weibo/api/motan/serialize/HproseSerialization.java index 8e5433805..c0baa8c0c 100644 --- a/motan-extension/serialization-extension/src/main/java/com/weibo/api/motan/serialize/HproseSerialization.java +++ b/motan-extension/serialization-extension/src/main/java/com/weibo/api/motan/serialize/HproseSerialization.java @@ -36,12 +36,19 @@ public class HproseSerialization implements Serialization { @Override public byte[] serialize(Object data) throws IOException { - ByteBufferStream stream = new ByteBufferStream(); - HproseWriter writer = new HproseWriter(stream.getOutputStream()); - writer.serialize(data); - byte[] result = stream.toArray(); - stream.close(); - return result; + ByteBufferStream stream = null; + try { + stream = new ByteBufferStream(); + HproseWriter writer = new HproseWriter(stream.getOutputStream()); + writer.serialize(data); + byte[] result = stream.toArray(); + return result; + } + finally { + if (stream != null) { + stream.close(); + } + } } @SuppressWarnings("unchecked")