キューイングする

■電源監視デバイスができたので、そうなるとやはり継続的な監視をやってみたい。すでに試行は始めているけど、ZigBeeの通信が思った以上に不安定なのがネックになっている。特に電源監視デバイスはまだバラックということもあって、床置きになっているのも不利なようだ。不利な条件はもう一つあって、アドホックに起きるリモコン操作の通信が割り込むのもあまりよくない。電源監視とリモコン操作の要求元になるプロセスが別物なのに、通信先のXBeeは1つしかないわけで、その送受信がごちゃごちゃになってしまう。こうなってくるとお気楽に書き流してもいられなくて、ちゃんとメッセージングを考えないといけない。キューイングが必要だ。

 PHPはOSが持つプロセス間通信用のメッセージングや排他制御を利用できる関数がある。プロセス制御→セマフォにあるセマフォ関数として分類されているのがそれで、今回使ったのはそのうち'msg_'ではじまるメッセージキュー関係の関数。
 プログラムの構成は単純なサーバー・クライアントモデルで、サーバーはメッセージキューとXBeeの仲立ちをする。XBeeの各デバイスは全てコール-レスポンス構造を持っていて、送信メッセージに対し必ず応答があることを期待して良いから、サーバーはクライアントから受け取ったメッセージをXBeeに送り、XBeeからの応答を要求元のクライアントだけにリレーする。このサーバーとXBeeとの送受信はペアにできて、その間サーバーは他のクライアントからの要求を受け取れず、クライアントは待つことになるから、そこで排他制御がかかることになる。

 クライアント側では今まで実装していたXBeeとのやりとりに使っていたクラスのメソッドをほぼそのままにして、中身をttyとのダイレクトIOではなく、サーバーとのメッセージング機構に置き換える。つまり、ラッパー関数にする。
 サーバーとクライアントは別々に動いていて、メッセージの読み書きのタイミングはもちろん同期されていない。なので、メッセージの識別は送信先ごとにユニークになるようmessageTypeを設定した。サーバーはmessageTypeを1にして、クライアントは自身のプロセスIDを使った。こうしないと、タイミングによって書き込んだ側が先に読み出してしまう可能性が高い。問題はクライアントが自身のmessageTypeをサーバーに伝える必要があることで、このために、クライアントはメッセージの先頭7バイトにmessageTypeを埋め込んでいる。逆にサーバー側は自身のmessageTypeがクライアント側に自明となっているのでmessageTypeの埋め込みはしていない。

 長時間使っていると、XBeeの比較的不安定な通信に起因するエラーがちょくちょく発生するから、そこでデバイスやサーバー側のプログラムがスタックしないようにそのたびに手直ししています。今の実装もたぶん仮のもので、安定や利便性のためにまだまだ手直しは続く気がしています。

Copyright (C) 2008-2015 Satosh Saitou. All rights reserved.
戻る
日記::一覧展開
2016.06
2016.05
2015.12
2015.11
2015.08
2015.07
2015.06
2015.05
2015.04
2015.03
2015.02
2015.01
2014.12
2014.11
2014.10
2014.09
2014.08
2014.07
2014.06
2014.05
2014.04
2014.03
2014.02
2014.01
2013.12
2013.11
2013.10
2013.09
2013.08
2013.07
2013.06
2013.05
2013.04
2013.03
2013.02
2013.01
2012.12
2012.11
2012.10
2012.09
2012.08
2012.07
2012.06
2012.05
2012.04
2012.03
2012.02
2012.01
2011.12
2011.11
アサーション (2011.11.20)
XB24-BとXB24-ZB (2011.11.06)
2011.10
家電入れ替え (2011.10.23)
2011.09
湿度センサ (2011.09.25)
2011.08
2011.07
2011.06
2011.05
2011.04
2011.03
2011.02
2011.01
2010.12
2010.11
2010.10
2010.09
2010.08
2010.07
2010.06
2010.05
2010.04
2010.03
2010.02
2010.01
2009.12
2009.11
2009.10
2009.09
2009.08
2009.07
2009.06
2009.05
2009.03
2009.02
2009.01
2008.12
2008.11
2008.10
2008.09
2008.08
2008.07
2008.06
2008.05
2008.04
2008.03
2008.02
1998.11
作成:2010.08.14
公開:2011.09.03

Valid XHTML 1.1

loading image reserved place