T roundtrip(final T msg) {
+ return SerializationUtils.deserialize(SerializationUtils.serialize(msg));
+ }
+
+ // Serialize
+ //-----------------------------------------------------------------------
+ /**
+ * Serializes an {@code Object} to the specified stream.
+ *
+ * The stream will be closed once the object is written.
+ * This avoids the need for a finally clause, and maybe also exception
+ * handling, in the application code.
+ *
+ * The stream passed in is not buffered internally within this method.
+ * This is the responsibility of your application if desired.
+ *
+ * @param obj the object to serialize to bytes, may be null
+ * @param outputStream the stream to write to, must not be null
+ * @throws IllegalArgumentException if {@code outputStream} is {@code null}
+ * @throws SerializationException (runtime) if the serialization fails
+ */
+ public static void serialize(final Serializable obj, final OutputStream outputStream) {
+ if (outputStream == null) {
+ throw new IllegalArgumentException("The OutputStream must not be null");
+ }
+ ObjectOutputStream out = null;
+ try {
+ // stream closed in the finally
+ out = new ObjectOutputStream(outputStream);
+ out.writeObject(obj);
+
+ } catch (final IOException ex) {
+ throw new RuntimeException(ex);
+ } finally {
+ try {
+ if (out != null) {
+ out.close();
+ }
+ } catch (final IOException ex) { // NOPMD
+ // ignore close exception
+ }
+ }
+ }
+
+ /**
+ * Serializes an {@code Object} to a byte array for
+ * storage/serialization.
+ *
+ * @param obj the object to serialize to bytes
+ * @return a byte[] with the converted Serializable
+ * @throws SerializationException (runtime) if the serialization fails
+ */
+ public static byte[] serialize(final Serializable obj) {
+ final ByteArrayOutputStream baos = new ByteArrayOutputStream(512);
+ serialize(obj, baos);
+ return baos.toByteArray();
+ }
+
+ // Deserialize
+ //-----------------------------------------------------------------------
+ /**
+ *
+ * Deserializes an {@code Object} from the specified stream.
+ *
+ *
+ *
+ * The stream will be closed once the object is written. This avoids the need for a finally clause, and maybe also
+ * exception handling, in the application code.
+ *
+ *
+ *
+ * The stream passed in is not buffered internally within this method. This is the responsibility of your
+ * application if desired.
+ *
+ *
+ *
+ * If the call site incorrectly types the return value, a {@link ClassCastException} is thrown from the call site.
+ * Without Generics in this declaration, the call site must type cast and can cause the same ClassCastException.
+ * Note that in both cases, the ClassCastException is in the call site, not in this method.
+ *
+ *
+ * @param the object type to be deserialized
+ * @param inputStream
+ * the serialized object input stream, must not be null
+ * @return the deserialized object
+ * @throws IllegalArgumentException
+ * if {@code inputStream} is {@code null}
+ * @throws SerializationException
+ * (runtime) if the serialization fails
+ */
+ public static T deserialize(final InputStream inputStream) {
+ if (inputStream == null) {
+ throw new IllegalArgumentException("The InputStream must not be null");
+ }
+ ObjectInputStream in = null;
+ try {
+ // stream closed in the finally
+ in = new ObjectInputStream(inputStream);
+ @SuppressWarnings("unchecked") // may fail with CCE if serialised form is incorrect
+ final T obj = (T) in.readObject();
+ return obj;
+
+ } catch (final ClassCastException ex) {
+ throw new RuntimeException(ex);
+ } catch (final ClassNotFoundException ex) {
+ throw new RuntimeException(ex);
+ } catch (final IOException ex) {
+ throw new RuntimeException(ex);
+ } finally {
+ try {
+ if (in != null) {
+ in.close();
+ }
+ } catch (final IOException ex) { // NOPMD
+ // ignore close exception
+ }
+ }
+ }
+
+ /**
+ *
+ * Deserializes a single {@code Object} from an array of bytes.
+ *
+ *
+ *
+ * If the call site incorrectly types the return value, a {@link ClassCastException} is thrown from the call site.
+ * Without Generics in this declaration, the call site must type cast and can cause the same ClassCastException.
+ * Note that in both cases, the ClassCastException is in the call site, not in this method.
+ *
+ *
+ * @param the object type to be deserialized
+ * @param objectData
+ * the serialized object, must not be null
+ * @return the deserialized object
+ * @throws IllegalArgumentException
+ * if {@code objectData} is {@code null}
+ * @throws SerializationException
+ * (runtime) if the serialization fails
+ */
+ public static T deserialize(final byte[] objectData) {
+ if (objectData == null) {
+ throw new IllegalArgumentException("The byte[] must not be null");
+ }
+ return SerializationUtils.deserialize(new ByteArrayInputStream(objectData));
+ }
+
+ /**
+ * Custom specialization of the standard JDK {@link java.io.ObjectInputStream}
+ * that uses a custom ClassLoader to resolve a class.
+ * If the specified ClassLoader is not able to resolve the class,
+ * the context classloader of the current thread will be used.
+ * This way, the standard deserialization work also in web-application
+ * containers and application servers, no matter in which of the
+ * ClassLoader the particular class that encapsulates
+ * serialization/deserialization lives.
+ *
+ * For more in-depth information about the problem for which this
+ * class here is a workaround, see the JIRA issue LANG-626.
+ */
+ static class ClassLoaderAwareObjectInputStream extends ObjectInputStream {
+ private static final Map> primitiveTypes =
+ new HashMap>();
+ private final ClassLoader classLoader;
+
+ /**
+ * Constructor.
+ * @param in The InputStream.
+ * @param classLoader classloader to use
+ * @throws IOException if an I/O error occurs while reading stream header.
+ * @see java.io.ObjectInputStream
+ */
+ public ClassLoaderAwareObjectInputStream(final InputStream in, final ClassLoader classLoader) throws IOException {
+ super(in);
+ this.classLoader = classLoader;
+
+ primitiveTypes.put("byte", byte.class);
+ primitiveTypes.put("short", short.class);
+ primitiveTypes.put("int", int.class);
+ primitiveTypes.put("long", long.class);
+ primitiveTypes.put("float", float.class);
+ primitiveTypes.put("double", double.class);
+ primitiveTypes.put("boolean", boolean.class);
+ primitiveTypes.put("char", char.class);
+ primitiveTypes.put("void", void.class);
+ }
+
+ /**
+ * Overriden version that uses the parametrized ClassLoader or the ClassLoader
+ * of the current Thread to resolve the class.
+ * @param desc An instance of class ObjectStreamClass.
+ * @return A Class object corresponding to desc.
+ * @throws IOException Any of the usual Input/Output exceptions.
+ * @throws ClassNotFoundException If class of a serialized object cannot be found.
+ */
+ @Override
+ protected Class resolveClass(final ObjectStreamClass desc) throws IOException, ClassNotFoundException {
+ final String name = desc.getName();
+ try {
+ return Class.forName(name, false, classLoader);
+ } catch (final ClassNotFoundException ex) {
+ try {
+ return Class.forName(name, false, Thread.currentThread().getContextClassLoader());
+ } catch (final ClassNotFoundException cnfe) {
+ final Class cls = primitiveTypes.get(name);
+ if (cls != null) {
+ return cls;
+ } else {
+ throw cnfe;
+ }
+ }
+ }
+ }
+
+ }
+}
\ No newline at end of file
diff --git a/weixin4j-base/src/main/java/com/foxinmy/weixin4j/util/Weixin4jConfigUtil.java b/weixin4j-base/src/main/java/com/foxinmy/weixin4j/util/Weixin4jConfigUtil.java
index 4eadf343..8add27c8 100644
--- a/weixin4j-base/src/main/java/com/foxinmy/weixin4j/util/Weixin4jConfigUtil.java
+++ b/weixin4j-base/src/main/java/com/foxinmy/weixin4j/util/Weixin4jConfigUtil.java
@@ -4,11 +4,12 @@ import java.util.MissingResourceException;
import java.util.ResourceBundle;
import com.alibaba.fastjson.JSON;
+import com.foxinmy.weixin4j.model.Consts;
import com.foxinmy.weixin4j.model.WeixinAccount;
/**
* 公众号配置信息 class路径下weixin4j.properties文件
- *
+ *
* @className Weixin4jConfigUtil
* @author jinyu(foxinmy@gmail.com)
* @date 2014年10月31日
@@ -23,7 +24,7 @@ public class Weixin4jConfigUtil {
CLASSPATH_VALUE = Thread.currentThread().getContextClassLoader()
.getResource("").getPath();
try {
- weixinBundle = ResourceBundle.getBundle("weixin4j");
+ weixinBundle = ResourceBundle.getBundle(Consts.WEIXIN4J);
} catch (MissingResourceException e) {
;
}
@@ -40,7 +41,7 @@ public class Weixin4jConfigUtil {
/**
* 获取weixin4j.properties文件中的key值
- *
+ *
* @param key
* @return
*/
@@ -51,7 +52,7 @@ public class Weixin4jConfigUtil {
/**
* key不存在时则返回传入的默认值
- *
+ *
* @param key
* @param defaultValue
* @return
@@ -73,7 +74,7 @@ public class Weixin4jConfigUtil {
/**
* 判断属性是否存在[classpath:]如果存在则拼接项目路径后返回 一般用于文件的绝对路径获取
- *
+ *
* @param key
* @return
*/
@@ -82,7 +83,7 @@ public class Weixin4jConfigUtil {
}
/**
- *
+ *
* @param key
* @param defaultValue
* @return
diff --git a/weixin4j-example/pom.xml b/weixin4j-example/pom.xml
index b82d42e7..974b62a9 100644
--- a/weixin4j-example/pom.xml
+++ b/weixin4j-example/pom.xml
@@ -84,5 +84,10 @@
1.9.1
test