PingSenderの拡張実装

[TodorokiKohei]

• PingSenderを実装したAbstractなTimerPingSenderを実装する

[TodorokiKohei]

PINGREQ生成メソッド以外を実装した抽象クラスExtendedPingSenderを実装する。この抽象クラスを実装する理由は、ユースケースによってPINGREQに付加したい情報が異なると考えられるためである。このクラスを継承し、PINGREQ生成メソッドcreatePingreqで任意のデータを送信できるようにする。
また、PINGREQの送信間隔をKeepAliveやServerKeepAliveとは独立して設定できるようにする。現在のクライアントではKeepAliveで設定した時間間隔でPINGREQが送信されるように実装されており、MQTTの仕様ではKeepAliveの最小値は１秒である。しかし、各サブスクライバのPINGREQ送信を同期することができない現状では、この1秒という時間はサブスクライバの最新状態を十分に反映できるものではないと考えられる。そのため、今回の実装ではサーバに送信するKeepAliveとは独立してPINGREQの送信間隔を設定可能にする。

[TodorokiKohei]

拡張PINGREQを有効にするのに、現在はMqttConnectOptions経由でMqttConnectionStateにフラグを設定していた。この実装ではクライアントがブローカに接続するまで拡張PINGREQが有効かを判定することができない。
MqttAsyncClientに拡張PINGREQを有効にするsetterを実装するのでもいいが、MqttAsyncClient生成時にClientCommsやClientStateも生成されるため、後からsetterによってそれぞれに反映させるのは遅い気がする。

今回はPingSenderがExtendedPingSenderを継承したクラスの場合にフラグを立てる設計にする。