Mercurial > hg > Papers > 2018 > nozomi-master

<!DOCTYPE html>
<html>
<head>
   <meta http-equiv="content-type" content="text/html;charset=utf-8">
   <title>分散フレームワークChristieの設計</title>

<meta name="generator" content="Slide Show (S9) v2.5.0 on Ruby 2.1.0 (2013-12-25) [x86_64-darwin13.0]">
<meta name="author"    content="照屋のぞみ" >

<!-- style sheet links -->
<link rel="stylesheet" href="s6/themes/projection.css"   media="screen,projection">
<link rel="stylesheet" href="s6/themes/screen.css"       media="screen">
<link rel="stylesheet" href="s6/themes/print.css"        media="print">
<link rel="stylesheet" href="s6/themes/blank.css"        media="screen,projection">

<!-- JS -->
<script src="s6/js/jquery-1.11.3.min.js"></script>
<script src="s6/js/jquery.slideshow.js"></script>
<script src="s6/js/jquery.slideshow.counter.js"></script>
<script src="s6/js/jquery.slideshow.controls.js"></script>
<script src="s6/js/jquery.slideshow.footer.js"></script>
<script src="s6/js/jquery.slideshow.autoplay.js"></script>

<!-- prettify -->
<link rel="stylesheet" href="scripts/prettify.css">
<script src="scripts/prettify.js"></script>

<script>
  $(document).ready( function() {
    Slideshow.init();

    $('code').each(function(_, el) {
      if (!el.classList.contains('noprettyprint')) {
        el.classList.add('prettyprint');
        el.style.display = 'block';
      }
    });
    prettyPrint();
  } );


</script>

<!-- Better Browser Banner for Microsoft Internet Explorer (IE) -->
<!--[if IE]>
<script src="s6/js/jquery.microsoft.js"></script>
<![endif]-->


</head>
<body>

<div class="layout">
  <div id="header"></div>
  <div id="footer">
    <div align="right">
      <img src="s6/images/logo.svg" width="200px">
    </div>
  </div>
</div>

<div class="presentation">

  <div class='slide cover'>
    <table width="90%" height="90%" border="0" align="center">
      <tr>
        <td>
          <div align="center">
            <h1><font color="#808db5">分散フレームワークChristieの設計</font></h1>
          </div>
        </td>
      </tr>
      <tr>
        <td>
          <div align="left">
            照屋のぞみ
            - profile not found -
            <hr style="color:#ffcc00;background-color:#ffcc00;text-align:left;border:none;width:100%;height:0.2em;">
          </div>
        </td>
      </tr>
    </table>
  </div>

<div class='slide '>
<!-- === begin markdown block ===

      generated by markdown/1.2.0 on Ruby 2.1.0 (2013-12-25) [x86_64-darwin13.0]
                on 2018-02-06 12:15:41 +0900 with Markdown engine kramdown (1.5.0)
                  using options {}
  -->

<!-- _S9SLIDE_ -->
<h1 id="section">研究目的（1/2）</h1>
<ul>
  <li>スケーラブルで信頼性の高い分散プログラムを書くのは容易ではない
    <ul>
      <li>並列で動く分散した資源を意識するのは難しい</li>
      <li>分散したノードの選択方法が明確ではない􏱾􏱿􏰮􏳠􏲒􏰌􏰍􏰞􏰫􏷑􏷒􏱃􏱱􏲭􏰞􏰡􏰨􏰢􏱯􏱰􏰻􏰼􏰔􏰠􏳍􏳎􏰮􏰠􏰡􏲒􏰭􏲣 􏰫􏰭􏰘􏰔􏱑􏰥􏰹􏰌􏰍􏰞􏰫</li>
    </ul>
  </li>
  <li>当研究室が開発している並列分散フレームワークAliceではスケーラブルな分散プログラムを信頼性高く記述できる環境を実現する。</li>
  <li>ここで言う信頼性とは定められた環境下で安定して仕様に従った動作を行うことを指す。
    <ul>
      <li>仕様の記述のしやすさ、可読性、拡張時に仕様変更を抑えられるかも含む</li>
    </ul>
  </li>
  <li>スケーラビリティとはサービス利用者が増加したとき単純にノードを追加するだけで線形に性能を向上させる能力</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="section-1">研究目的（2/2）</h1>
<ul>
  <li>本研究では、Aliceの通信の信頼性を高めるためにNAT越えの機能設計を提案する</li>
  <li>そしてその実現にはAliceの再設計が必要であることを示す</li>
  <li>Aliceの問題点を整理し、得られた知見をもとに分散フレームワークChristieの設計を行う</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="section-2">目次</h1>
<ul>
  <li>Aliceの概要
    <ul>
      <li>Code Segment / Data Segment</li>
      <li>Data Segment Manager</li>
      <li>API</li>
      <li>Computation / Meta Computation</li>
      <li>Topology Manager</li>
      <li>圧縮</li>
    </ul>
  </li>
  <li>Topology Managerの拡張設計
    <ul>
      <li>別トポロジー間の接続のための設計</li>
      <li>別ネットワーク間の接続のための設計</li>
    </ul>
  </li>
  <li>Aliceの問題点
    <ul>
      <li>LocalDSMの複数立ち上げができない</li>
      <li>記述の煩雑さ</li>
    </ul>
  </li>
  <li>Christieの設計
    <ul>
      <li>基本設計</li>
      <li>記述性の改善</li>
    </ul>
  </li>
  <li>他フレームワークとの比較
    <ul>
      <li>Akka, Hazelcast</li>
      <li>設計思想の違い</li>
      <li>記述性の違い</li>
      <li>提供する機能 </li>
    </ul>
  </li>
  <li>まとめ</li>
  <li>今後の課題</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="data-segment--code-segment">Data Segment と Code Segment</h1>
<ul>
  <li>Aliceではデータを <strong>Data Segment(DS)</strong> 、タスクを <strong>Code Segment(CS)</strong> という単位に分割して依存関係を記述することでプログラミングを行う。</li>
  <li>CSはInput DS(入力されるDS)とOutput DS(出力されるDS)を持つ。</li>
  <li>CSはkeyで指定されたDSが揃うと実行されるという性質を持つ。
<img src="./images/dsandcs.svg" alt="opt" width="50%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="codesegment">CodeSegmentの依存関係</h1>
<ul>
  <li>データの依存関係にないCSは並列実行される</li>
  <li>データの依存関係がある場合は Input DS が揃うと順に実行される</li>
  <li>DSはCSに専有されるためロックの記述を必要としない
<img src="./images/dsandcs2.svg" alt="opt" width="60%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="data-segment--codesegment">Data Segment と CodeSegment</h1>
<ul>
  <li>AliceはJavaで実装されており、DSはJava-Object、CSはRunnableに相当する</li>
  <li>ユーザーが記述する際には CodeSegment.class を継承することでDSを操作するためのAPIを利用して依存関係を記述することができる。</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="data-segment-manager">Data Segment Manager</h1>
<ul>
  <li>DS の集合体であるデータベースを Alice では <strong>DS Manager(DSM)</strong> と呼ぶ。  </li>
  <li>DSM 内の DS には対応する一意の String型のkey が存在し、 DSM 名と key を指定しすることで DS の保存、取得を行う。
<img src="./pictures/key.svg" alt="opt" width="50%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="data-segment-manager-1">Data Segment Manager</h1>
<ul>
  <li>Local DSM … 各ノード固有のデータベース</li>
  <li>Remote DSM … 他のノードのLocal DSMのproxy。接続しているノードの数だけ存在する。</li>
  <li>Remote DSMに書き込むと対応するノードのLocalDSMに書き込まれる</li>
  <li>Remote DSMにはString型のDSM keyを指定してアクセスする
<img src="./pictures/newDSM.svg" alt="opt" width="50%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="data-segment-api">Data Segment API</h1>
<ul>
  <li>DSの取得
    <ul>
      <li><code>void take(String managerKey, String key)</code>  </li>
      <li><code>void peek(String managerKey, String key)</code>   </li>
    </ul>
  </li>
  <li>DSの追加
    <ul>
      <li><code>void put(String managerKey, String key, Object val)</code>  </li>
      <li><code>void update(String managerKey, String key, Object val)</code>  </li>
      <li><code>void flip(String managerKey, String key, Receiver val)</code>  </li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="code-segment">Code Segmentの記述例</h1>
<ul lang="java">
  <li>take/peekをするにはcreate/setKeyメソッドを使わなければならない</li>
  <li><em>create</em> でインプットDGのRecieverを作り、<em>setKey</em> でReceiverにインプットとなるkeyを指定</li>
  <li>データをReceiverから取り出す際は <em>asClass()</em> で型を指定</li>
  <li>処理をループさせたい場合はCSをnewする</li>
</ul>
<pre><code>public class TestCodeSegment extends CodeSegment {
    private Receiver input = ids.create(CommandType.TAKE);

    public TestCodeSegment() {
        input.setKey("count");
    }

    @Override
    public void run() {
        int count = input.asClass(Integer.class);
        System.out.println("data = " + count);

        new TestCodeSegment();

        ods.put("count", count);
    }
}
</code></pre>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="computation--meta-computation">Computation と Meta Computation</h1>
<ul>
  <li>Aliceでは、計算の本質的な処理をComputatin、Computationとは別のレベルでそれを支える処理をMeta Computationとして分けて考える。</li>
  <li>Alice のComputationは、keyによりDSを待ち合わせ、DSが揃ったCSを並列に実行する処理</li>
  <li>Meta Computationはそれを実現している処理
    <ul>
      <li>DSの待ち合わせ</li>
      <li>分散トポロジーの構成</li>
      <li>通信の切断・再接続時の処理</li>
      <li>データの表現形式の選択</li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="computation--meta-computation-1">Computation と Meta Computation</h1>
<ul>
  <li>分散環境構築などの複雑な処理をAliceがMeta Computationとして提供する</li>
  <li>プログラマは目的の処理だけ記述し通信部分などはMeta Computationを指定する</li>
  <li>シンプルで見通しの良いコードを保つ</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation---topology-managertopology-node">AliceのMeta Computation - Topology Manager/Topology Node</h1>
<ul>
  <li>Topology Manager
    <ul>
      <li>ノード間の接続管理やトポロジーの構成管理行うMeta Computation</li>
      <li>Static Topology ManagerとDynamic Topology Managerがある  </li>
    </ul>
  </li>
  <li>Topology Node
    <ul>
      <li>各ノード側でTopology Managerとの通信を行うMeta Computation</li>
      <li>ノードアプリケーションを記述する際にTopology Nodeをnewしておけば以降のTopology Managerとの通信やノード間の接続を行う  </li>
    </ul>
  </li>
  <li>Topology Manager/NodeもCS/DSを用いて実装されている。</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation---static-topology-manager">AliceのMeta Computation - Static Topology Manager</h1>
<ul>
  <li>プログラマがdot形式のトポロジーファイルを用意し、Topology Managerに読み込ませる</li>
  <li>トポロジーファイルにはノードの接続関係と接続する際に指定するRemote DSM名を記す</li>
  <li>Graphvizを用いればトポロジーを描くだけでトポロジーファイルが自動出力されるため構成が容易</li>
</ul>

<pre lang="dot"><code>digraph test{
	node0 −&gt; node1[label=”right”]
	node0 −&gt; node2[label=”left”]
	node1 −&gt; node2[label=”right”]
	node1 −&gt; node0[label=”left”]
	node2 −&gt; node0[label=”right”]
	node2 −&gt; node1[label=”left”]
}
</code></pre>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation---static-topology-manager-1">AliceのMeta Computation - Static Topology Manager</h1>
<ul>
  <li>ファイルを読み込んだTopology Managerを立ち上げる</li>
  <li>各Topology NodeはTopology Managerに参加表明をし接続すべきノードの情報を要求する<br />
<img src="./pictures/tree1.svg" alt="opt" width="60%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation---static-topology-manager-2">AliceのMeta Computation - Static Topology Manager</h1>
<ul>
  <li>参加表明があった順に各ノードにnodeNameを割り当て、接続するべきノードのIPアドレス/ポート番号を送る
<img src="./pictures/tree2.svg" alt="opt" width="60%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation---static-topology-manager-3">AliceのMeta Computation - Static Topology Manager</h1>
<ul>
  <li>Topology Nodeが受け取った情報をもとにRemote DSMを立ちあげ接続し合うことでオーバーレイネットワークが作られる  </li>
  <li>Topology Managerは接続情報を管理し、実際の接続はTopology Nodeが行う
<img src="./pictures/tree3.svg" alt="opt" width="60%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation---dynamic-topology-manager">AliceのMeta Computation - Dynamic Topology Manager</h1>
<ul>
  <li>参加するノード数があらかじめ決まっているとは限らない</li>
  <li>Dynamic Topology Managerがノードを参加表明順にトポロジーに組み込む</li>
  <li>現在はTree Topologyに対応</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation---">AliceのMeta Computation - 圧縮</h1>
<ul>
  <li>DSは内部に圧縮・非圧縮の複数の形式を複数もつことができる</li>
  <li>圧縮したデータの伸長と圧縮したままの転送が同時に可能
<img src="./pictures/compress.svg" alt="opt" width="80%" /> </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation----1">AliceのMeta Computation - 圧縮</h1>
<ul>
  <li>圧縮の指定には宛先DGM keyに”compressed”とつけるだけでよい
<code>put("compressedRemoteDGM", "key", data)</code></li>
  <li>伸長も <em>asClass()</em> した際に自動でされる</li>
  <li>コードの変更が抑えて圧縮・非圧縮が切り替えられる</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation----2">Aliceに求められるMeta Computation - アプリケーションの接続</h1>
<ul>
  <li>別のトポロジーをもった既存のアプリケーション同士をコードの変更を抑えつつ接続させたい</li>
  <li>AliceVNC
    <ul>
      <li>Alice上に実装したツリートポロジーの画面配信システム</li>
    </ul>
  </li>
  <li>AliceChat
    <ul>
      <li>Alice上に実装したスタートポロジーのチャット</li>
    </ul>
  </li>
  <li>連携することで実現したい機能
    <ul>
      <li>VNC画面のスナップショットをチャットに載せる</li>
      <li>チャットの内容をVNC画面にコメントとして流す</li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation----3">Aliceに求められるMeta Computation - アプリケーションの接続</h1>
<ul>
  <li>それぞれのアプリケーションのトポロジーを構成するTopologyManagerを連携させることで可能
<img src="./pictures/vncandchat.svg" alt="opt" width="70%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation---nat">Aliceに求められるMeta Computation - NATを越えた接続</h1>
<ul>
  <li>NATを越えたノード間通信は分散処理の課題である</li>
  <li>Aliceではトポロジー管理がアプリケーションから分離しているため、コードを大きく変更しなくともTopology Managerを増やすことでトポロジーの拡張が可能</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alicemeta-computation---nat-1">Aliceに求められるMeta Computation - NATを越えた接続</h1>
<ul>
  <li>各プライベートネットワーク内を管理するPrivate Topology Manager</li>
  <li>グローバルIPアドレスを持ったGlobal Topology Managerを１つ立てる</li>
  <li>TopologyNodeが複数対応できるためPrivate/Global Topology Managerに接続<br />
<img src="./pictures/overNAT.svg" alt="opt" width="70%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="topology-manager">複数のTopology Managerへの対応</h1>
<ul>
  <li>別トポロジーのアプリケーションの連携やNAT越えはノードが複数のTopologyManagerに接続することで可能になる</li>
  <li>この機能を実現するにはTopology Nodeが各Topology Managerに対応する複数のnodeNameを持つようにする必要がある</li>
  <li>Topology Nodeは割り当てられたnodeNameをDSとして保持してTopology Managerと通信を行うため、nodeNameの衝突を避けなければならない</li>
</ul>

<p><img src="./pictures/somehostname.svg" alt="opt" width="50%" /></p>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="local-dsm">Local DSMの切り替えによる対応</h1>
<ul>
  <li>通常のLocal DSMとは別にTopology ManagerごとのLocal DSMを作成しnodeNameを管理</li>
  <li>Tpology Manager/Nodeの働きはそのままに、指定するLocal DSMを変えるだけでTopology Managerの複数対応が可能<br />
<img src="./pictures/somehostname2.svg" alt="opt" width="50%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alice---localdsm">Aliceの問題点 - LocalDSMを複数立ち上げられない</h1>
<ul>
  <li>AliceではDSMを管理するクラスがstaticで書かれていたためLocal DSMを複数立ち上げることができない</li>
  <li>このstaticを抜くにはAliceのコード全体を大きく変更しなければならない</li>
  <li>アプリケーション接続やNAT越えのMeta Computationの追加が困難</li>
  <li>複数インスタンスを立ち上げての分散プログラムのテストが書けない</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alice---api">Aliceの問題点 - APIシンタックスの分離</h1>
<ul>
  <li>setKeyは記述場所が決まっておらず、CSの外からも呼べる
    <ul>
      <li>CSの再利用を可能にするが、どのkeyを待っているのか不明なCSが生まれてしまう</li>
    </ul>
  </li>
  <li>setKeyではkeyを動的に指定することができる
    <ul>
      <li>どんな処理を行っているかわかりづらい</li>
      <li>対応するput箇所も修正しなければならない</li>
      <li>モデル検査しづらくなる</li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alice---api-1">Aliceの問題点 - APIシンタックスの分離</h1>
<ul lang="java">
  <li>setKeyは全てのcreateが終わった最後に呼ばなければならない
    <ul>
      <li>Input DGの待ち合わせを行うカウンタはcreateの総数を持っている</li>
      <li>カウントが0になると入力が揃ったと判断しrunに入る</li>
      <li>countとsetKeyを交互に書くと入力が揃わないまま実行されNullPointExceptionになる</li>
    </ul>
  </li>
</ul>
<pre><code>class ShowData extends CodeSegment{
    private Receiver[] info;

    public ShowData(int cnt) {
        info = new Receiver[cnt];
        for (int i= 0;i &lt; cnt; i++) {
            info[i] = ids.create(CommandType.TAKE);
            info[i].setKey(SetInfo.array[i]);
        }
    }

    @Override
    public void run() {
        int size = 0;
        for (Receiver anInfo : info) {
            DataList dlist = anInfo.asClass(DataList.class);
            dlist.showData();
        }
    }
}
</code></pre>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alice---">Aliceの問題点 - 型が推測できない</h1>
<ul>
  <li>Input DSをReceiver型でcreateするため、どの型のデータを待っているのかわからない</li>
  <li>しかしReceiverからデータを取り出すにはasClass()で型を指定する必要がある</li>
  <li>型をDSをputした箇所までコードをたどる必要がある
    <ul>
      <li>flipでの転送もあるため、それを発見するのは容易ではない</li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="alice----1">Aliceの問題点 - まとめ</h1>
<ul>
  <li>以下の問題がAliceの信頼性・拡張性を下げている
    <ul>
      <li>Local DSMを複数立ち上げられないため、Topology Managerの拡張やテストが困難</li>
      <li>インプットAPIが分離しているためCSでどんな処理が行われているかわかりづらい</li>
      <li>setKyeの記述順序や型を気にしてプログラミングをしなくてはならない</li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie">分散フレームワークChristieへの必要要件</h1>
<ul>
  <li>Aliceの問題点を踏まえ、フレームワークをChristieを設計する
    <ul>
      <li>staticなLocalDSMをなくし複数インスタンスを立ち上げられるようにすることでスケーラビリティを高める</li>
      <li>煩雑なAPIをシンプルにし、記述性を高める</li>
      <li>型の整合性をとれるようにし、信頼性を向上させる</li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie---">Christie - 基本設計</h1>
<ul>
  <li>Javaで実装される</li>
  <li>将来的に当研究室で開発しているGearsOSに統合したい
    <ul>
      <li>GearsOSに倣い、Code Gear(CG)/ Data Gear(DG) という名称を用いる</li>
    </ul>
  </li>
  <li>CG/DGの依存関係や、DG Manager（DGM）の構造、Remote DGMへの接続方法はAliceと同様である</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie----1">Christie - 基本設計</h1>
<ul>
  <li>DGMはLocalもRemoteも全てCode Gear Manager(CGM)が管理する</li>
  <li>1つのCGMは1つのLocalDGMを持つ</li>
  <li>CGM同士はThreadPoolとCGMのリストを共有している
    <ul>
      <li>メタ計算で全てのCGMにアクセス可能
<img src="./pictures/ChristieClass.svg" alt="opt" width="60%" /></li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie----2">Christie - 基本設計</h1>
<ul>
  <li>CG を記述する際は Alice同様CodeGear.classを継承</li>
  <li>CGは　<em>void run(CodeGearManager cgm)</em> を持ち、run メソッド内に処理を記述
    <ul>
      <li>このようにCGMを持ち運ぶ書き方はGearsOSに合わせてた書き方</li>
    </ul>
  </li>
  <li>CGを作るためのAPIにはCGM経由で呼び出す</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie---dgm">Christie - DGMの複数立ち上げ</h1>
<ul>
  <li>ChristieではCGMを2つ生成すればLocalDGMも2つ作られる</li>
  <li>複数のLocalDGM同士のやりとりは、Remoteへの接続と同じようにRemoteDGMを介してアクセスする</li>
  <li>分散プログラムのローカルでのテストが可能になる
<img src="./pictures/DGM.svg" alt="opt" width="50%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie---cg">Christie - CGの生成方法</h1>
<ol>
  <li>StartCodeGear.classを継承しCGMを生成する</li>
  <li>CGをnewしたあと<em>setup</em>を用いる
    <ul>
      <li>newが終わらないとアノテーションから待ち合わせを行う処理ができないため</li>
      <li>このときCGMがCGに渡されるため、プログラマが引数にCGMを渡す必要はない</li>
    </ul>
  </li>
</ol>

<pre lang="java"><code>public class StartTest extends StartCodeGear{//StartCG

    public StartTest(CodeGearManager cgm) {
        super(cgm);
    }

    public static void main(String args[]){
        StartTest start = new StartTest(createCGM(10000));//CGMを生成
    }

    @Override
    protected void run(CodeGearManager cgm) {
        cgm.setup(new TestCodeGear());//CGの待ち合わせを開始
        getLocalDGM().put("count", 1);
    }
}
</code></pre>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie----3">Christie - アノテーションを用いたインプット記述</h1>
<ul>
  <li>keyの指定にはJavaのアノテーションを用いる
    <ul>
      <li>先頭を@で始める注釈</li>
      <li>独自アノテーションを定義できる</li>
    </ul>
  </li>
  <li>アノテーションから待ち合わせを行う処理にはJavaのreflectionAPIを使用</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie----4">Christie - アノテーションを用いたインプット記述</h1>
<ul lang="java">
  <li>InputのためのDGを宣言し、その上にアノテーションでkeyを指定</li>
  <li>Takeの例</li>
</ul>
<pre><code>@Take(”count”)
public DataGear&lt;Integer&gt; count = new DataGear&lt;&gt;();
</code></pre>
<ul lang="java">
  <li>RemoteTakeの例</li>
</ul>
<pre><code>@RemoteTake(dgmName="remote", key=”count”)
public DataGear&lt;Integer&gt; count = new DataGear&lt;&gt;();
</code></pre>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie----5">Christie - アノテーションを用いたインプット記述</h1>
<ul>
  <li>アノテーションは必ずフィールドに付けなければならない
    <ul>
      <li>InputDGの生成とkeyの指定を一箇所に書ける</li>
    </ul>
  </li>
  <li>アノテーションの内容はコンパイル時に決定される
    <ul>
      <li>動的なkey指定を防ぐ</li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie----6">Christie - 型を指定しないデータ取り出し</h1>
<ul lang="java">
  <li>InputDGを宣言する際には必ず型の指定が必要となるため、CG内で型を把握できる</li>
  <li>DataGearはJavaの総称型を用いて&lt;&gt;内に指定した型を受け取る</li>
</ul>
<pre><code>@Take(”count”)
public DataGear&lt;Integer&gt; count = new DataGear&lt;&gt;();
</code></pre>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie----7">Christie - 型を指定しないデータ取り出し</h1>
<ul lang="java">
  <li>宣言された型は内部で保存され、ノード間通信でも保たれる</li>
  <li>AliceのasClass()と違い、getData()で型を指定せずにデータを取り出すことができる</li>
</ul>
<pre><code>public class GetData extends CodeGear{ @Take(”name”)
    public DataGear&lt;String&gt; name = new DataGear&lt;&gt;();

    @Override
    protected void run(CodeGearManager cgm) {
        System.out.println(”this name is : ” + name.getData());
    }
}
</code></pre>
<ul>
  <li>取得したDGが待ち合わせに指定した型と違う場合はエラーになる</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie----8">Christie - まとめ</h1>
<ul>
  <li>CodeGearManagerというDGMの管理機構を作ったことでLocalDGM複数立ち上げが可能になった
    <ul>
      <li>テストや機能拡張がしやすくなった</li>
    </ul>
  </li>
  <li>アノテーションを用いたことでDG生成とkey指定の分離問題を解決し、処理の見通しを良くした</li>
  <li>型の整合性を保証することで信頼性が向上した</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie-1">Christieと他フレームワークの比較</h1>
<ul>
  <li>Christieの特徴を述べるために他の分散フレームワークとしてAkka、Hazelcastと比較を行う</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie---akka">Christieと他フレームワークの比較 - Akka</h1>
<ul>
  <li>アクターモデル
    <ul>
      <li>アクターと呼ばれるオブジェクト同士が並列で非同期メッセージを送受信するモデル</li>
    </ul>
  </li>
  <li>アクターは固有のアドレス持つ
    <ul>
      <li>ローカルアクターにもリモートアクターにもアドレス指定でメッセージを送受信</li>
    </ul>
  </li>
  <li>アクターはメールボックスというキューを持つ
    <ul>
      <li>受け取ったメッセージをパターンマッチで順次処理</li>
      <li>パターンマッチにはScalaのcase classを用いられる
<img src="./pictures/Akka.svg" alt="opt" width="50%" /></li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie---hazelcast">Christieと他フレームワークの比較 - Hazelcast</h1>
<ul>
  <li>キーと値の1対1でデータを管理するインメモリ・データグリッド
    <ul>
      <li>複数のノードに分散させたデータを、仮想的な1つのメモリ空間に見せるモデル</li>
      <li>プログラマがサーバを意識せずに共有のタプルスペースに対してデータをget/put</li>
    </ul>
  </li>
  <li>共有のタプルスペースに書き込むとマルチキャストで全サーバにデータが送られる
<img src="./pictures/Hazelcast.svg" alt="opt" width="50%" /></li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie----9">Christieと他フレームワークの比較 - 設計思想</h1>
<ul>
  <li>AkkaやHazelcastはロケーション透過性が高く、分散プログラムの煩雑な処理を抽象度を高めることで隠している</li>
  <li>Christieでは分散性を明示的に意識しながら記述できるためチューニングしやすい</li>
  <li>通常計算とメタ計算に分けているため複雑さを下げている</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="christie----10">Christieと他フレームワークの比較 - 記述性</h1>
<ul>
  <li>アノテーションを使ったインプットの指定はAkkaやHazelcastにはない</li>
  <li>複数のインプットを待ち合わせして処理を行いたい場合
    <ul>
      <li>Akkaは待ち合わせ処理をプログラマが書かなければならない</li>
      <li>Christieでは複数のインプットを記述でき待ち合わせ処理が必要ない</li>
    </ul>
  </li>
  <li>データの圧縮通信を指定したい場合
    <ul>
      <li>Akka、Hazelcastでは圧縮メソッドが用意されているため、それを用いて記述する</li>
      <li>ChristieではDGMkeyの名前を変えるだけなのでメソッド呼び出しの記述が必要ない</li>
    </ul>
  </li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="section-3">まとめ</h1>
<ul>
  <li>AliceのプロトコルやMeta Computationを説明し、TopologyManagerを用いたNAT越えの手法を示した</li>
  <li>Aliceの問題点を整理し、再設計の必要性を述べた</li>
  <li>LocalDGMの複数立ち上げを可能にし、テストや機能拡張がしやすい環境を整えた</li>
  <li>Christieではアノテーションを用いたAPIで信頼性の高い記述を実現した</li>
  <li>Christieを他のフレームワークと比較し、分散性を意識して記述できる特徴があることを述べた</li>
</ul>


</div>
<div class='slide '>
<!-- _S9SLIDE_ -->
<h1 id="section-4">今後の課題</h1>
<ul>
  <li>DataGearのメタレイヤーへの移行</li>
  <li>TopologyManagerの実装</li>
  <li>実用性の検証</li>
  <li>Jungleとの統合</li>
  <li>GearsOSへの移行</li>
</ul>

<style type="text/css">
<!--
*{
	font:nomal 100% 'PT Sans';
}

ul > li{
	list-style-type:disc;
}

.slide h1{
	text-align:left;
	color:#777777;
	font:bold 40px/1.13 'PT Sans', sans-serif;
	margin-bottom: 50px;
}

div#slide1 h1{
	text-align:left;
	color:#777777;
	font:bold 60px 'PT Sans', sans-serif;
	margin-bottom: 50px;
}

pre > code{
	font-family:'Droid Sans Mono', 'Courier New', monospace;
}

img[alt="opt"]{
	display: block;
	margin-left: auto;
	margin-right: auto;
}

img[alt="right"]{
	margin-right: 0;
}

table {
	margin-left: auto;
	margin-right: auto;
}

th {
    font-size: 120%;
}
-->
</style>

<!-- === end markdown block === -->
</div>


</div><!-- presentation -->
</body>
</html>
author	Nozomi Teruya <e125769@ie.u-ryukyu.ac.jp>
date	Tue, 06 Feb 2018 12:19:12 +0900
parents	055266d62d84
children	a3ee75a897f3