ソケット通信を行うサーバープログラムは通常デーモンとして動作します。
サーバーデーモンは通常、接続をまつ親プロセスがいて、クライアントとからの接続要求を処理し、
クライアントと接続したあとの実際のデータ処理部分は、子プロセスを起動してそちらにまかせ、
自分は、次のクライアント接続要求に備えるという動きをします。
この機能のサポートの為、よく使用されるのは、プロセスまたはスレッドです。
しかし、残念ながらＲＰＧでは、上記のいずれの機構もサポートしていません。
そのため、前項のサンプルプログラム(SOKRPGSVR)では、１つのサーバーＰＧＭ当たり１つのクライアント
しかサポート出来ませんでした。（１クライアントが接続すると、LISTENポートをクローズして、クライアント
との通信を処理するようになっています。このようなプログラムのロジックでは、次のクライアントも接続
出来るようにするためには、別途サーバーＰＧＭを実行する必要があります。）
ＲＰＧでは、ＲＰＧ内でＣＡＬＬで呼びだしを行うと、そのＰＧＭがリターンするまで、呼び出し元のＲＰＧ
の実行は止まってしまいます。これでは、次のクライアントの接続要求を処理することはできません。
ＳＢＭＪＯＢでバッチＪＯＢとして投入する方法も考えられますが、この方法だと、たしかに、実行は並列が
可能ですが、バッチＪＯＢは、独自のＪＯＢとして起動されるため、ソケットの接続をそのバッチＪＯＢに
渡す方法が難しくなってしまいます。
ＲＰＧでの解決策は？
- ＲＰＧからプロセスサポートのプログラムを呼び出す
子プロセス起動するためのＣのプログラムを作成し、ＲＰＧからコールする。
起動する子プロセスでは、まずＣのプログラムが動き、そのプログラムより、指定された
ＲＰＧを起動する。プロセス間のコントロールなどは、中間に位置するＣのプログラムで
行い、ＲＰＧでは考慮しなくてよいようにする。
- ＲＰＧからスレッドサポートのプログラムを呼び出す
スレッド起動するためのＣのプログラムを作成し、ＲＰＧからコールする。
起動するスレッドではでは、まずＣのプログラムが動き、そのプログラムより、指定された
ＲＰＧを起動する。だだし、この方法を取る場合、ＲＰＧ自体もスレッドセーフな処理を
考慮する必要があると考えられる。
- 異なるＪＯＢ間で、ソケットディスクリプターを渡せるようにする
Takedescriptor()/Givedescriptor()を使用して、ＪＯＢ間でソケットディスクリプターを受け渡す
ただし、この関数が、相手のJOBIDを必要とするため、単純なCALLだけでは処理ができない。
が考えられます。
今回は、ＲＰＧでの考慮をできるだけしたくないので、
１．ＲＰＧからプロセスサポートのプログラムを呼び出す
方法で実装したいと思います。
それでは、まずプロセスを呼び出すＣのプログラムを用意しましょう
| プロセス関数 | Ｃのプログラム名 | 説 明 |
| spawn() | SKSPWN | 子プロセスの生成 |
| .. | SKCHLD | 子プロセス実行 |
上記のＰＧＭはSocket RPGとして、一つのパッケージにまとめました。
それでは実際に、これらのプログラムを利用して、
ＲＰＧによるサーバーデーモン型ソケット通信のプログラムを作成してみましょう
作成するサンプルのＲＰＧは、以下の様なプログラムとします。
| サーバーデーモンＲＰＧ |
クライアントＲＰＧ |
１．ソケットのオープン
SKOPENプログラムによりソケットをオープンします。SKOPENでは、setsocketオプションで、
TCP_NODELAY,SO_REUSEADDRをセットしています。
|
１．ソケットのオープン
SKOPENプログラムによりソケットをオープンします。SKOPENでは、setsocketオプションで、
TCP_NODELAY,SO_REUSEADDRをセットしています。
|
２．バインド
SKBINDプログラムによりソケットにＩＰアドレス／ポート番号を割り当てます。
SKBINDでは、明示的なＩＰ割り当ての代わりにＡＮＹとしてどのインターフェースからの
接続要求についても受けとれります。
|
なし |
３．リッスン
SKLISNプログラムにより、クライアントからの接続要求の受け入れ準備をします。
|
なし |
| なし |
４．コネクト
SKCONNプログラムにより、サーバーに接続を行います。ＩＰアドレスは、
構内ループバックアドレス（１２７．０．０．１）を指定しているので、サーバーと同じマシン上で
クライアントも実行すると仮定しています。
|
５．アクセプト
SKACPTプログラムにより、クライアントからの接続要求を受け入れます。
この際に、新しいソケットディスクリプターがシステムにより与えられます。これ以降の通信は
ここで割り当てられた新しいディスクリプターを使用します。
|
なし |
６．子プロセス作成
SKSPWNプログラムにより、パラメーターに子プロセスプログラム(SOKRPGUP)と
５．アクセプトで入手したソケットデイスクリプターを指定し、子プロセスを起動します。
”５．アクセプトへ戻る”
|
なし |
| 子プロセスＲＰＧ |
なし |
７．子プロセス起動
SKSPWNにより呼び出されたSKCHLDプログラムからRPG(SOKRPGUP)が起動されます。
ＲＰＧは、SKCHLDプログラムからソケットディスクリプターをパラメーターとして受け取ります。
|
なし |
８．データ受信
SKRECVプログラムを使用し、クライアントから送信された文字列を受信します
|
８．データ送信
SKSENDプログラムにより、画面から入力された文字列を送信します。
|
９．データ送信
SKSENDプログラムにより、８．でクライアントから受信した文字列をそのまま送信します。
（エコー処理）
|
９．データ受信
SKRECVプログラムにより、サーバーから送信された文字列を受信し、画面表示します。
（エコー処理）
|
１０．ソケットクローズ
文字列［EXIT]が送られてきた場合は、SKCLOSプログラムにより、ソケットのクローズを行います。
|
１０．ソケットクローズ
画面からＦ３が押されるか、サーバープログラムが終了した場合は、SKCLOSプログラムにより、ソケットのクローズを行います。
|
