工業用製品などで使用されている通信規格であるModbus。仕様はオープンされているので、様々な機器で使用されています。マスタ/スレーブ形式で、1対1または1対多で接続され、マスタがスレーブのデータを読み書きするといった通信となっています。Modbusは物理レイヤとしては、RS-232CやRS-485、Ethernetなどで採用されています。

Google等で「Modbus」を検索すれば、いろいろ資料が公開されているので詳しくは検索してみて下さい。

Modbus/TCPノード

enebularのDiscoverにはModbusスレーブとEthernetで通信するためのノードが有料プライベートノードとして公開されています。このノードは、読み出し系のファンクションコードに対応しています。

Discover / modbus-tcp

Modbus/TCPの入力と出力は以下の様になっています。Modbus通信に必要なパラメータはすべてノードの入力で設定します。

入力
- server　型：string
  通信対象のスレーブのIPアドレスを指定します
- port 型：number
  通信対象のスレーブのポート番号を指定します
- timeOut 型：number
  スレーブと通信を行う際のタイムアウト時間をmsで指定します
- functionCode 型：number
  スレーブの実行機能に対応したファンクションコードを指定します
  - 0x01 コイル読み込み
  - 0x02 入力ステータス読み込み
  - 0x03 保持レジスタ読み込み
  - 0x04 入力レジスタ読み込み
  - 0x2B デバイスID読み込み
- address 型：number
  読み取り対象の開始アドレスを指定します。本項目は、ファンクションコード：0x2Bの場合に未使用
- quantity 型：number
  読み取り対象の範囲を指定します。本項目は、ファンクションコード：0x2Bの場合に未使用
- readDeviIdCode 型：number
  読み取り対象のReadDeviIdコードを指定します。本項目は、ファンクションコード：0x2Bの場合に使用
- objectId 型：number
  読み取り対象のオブジェクトIDを指定します。本項目は、ファンクションコード：0x2Bの場合に使用
出力（正常時）
- payload.buffer 型：buffer
  スレーブから受信したデータ。プロトコルデータ部をバイナリバッファで設定します。本項目は、ファンクションコード：0x2Bの場合に未使用
- payload.data 型：object
  スレーブから受信したデータ。プロトコルデータ部をオブジェクトIDをキーとした連想配列で設定します。本項目は、ファンクションコード：0x2Bの場合に使用
- server 型：string
  通信対象のスレーブのIPアドレス
- port 型：number
  通信対象のスレーブのポート番号
- statusCode 型：number
  スレーブとの通信結果。未設定
出力（異常時）
- payload.buffer 型：buffer
  スレーブから受信したデータ。未設定
- payload.data 型：object
  スレーブから受信したデータ。未設定
- server 型：string
  通信対象のスレーブのIPアドレス
- port 型：number
  通信対象のスレーブのポート番号
- statusCode 型：number
  スレーブとの通信結果。スレーブからの例外レスポンスコードを設定します

Modbusスレーブ機器を作って試す

Modbus対応のスレーブ機器が手元になかったため、M5 ATOM Matrixを用意して、Arduinoでスケッチを作りました。
M5 ATOM Matrixにはボタンと加速度センサーが搭載されているので、その値をModbus経由で読み出せるようにします。

Modbusのレジスタのアドレスとして以下の様にしています。
100番地ボタン
101番地加速度X軸上位16bit
102番地加速度X軸下位16bit
103番地加速度Y軸上位16bit
104番地加速度Y軸下位16bit
105番地加速度Z軸上位16bit
106番地加速度Z軸下位16bit

Arduino IDEで以下のライブラリとスケッチを用意して、M5 ATOM Matrixに書き込みました。

M5Atom
modbus-esp8266

#include <M5Atom.h>
#include <WiFi.h>
#include <ModbusIP_ESP8266.h>

// Modbusのアドレス
const int SW_IREG = 100;
const int ACCX_H_IREG = 101;
const int ACCX_L_IREG = 102;
const int ACCY_H_IREG = 103;
const int ACCY_L_IREG = 104;
const int ACCZ_H_IREG = 105;
const int ACCZ_L_IREG = 106;

// Wi-Fi設定
const char WIFI_SSID[] = "ssid";
const char WIFI_PASS[] = "pass";

ModbusIP mb;
long ts;

void setup() {
  // M5 ATOM初期化
  M5.begin(true, false, false);
  // M5 ATOM内蔵加速度センサ初期化
  M5.IMU.Init();

  // Wi-Fi接続
  WiFi.begin(WIFI_SSID, WIFI_PASS);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println("WiFi connected");  
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());

  // Modbusスタート
  mb.server();
  // Modbus設定
  mb.addIreg(SW_IREG);
  mb.addIreg(ACCX_H_IREG);
  mb.addIreg(ACCX_L_IREG);
  mb.addIreg(ACCY_H_IREG);
  mb.addIreg(ACCY_L_IREG);
  mb.addIreg(ACCZ_H_IREG);
  mb.addIreg(ACCZ_L_IREG);
  
  ts = millis();
}

void loop() {
  int sw;
  static int before_sw = LOW;

  // Modbus周期処理
  mb.task();

  // スイッチ読み込み
  sw = M5.Btn.isPressed();
  if (sw != before_sw) {
    // スイッチ状態をModbusに反映
    mb.Ireg(SW_IREG, sw);
    before_sw = sw;
  }

  // 500ms周期処理
  if (millis() > ts + 500) {
    int value;
    float x=0, y=0, z=0;
    ts = millis();
    // 加速度センサ読み込み
    M5.IMU.getAccelData(&x, &y, &z);
    // 加速度センサをModbusに反映
    memcpy(&value,&x,4);
    mb.Ireg(ACCX_H_IREG, (uint16_t)((value & 0xFFFF0000) >> 16));
    mb.Ireg(ACCX_L_IREG, (uint16_t)(value & 0x0000FFFF));
    memcpy(&value,&y,4);
    mb.Ireg(ACCY_H_IREG, (uint16_t)((value & 0xFFFF0000) >> 16));
    mb.Ireg(ACCY_L_IREG, (uint16_t)(value & 0x0000FFFF));
    memcpy(&value,&z,4);
    mb.Ireg(ACCZ_H_IREG, (uint16_t)((value & 0xFFFF0000) >> 16));
    mb.Ireg(ACCZ_L_IREG, (uint16_t)(value & 0x0000FFFF));
  }
  delay(10);
  
  M5.update();
}

（Wi-Fiの設定は環境に合わせて下さい）

動作させると以下のようにIPアドレスが表示されるので、それを控えておいて下さい。

WiFi connected
IP address: 
192.168.2.236

IPアドレスを固定にする場合は、WiFi.begin()の前に以下を追加して下さい。

const IPAddress ip(192,168,1,100);     // 使用するルータの範囲に合わせて下さい
const IPAddress gateway(192,168,1,1);  // 使用するルータのIPを設定
const IPAddress subnet(255,255,255,0); // 使用するルータのサブネットに合わせて下さい

WiFi.config(ip,gateway,subnet);

Modbus/TCPノードを使ったフロー

1秒周期でModbusスレーブであるM5 ATOM Matrixからボタンの状態と加速度センサーの値を読み出し、JSONに変換してDebugノードで表示するフローです。

[{"id":"93cd5a5.2c872a8","type":"tab","label":"フロー 1","disabled":false,"info":""},{"id":"61a5999e.1973e8","type":"inject","z":"93cd5a5.2c872a8","name":"","topic":"","payload":"","payloadType":"date","repeat":"1","crontab":"","once":false,"onceDelay":0.1,"x":250,"y":360,"wires":[["be6a29d5.0196f8"]]},{"id":"89a1f8f4.f768c8","type":"debug","z":"93cd5a5.2c872a8","name":"","active":true,"tosidebar":true,"console":true,"tostatus":false,"complete":"payload","targetType":"msg","x":1120,"y":360,"wires":[]},{"id":"be6a29d5.0196f8","type":"change","z":"93cd5a5.2c872a8","name":"","rules":[{"t":"set","p":"server","pt":"msg","to":"192.168.2.230","tot":"str"},{"t":"set","p":"port","pt":"msg","to":"502","tot":"num"},{"t":"set","p":"functionCode","pt":"msg","to":"4","tot":"num"},{"t":"set","p":"address","pt":"msg","to":"100","tot":"num"},{"t":"set","p":"quantity","pt":"msg","to":"7","tot":"num"},{"t":"set","p":"timeOut","pt":"msg","to":"500","tot":"num"}],"action":"","property":"","from":"","to":"","reg":false,"x":460,"y":360,"wires":[["e8016c9f.b29e6"]]},{"id":"57730195.163f8","type":"function","z":"93cd5a5.2c872a8","name":"バッファ列から各値に変換","func":"var btn = msg.payload.buffer.readUInt16BE(0);\nvar AccX = msg.payload.buffer.readFloatBE(2);\nvar AccY = msg.payload.buffer.readFloatBE(6);\nvar AccZ = msg.payload.buffer.readFloatBE(10);\n\nmsg.payload = {};\n\nmsg.payload.btn = btn;\nmsg.payload.AccX = AccX;\nmsg.payload.AccY = AccY;\nmsg.payload.AccZ = AccZ;\n\nreturn msg;","outputs":1,"noerr":0,"x":880,"y":360,"wires":[["89a1f8f4.f768c8"]]},{"id":"e8016c9f.b29e6","type":"modbus-tcp","z":"93cd5a5.2c872a8","name":"","x":650,"y":360,"wires":[["57730195.163f8"]]}]

changeノードでModbus通信の各パラメータを設定し、ファンクションノードで取得したバッファ列からJSONオブジェクトに変換しています。

changeノードのプロパティ
functionノードのプロパティ

フローを動作させる環境は、PC上のenebular editorでもRaspberry Pi上のenebular-agentでもOKです。条件としては、M5 ATOM Matrixと同じネットワーク内に繋がっていることです。

動作確認

M5 ATOM Matrixにスケッチを書き込み、動作させます。
フローのデバッグ出力に取得したボタンの状態と加速度センサーの値が表示されました。

M5 ATOM Matrixのボタンを押したり、傾けたりすると値が変化することが確認できました。

最後に

紹介しているModbus/TCPノードは、工業用の製品との連携で使用された実績もあり、テストされたモジュールです。enebularのオフィシャルで公開しているアセットは、基本的に無料/有料に関わらずテストを行ってリリースしています。今後も利用価値の高いアセットを増やしていきたいと思っています。