チャットサーバを改良する（入出力制御モジュールを組み込む）

対応作業

以下は変更前のプログラムです。

package App;
 
use strict;
use warnings;
use utf8;

use BBS;                            # BBSのロード
my $bbs = new BBS;                  # オブジェクト作成

$bbs->{'send_buffer'} = {};         # 送信バッファ(オブジェクト内に作る)
#            ->{node} = "{data}";


## ( onConnect : 接続時処理 )
sub onconnect {
   my $self = shift;

   printf "\n(%d) 接続しました ", $self->from();
   print "\n接続ノード: [ ".join(',', $self->nodes())." ] ";
}
 
## ( onDisconnect : 切断時処理 )
sub ondisconnect {
   my $self = shift;

   printf "\n(%d) 切断しました ", $self->from();
   print "\n接続ノード: [ ".join(',', $self->nodes())." ] ";
}
 
## ( onRecv : データ受信 )
sub onrecv {
   my $self = shift;
   my $rcvdata = join('', @_);                       # イベントから受信データを取得

   my @tonodes = $self->nodes();                     # ノードリストを取得
   map { $self->send( $_, $rcvdata ) } @tonodes;     # 受信データを全ノードに送信
}
 
## ( onSend : データ送信 )
sub onsend {
   my $self = shift;
   my $to_node = shift;                                  # イベントから送信対象のノード番号を取得
   my $send_data = join('', @_);                         # イベントから送信データを取得
 
   $self->{'send_buffer'}->{$to_node} = $send_data;      # 対象ノードの送信バッファに送信データを保存
}
 
## ( Output : データ出力 )
sub output {
   my $self = shift;

   my $to_node = $self->from();                              # 送信対象のノード番号を取得
   my $send_data = $self->{'send_buffer'}->{$to_node};       # 対象ノードの送信バッファからデータを取得
   if ( defined($send_data) ) {                              # 送信データを取得したら
      $self->{'send_buffer'}->{$to_node} = undef;                # 送信バッファを消去
      return $send_data;                                         # 送信データを返り値に設定してルーチンを抜ける
   }
   return;                                                   # ルーチンを抜ける（送信データを取得しなかったら）
}
 
$bbs->setsyshandler('onConnect',    sub { $bbs->App::onconnect(@_) });
$bbs->setsyshandler('onDisconnect', sub { $bbs->App::ondisconnect(@_) });
$bbs->setsyshandler('onRecv',       sub { $bbs->App::onrecv(@_) });
$bbs->setsyshandler('onSend',       sub { $bbs->App::onsend(@_) });
$bbs->setsyshandler('Output',       sub { $bbs->App::output(@_) });
 
print "開始しました";
$bbs->start(8888);

そして以下はモジュール組み込み後のプログラムです。

package App;
 
use strict;
use warnings;
use utf8;

use BBS;               # BBSのロード
use BBS::IO::Input;    # 入力制御モジュールのロード
use BBS::IO::Output;   # 出力制御モジュールのロード
my $bbs = new BBS;     # オブジェクト作成


## ( onConnect : 接続時処理 )
sub onconnect {
   my $self = shift;

   my $me = $self->from();
   printf "\n(%d) 接続しました ", $me;
   $self->node( $me )->{'__Input'} = new BBS::IO::Input;            # 入力制御オブジェクトを作成しノードテーブルに保存
   $self->node( $me )->{'__Output'} = new BBS::IO::Output;          # 出力制御オブジェクトを作成しノードテーブルに保存
   print "\n接続ノード: [ ".join(',', $self->nodes())." ] ";
   $self->setapphandler( sub { $bbs->App::appwork(@_) } );          # AppWorkイベントが発生したときに呼び出すルーチンを設定
}

## ( onDisconnect : 切断時処理 )
sub ondisconnect {
   my $self = shift;

   printf "\n(%d) 切断しました ", $self->from();
   print "\n接続ノード: [ ".join(',', $self->nodes())." ] ";
}

## ( onRecv : データ受信 )
sub onrecv {
   my $self = shift;
   my $recvdata = join('', @_);                     # イベントから受信データを取得

   my $me = $self->from();                          # 受信対象のノード番号を取得
   my $in = $self->node( $me )->{'__Input'};        # 対象ノードの入力制御オブジェクトを取得
   $in->store( $recvdata );                         #  入力制御オブジェクト内の受信バッファにデータを取り込む
}

## ( onSend : データ送信 )
sub onsend {
  my $self = shift;

  my $to = shift;                                   # イベントから送信先ノード番号を受け取る
  my $senddata = join('', @_);                      # イベントから送信データを受け取る
  my $out = $self->node( $to )->{'__Output'};       # 出力対象ノードの出力制御オブジェクトを取得
  $out->store( $senddata );                         # 出力制御オブジェクト内の送信バッファにデータを取り込む
}

## ( Output : データ出力 )
sub output {
  my $self = shift;

  my $me = $self->from();                           # 出力対象のノード番号を得る
  my $out = $self->node( $me )->{'__Output'};       # 対象ノードの出力制御オブジェクトを取得
    my $senddata = $out->emit();                    # 出力制御オブジェクト内の送信バッファからデータを取り出す
  if ( defined($senddata) ) {                       # 送信データを取得したら
    return $send_data;                                 # 送信データを返り値に設定してルーチンを抜ける
  }
  return;                                           # ルーチンを抜ける（送信データを取得しなかったら）
}

## ( AppWork : アプリケーション処理 )
sub appwork {
   my $self = shift;

   my $me = $self->from();                                 # 処理対象のノード番号を取得
   my $in = $self->node( $me )->{'__Input'};               # 対象ノードの入力制御オブジェクトを取得
   $in->keyin();                                           # 入力制御オブジェクト内の受信バッファからデータを取得
   my $inkey = $in->inkey();                               # 入力した文字を取得
   map { $self->send( $_, $inkey ) } $self->nodes();      # 取得した文字を全ノードに送信
}

$bbs->setsyshandler('onConnect',    sub { $bbs->App::onconnect(@_) });
$bbs->setsyshandler('onDisconnect', sub { $bbs->App::ondisconnect(@_) });
$bbs->setsyshandler('onRecv',       sub { $bbs->App::onrecv(@_) });
$bbs->setsyshandler('onSend',       sub { $bbs->App::onsend(@_) });
$bbs->setsyshandler('Output',       sub { $bbs->App::output(@_) });

print "開始しました";
$bbs->start(8888);

変更前よりも２０行弱程度コードが追加されていますが、大きな変更は変わっていないように見えると思います。

では、変更点を説明します。