13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
1 title: 分散フレームワークAliceの圧縮機能
|
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
2 author: 照屋のぞみ
|
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
3 profile:琉球大学 工学部 情報工学科 4年
|
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
4
|
|
17
|
5 # 研究目的
|
|
|
6 * 並列分散フレームワークAliceではスケーラブルな分散プログラムを信頼性高く記述できる環境を実現する。
|
|
|
7 * Aliceのメタ計算として通信が切断した際の処理やデータを圧縮する処理等を提供することで、プログラマがコードを大きく変更することなくプログラムの振る舞いを変えることを可能にする。
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
8
|
|
17
|
9 # Aliceの概要(1) - Data Segment と Code Segment
|
|
|
10 * Aliceではデータを **Data Segment(DS)** 、タスクを **Code Segment(CS)** という単位に分割してプログラミングを行う。
|
|
|
11 * AliceはJavaで実装されており、CS をユーザーが記述する際には CodeSegment.class を継承することで CS で使用する API を利用する事ができる。
|
|
|
12 * DSはAliceが内部にもつデータベースにより管理されており、CSはDSに対応する一意のkeyを使ってDSを操作する。
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
13
|
|
17
|
14 # Aliceの概要(2) - Data Segment と Code Segment
|
|
|
15 * CSはInput DS(入力されるDS)とOutput DS(出力されるDS)と呼ぶ。
|
|
|
16 * CSはkeyで指定されたDSが揃うと実行されるという性質を持つ。
|
|
|
17 
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
18
|
|
17
|
19 # Aliceの概要(3) - CodeSegmentの依存関係
|
|
|
20 * データの依存関係にないCSは並列実行される
|
|
|
21 * データの依存関係がある場合は Input DS が揃うと順に実行される
|
|
|
22 
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
23
|
|
17
|
24 # Aliceの概要(4) - Data Segment
|
|
|
25 * 整数や文字列などの基本的なデータの集まり
|
|
|
26 * Aliceの場合はJavaオブジェクトに対応
|
|
|
27
|
|
|
28 # Aliceの概要(5) - Data Segment Manager
|
|
|
29 * DS の集合体であるデータベースを Alice では DS Manager(DSM) と呼ぶ。
|
|
|
30 * DSM 内の DS には対になる String型のkey が存在し、 key を指定しすることで DS の保存、取得を行う。
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
31 
|
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
32
|
|
17
|
33 # Aliceの概要(6) - Data Segment Manager
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
34 * Local DSM … 各ノード固有のデータベース。
|
|
17
|
35 * Remote DSM … 他のノードの Local DSM の proxy。接続しているノードの数だけ存在する。
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
36 {:width="450px"}
|
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
37
|
|
17
|
38 # Aliceの概要(7) - Data Segment API
|
|
|
39 DSM に対して DSM の名前と DS を指し示すkey を指定することで操作を行う
|
|
|
40 * DS の追加
|
|
|
41 put(String managerKey, String key, Object val)
|
|
|
42 * DS の取得
|
|
|
43 take(String managerKey, String key)
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
44
|
|
17
|
45 # Aliceの概要(8) - Data Segment の表現
|
|
|
46 DSは複数の表現（多態性）を同時に持つ
|
|
|
47 1. 一般的な Java のクラスオブジェクト
|
|
|
48 2. MessagePack for Java でシリアライズ化されたバイナリオブジェクト。Remoteとの通信の際に用いる。
|
|
|
49 3. 2 を圧縮したバイナリオブジェクト。圧縮機能の一部として今回追加。
|
|
|
50
|
|
|
51 # MessagePackとは
|
|
|
52 シリアライズのための機能をまとめたライブラリであり、プログラミング言語に依存しないデータの表現形式として使用できる。
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
53
|
|
17
|
54 # Aliceの概要(9) - Code Segment
|
|
|
55 * setKey()にtakeコマンドをセットすることで Input DS を指定する
|
|
|
56 * 実際にtakeしたデータを参照するときには、asClass()を用いて任意のJavaのオブジェクトとして扱えるようにする
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
57
|
|
17
|
58 # Computation と Meta Computation
|
|
|
59 * Aliceでは、計算の本質的な処理をComputatin、Computationとは直接関係ないが別のレベルでそれを支える処理をMeta Computationとして考える
|
|
|
60 * これにより通常処理と例外処理を分離できるためシンプルなプログラムが記述可能
|
|
14
|
61
|
|
17
|
62 # Alice の Computation
|
|
|
63 * keyによりDSを待ち合わせ、DSが揃ったCSを並列に実行する
|
|
|
64 * VNCの場合、VNCサーバからデータを受け取って表示する処理
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
65
|
|
17
|
66 # Alice の Meta Computation
|
|
|
67 * 通信の切断・再接続時の処理や分散トポロジーの構成、データの表現形式の選択など、Computationを支えている処理。
|
|
|
68 * VNCの場合、VNCサーバのデータを各VNCノードにコピーする処理。
|
|
|
69 * Aliceの機能を追加するということは Meta Computation を追加すると言い換えられる
|
|
|
70
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
71
|
|
14
|
72 # AliceのMeta Computation(1/2)
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
73 * Aliceではプログラマが記述する部分を *Computation*、Aliceが提供するComputationを支える部分を *Meta Computation* として分けて捉えている。
|
|
14
|
74 * 分散環境の構築等の処理等は全てMeta Computationが行うためプログラマがシンプルに分散プログラムを記述できる環境を提供している。
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
75
|
|
17
|
76 # TreeVNC
|
|
|
77 * AliceのMeta Computationを用いて実装する実用的な分散プログラムの例題
|
|
|
78 * 本研究室で開発したノードを木構造に配置して負荷分散を行う授業向け画面共有システム
|
|
|
79 * TightVNCがもとになっており、この部分がComputationと言える
|
|
14
|
80 
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
81
|
|
17
|
82 # TreeVNCで用いるAliceのMeta Computation
|
|
|
83 * TreeTopologyの構成
|
|
|
84 * ノード間通信の切断時・再接続時の処理
|
|
|
85 * データの圧縮
|
|
|
86 * 子ノードへのデータの複製
|
13
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
87
|
Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
parents:
diff
changeset
|
88
|
|
17
|
89 # TreeVNCでの圧縮 Meta Computation
|
|
|
90 # データの転送 - DSMとAPIの追加
|
|
14
|
91 * Local と Remote それぞれに圧縮表現を扱う Compressed DSM を追加した。
|
|
17
|
92 * 指定する DSM を Compressed DSM に変えるだけで扱うデータ表現を変更できる
|
|
|
93 put(String **"compressed"** + managerKey, String key, Object val)
|
|
|
94 take(String **"compressed"** + managerKey, String key)
|
|
14
|
95
|
|
17
|
96 # データの転送 - データ表現の自動生成
|
|
|
97 * DS が圧縮表現を持っていれはそれをそのまま子ノードにputする
|
|
|
98 * 持っていなければその時点でCompressed DSM内部で圧縮表現を生成してputする
|
|
|
99 * DS はオブジェクト表現と圧縮表現を同時にもつため、TreeVNCでは受け取った画面データを伸長をした後、転送のために再圧縮することはない。
|
|
16
|
100
|
|
17
|
101 # データの受け取り - 任意の形式での取得
|
|
|
102 * 圧縮表現で画面データ受け取り、Compressed DSM 内に格納。
|
|
|
103 * TightVNCが画面表示のためにデータを必要としたときに、 asClass() を用いて任意の形式でデータを取り出す。
|
|
|
104 * asClass() は DS のcastメソッドであり、伸長と MessagePack での変換を行う。
|
|
16
|
105
|
|
17
|
106 # データの受け取り - Aliceの通信パケットの変更
|
|
|
107 * 通信ヘッダにデータの状態を表すフラグを追加したことで、受け取ったデータを適切な形式でDSM内に格納できる。
|
|
|
108 * 圧縮前と圧縮後のデータサイズを入れたことにより、受け取ったデータの適切な伸長が可能。
|
|
16
|
109 <table style="border-collapse: collapse;border:1px solid #000000;">
|
|
|
110 <td style="border:1px solid #000000;"> serialized </td>
|
|
|
111 <td style="border:1px solid #000000;">データ本体のシリアライズ状態を示す</td>
|
|
|
112 </tr>
|
|
|
113 <tr>
|
|
|
114 <td style="border:1px solid #000000;"> compressed </td>
|
|
|
115 <td style="border:1px solid #000000;">データ本体の圧縮状態を示す</td>
|
|
|
116 </tr>
|
|
|
117 <tr>
|
|
17
|
118 <td style="border:1px solid #000000;"> objectDataSize </td>
|
|
|
119 <td style="border:1px solid #000000;">圧縮前のオブジェクトのデータサイズを表す</td>
|
|
|
120 </tr>
|
|
|
121 <tr>
|
|
16
|
122 <td style="border:1px solid #000000;"> dataSize </td>
|
|
17
|
123 <td style="border:1px solid #000000;">送信するDSのデータサイズを表す</td>
|
|
16
|
124 </tr>
|
|
|
125 </table>
|
|
|
126
|
|
17
|
127 # Aliceと他言語等との比較
|
|
14
|
128
|
|
|
129 # まとめ
|
|
17
|
130 * Alice が実用的なアプリケーションを記述するための Meta Computation として、データに多態性を持たせ、指定するDSMによってデータ表現を変える機能を実装した。
|
|
14
|
131 * これによりユーザが記述する Computation 部分を大きく変えずに自由度の高い通信を行うことが可能になった。
|
|
|
132 * 同様の手法により、暗号形式・JSON 形式など複数のデータ表現を扱えるように拡張できる。
|
|
17
|
133 * 今後の課題としては、圧縮機能を TreeVNC で用 いることで有効性を測る必要がある。
|
