天使やカイザーと呼ばれて

動的プロキシをシリアライズする具体的方法

「Javassistを使った動的プロキシの作成」エントリと「替わりのオブジェクトをシリアライズするwriteReplace()/readResolve()」エントリを組み合わせると，実行時にその場で作った動的プロキシクラスを元にnewしたインスタンスをシリアライズし，異なるJavaVMプロセスにてデシリアライズできるようになる。今回はその具体的な方法を紹介しよう。

まずは，動的プロキシの対象となる抽象クラスを以下とする。これは「Javassistを使った動的プロキシの作成」で取り上げたものと同一である。

<br /> package test;<br /> public abstract class Component {<br /> private int cnt;<br /> public abstract void onClick();<br /> public void output() {<br /> System.out.println(cnt++);<br /> }<br /> }<br />

このクラスはabstractなため，当然そのままではnewできない。そこで，動的プロキシクラスの登場である。onClick()メソッドの実装として，output()メソッドを呼び出すだけの実装コードを持つ動的プロキシクラスの生成処理が以下である。

<br /> package test;<br /> public class ProxyFactory {<br /> public static Class createClass(String proxyClassName) {<br /> ClassPool cp = ClassPool.getDefault();<br /> CtClass componentCC = cp.get(“test.Component”);<br /> CtClass proxyCC = cp.makeClass(proxyClassName, componentCC);<br /> CtClass serializableCC = cp.get(“java.io.Serializable”);<br /> proxyCC.addInterface(serializableCC);<br /> CtMethod onClickMethod = CtMethod.make(<br /> “public void onClick() {”<br /> + ” output();”<br /> + “}”, proxyCC);<br /> proxyCC.addMethod(onClickMethod);<br /> CtMethod writeReplaceMethod = CtMethod.make(<br /> “public Object writeReplace() throws ObjectStreamException {”<br /> + ” java.util.Map fieldMap = new java.util.HashMap();”<br /> + ” java.lang.reflect.Field[] fields = ”<br /> + ” test.Component.class.getDeclaredFields();”<br /> + ” for (int i = 0; i < fields.length; i++) {"<br /> + " f.setAccessible(true);"<br /> + " if (!java.lang.Modifier.isTransient(f.getModifiers())) {"<br /> + " fieldMap.put(f.getName(), f.get(this));"<br /> + " }"<br /> + " }"<br /> + " return new test.SerializedObject(\"" + proxyClassName + "\", fieldMap);"<br /> + "}", proxyCC);<br /> proxyCC.addMethod(writeReplaceMethod);<br /> Class proxyClazz = proxyCC.toClass();<br /> return proxyClazz;<br /> }<br /> }<br />

動的プロキシクラスの生成処理を，ProxyFactory#createClass()メソッドに定義しているコードである。createClass()メソッドには，動的プロキシのクラス名を指定できるようにしている。onClick()メソッドのオーバーライドだけでなく，writeReplace()メソッドに関しても，動的プロキシクラスに追加しているのが見てとれるだろう。writeReplace()メソッド内では，シリアライズ対象となる自分自身が持つフィールドの値を（transient修飾子が付けられたもの以外に対して）取得し，フィールド名と値の組み合わせを持つコレクションを作成している。これと，createClass()メソッドの引数で受け取った動的プロキシのクラス名を引数に渡して，SeriarlizedObjectオブジェクトを生成し，そのオブジェクトを替わりのシリアライズ対象として返却している。

SerializedObjectクラスは，コレクションとクラス名を持つ単純なクラスではあるが，readResolve()メソッドを持っていることが特徴的である。

<br /> package test;<br /> import java.util.Map;<br /> public class SerializedObject implements java.io.Serializable {<br /> private String className;<br /> private Map fieldMap;<br /> public SerializedObject(String className, Map fieldMap) {<br /> this.className = className;<br /> this.fieldMap = fieldMap;<br /> }<br /> public String getClassName() {<br /> return className;<br /> }<br /> public Map getFieldMap() {<br /> return fieldMap;<br /> }<br /> public Object readResolve() throws ObjectStreamException {<br /> Class clazz = ProxyFactory.createClass(className);<br /> Object result = clazz.newInstance();<br /> Set entrySet = fieldMap.entrySet();<br /> for (java.util.Iterator i = entrySet.iterator(); i.hasNext(); ) {<br /> Map.Entry entry = (Map.Entry)i.next();<br /> java.lang.reflect.Field field =<br /> Component.class.getDeclaredField((String)entry.getKey());<br /> field.setAccessible(true);<br /> field.set(result.entry.getValue());<br /> }<br /> return result;<br /> }<br /> }<br />

readResolve()メソッドでは，保持しておいたクラス名を元に動的プロキシクラスを生成し，そのインスタンスも生成する。そして保持しておいたフィールドの値を１つずつ生成したインスタンスにセットし，そのインスタンスをデシリアライズ結果として返却している。

ほとんどの例外処理をすっとばしたコードなので，そのままではコンパイルエラーとなるが，本質的な処理は以上である。あとは，以下のように，

<br /> Component c = (Component)(ProxyFactory.createClass(“Proxy”).newInstance());<br /> c.onClick();<br /> FileOutputStream fos = new FileOutputStream(“./test.ser”);<br /> ObjectOutputStream out = new ObjectOutputStream(fos);<br /> out.writeObject(c);<br />

として実行結果「0」を得てJavaVMを一旦終了し，次に，

<br /> FileInputStream fis = new FileInputStream(“./test.ser”);<br /> ObjectInputStream in = new ObjectInputStream(fis);<br /> Component c = (Component)in.readObject();<br /> c.onClick();<br />

としてあげれば，実行結果「1」を得ることができるだろう。Javassistによって生成した動的プロキシに関しても，writeReplace()/readResolve()メソッドの機構をうまく利用することで，シリアライズが実現可能になることを上記の例は示してくれている。

DIコンテナの普及のおかげで，動的プロキシの生成を自前で行う機会はそう多くないかもしれない。しかし，動的プロキシによって実現できることは多岐に渡るため，知ってるのと知らないのとでは雲泥の差がある。もちろん「ご利用は計画的に」なのは言うまでもないが。。

Posted:

04.20.2007

Category:

Java

Trackback URL: