Socket 通信

Topへ

概要：ETIでSocket通信を行なうためのビルトインルール群です。これらのルールにはプレフィックスとしてic::がつきます。これらのルールを有効にするためにはic.dllをロードする必要があります。

/**
 *Socketによる接続の例
 *
 *このサンプルは、始めにETIで(test2)を実行しサーバを起動して、その後別のETIで(test1)を実行する。
 *(test2)で(test1)から要求されたappに関するクエリを実行しその結果をクライアント(test1)に返す。
 */

//********************************************クライアントの例**************************************
/**
 *サーバに接続して、アペンドに関するクエリを送信し、実行結果を受け取る。
 */
(test1)-->
(loadModule "ic.dll" *m),//モジュールロード
(gsetv CONTINUE yes),
(ic::asyncConnect "127.0.0.1" 45678 *ic),//127.0.0.1にポート番号45678で接続する。*icは接続を表す識別子。
(ic::sendString *ic "(((ans (app *1 *2 (1 2 3 4 5 6 7 8 9 10))) (app *1 *2 (1 2 3 4 5 6 7 8 9 10))(app *1 *3 *4) ))" *len1),//文字列を送る。*len1は送ったデータの長さ(終端記号を含む)。
(cloop *ic),
(getv ANS *s),
(print *s),
(ic::asyncDisconnect *ic *Re),//切断
(ic::cleanup ?),//socket開放
(freeModule *m).//モジュール開放

/**
メッセージループ
*/
(cloop *ic),{(ggetv CONTINUE yes)}-->
(ic::getMessage *m),(cmh *m *ic), (cloop *ic).
(cloop *ic)-->.

//メッセージハンドラ
/**
クライアントが接続したときの処理
*/
(cmh (CONNECT *socket) *ic)-->
(printf "connected to %d.\n" (*socket)),
(ggetv CL *n),(:= *nn (+ *n 1)),(gsetv CL *nn).

/**
メッセージを受け取ったときの処理
*/
(cmh (RECEIVE *socket) *ic)-->
(ic::getText *ic *text),(sread *text *s), (setv ANS *s), (gsetv CONTINUE no).
/**
クライアントが切断したときの処理
*/
(cmh (DISCONNECT *socket) *ic)-->
(printf "disconnected from %d.\n" (*socket)),
(ggetv CL *n),(:= *nn (- *n 1)),(gsetv CL *nn),
(continue *nn).

/**
 *その他
 */
(cmh ? *ic)-->.

//**********************************************サーバの例******************************************
/**
 *サーバとしてクライアントからクエリを受け取り実行して結果を送信する
 */
(test2)-->
(loadModule "ic.dll" *m),
(ic::initializeServer 45678 *ic),//サーバを初期化し起動する。*icはサーバの識別子
(loop *ic),//メッセージループ
(ic::cleanup ?),//ソケット開放
(freeModule *m).//モジュール開放

/**
 *メッセージループ
 */
(loop *ic)-->(ic::getMessage *m), (mh *m *ic), (loop *ic).

//メッセージハンドラ
/**
 *クライアントが接続したときの処理
 */
(mh (CONNECT *socket) *ic)-->
(printf "connected to %d.\n" (*socket)).

/**
 *メッセージを受け取ったときの処理
 */
(mh (RECEIVE *socket) *ic)-->
(ic::getText *ic *socket *text),
(sread *text *clauses),
(createRootWorld *w),
(setDDWorld *clauses *w),
(callRootWorld *w 1000),
(getDDWorld *newClauses *w),
(sformat *s "/a" (*newClauses)),
(killRootWorld *w),
(ic::sendString *ic *socket *s *len).
/**
 *クライアントが切断したときの処理
 */
(mh (DISCONNECT *socket) *ic)-->
(printf "disconnected from %d.\n" (*socket)).
/**
 *その他
 */
(mh ? ?)-->.


(Rule app (Head (app *X *Y *Z))
(Body (exec (= *X ())(= *Y *Z)))
(Body (exec (= *X (*A|*X1))(= *Z (*A|*Z1)))(app *X1 *Y *Z1)))