プログラマーですが何か?まだプログラマーですが何か?プログラマーネタとアスリートネタ中心。内で指定されていればその値が、されていなければ動的に生成されるようにしました。ランタイムを作ると動作を確認しやすく、またそのためカスタマイズの勘所が分かりやすいと思っています。以下、この環境での動作確認方法を紹介します。インストールされたマシンが必要です。インストール可能なマシンで導入を済ませていると仮定して以下を続けます。値(メッセージデータを送信する時間間隔(ミリ秒)。デフォルトは空文字列なので、後で自動生成された値になります)くらいです。値は変えなくても動きます。ような簡単な単語ではなく)他の人が使わないようなユニークな値になるよう指定してください。生成するので、この値は実行ごとに変わることに留意してください。5d7436e992d0)。指定した場合はその値が、指定しなかった場合は自動生成された値が表示されます。強制終了してください。指定した値の間隔でメッセージデータを送信し続けている状態になりました。内容をデバッグタブに表示する、というシンプルなフローです。画面右のデバッグタブに(デフォルトであれば)1秒おきにメッセージが追加されていく様子が確認できるはずです:メッセージの1つを選んで展開してみると、元のアプリケーションから送信されたカウント値(count)、タイムスタンプ値(timestamp)、CPU稼働率(cpu)、サイン値(sin)、コサイン値(cos)、そして乱数値(random)が確認できます。入れる)ということになります。こちらはシンプルなのでなんとなく理解できるんじゃないかな・・・と期待しています。組み合わせることで、ここで取得した値を簡単にチャート化することもできます。データを送信するサンプルとして使ってくださいませ。環境を使って集めたデータをリレーショナルデータベース(dashDB)に格納する、という手順を紹介します。準備段階として、「何の」データを集めるか、という問題があります。パブリッシュが可能なアプリケーションやデバイスであれば何でもいいのですが、後のデータ解析のことを考え、シミュレーターではなく実機のデータを集めることにします。ブローカー)に送られるようになります。今回はそのデータを集めてみます。パブリッシュする仕様になっています。ボタンをクリックすると、このノードアプリケーションが動き出します。一意のメッセージID}上記の赤字で書かれたデータは個々のメッセージ毎に変わるデータなので、このデータを集めることにします。データの変換を行うよう指定します。4つの値だけをフラットに取り出すことができるようになりました。サービスを追加します:実際にデータを追加(insert)するには、その前にテーブルを定義しておく必要があります。ダイアログボックスが表示されます。テーブルが追加されています。テーブルの設計要素が表示されます。格納する、という処理が実現できました。ブローカーを使ったアプリのサンプルを紹介します。作成するような内容にします。北米データセンターのサービス状況確認用です。ランタイムやサービスの単位での稼働状況を教えてくれるサービスサイトです。アクセスすることで確認することはできます。それでは「上記サイトを見に行った人が稼働状況を確認できる」というだけです。情報そのものは便利なのですが、稼働ステータスをもっとインタラクティブにプッシュしたり、ユーザーフレンドリーな形で提供することを考えてみましょう。具体的にはこのようなシステムを作ります。サービスの稼動状態を確認します。パブリッシュする、というものです。アプリケーション起動時に動的に作成し、コンソールへ出力します。英国データセンター用に作り変えたり、実行感覚を変更したい場合はソースコードの該当箇所を適宜変更してください。サブスクライバーを使って取り出せます。簡単にメッセージを取り出すことができるので、その結果をデバッグタブに出力したり、メールで通知したり、といった管理機能が簡単に実現できます。使ったことがある方であれば、あまり難しくないと思っています。アプリケーションの実装に戻します。使ったサンプルを作成してみました。最新版(org.eclipse.paho.client.mqttv3-X.X.X.jar)が必要です。別途ダウンロードしておいてください。ライブラリとソースコード(EstadoQuickstart.java)をダウンロードしてコンパイル&実行します。ユーザーであれば、この結果を簡単に取り出すことができます。環境にアクセスします。サービスの情報が送られてくるようになります。フォーマットでメッセージを取得します。アプリを作って動かすことも可能になる、ということになります。デバイスを意識して作成された軽量なプロトコルですが、必ずしもデバイスでしか使えない、というものでもありません。今回のようなサーバーの死活情報を扱ってはいけない、というものではないし、現に某有名ソーシャルサイトのメッセージング機能で使われていたりもします。ここが簡単にできる、というサービスです)、が重要だと思っています。みなさんも色んなアイデアを是非形にしてみてください。以外の言語でも実現できると思っていますので、興味のある方は是非移植にも挑戦してみてください。導入方法を紹介しました。ブローカーに任意のメッセージデータを送る方法を紹介します。データを送るにはどうするか?という手段の紹介です。クライアント(パブリッシャー)を使った例を紹介します。パブリッシャー(mosquitto_pub)をインストールする所までは済ませておいてください。送られてきたメッセージデータを確認するための環境を整えておく必要があります。環境を用意してください。ノードをダブルクリックし、このような属性値に設定します。していますが、同じものを使わないでください。アドレスを想定しています)を入力します。ノードの属性は以下のようにします。送られてくるデータを取得してデバッグタブに表示する、というアプリが動いている状態になりました。パブリッシュしてみます。パブリッシュする、という処理内容のコマンドです。形式で送付することを推奨しています。中身として届けられています。値として表示されています。して届いていることもわかります。パブリッシュする側で任意に設定できる、デバイスとイベントの分類用文字列です。メッセージを送ることができる、ということが分かりました。使って便利に処理できます。このコマンドをプログラミング言語から実行するにはどのようにすればよいのか、それは別途紹介させていただくつもりです。ブログ検索」ブログパーツは、サービスを終了しました。