Crate rsiot_modbus_client

Опрос устройств Modbus, используя библиотеку tokio-modbus

Ссылки:

• Документация docs.rs

• Репозиторий GitHub

• Примеры

Тестирование

Готовый docker-образ для тестов - GitHub.

Запускается через docker compose в корне. Инструкция.

Диаграмма

Пример

//! Простейший пример использования клиента Modbus
//!
//! Для тестирования можно использовать образ docker oitc/modbus-server
//!
//! Выполняется две операции:
//! - раз в 2 секунды на сервер в регистр 0 записывается значение счетчика (`input_config`)
//! - раз в 2 секунды считывается значение регистра 0 (`periodic_config`) и отправляется в логгер
//!
//! Запуск:
//!
//! ```bash
//! cargo run -p rsiot-modbus-client --example modbus_tcp_client
//! ```

use std::net::{IpAddr, Ipv4Addr};

use serde::{Deserialize, Serialize};
use tokio::{main, time::Duration};
use tracing::Level;
use tracing_subscriber::fmt;

use rsiot_component_core::ComponentCollection;
use rsiot_extra_components::{cmp_inject_periodic, cmp_logger};
use rsiot_messages_core::IMessage;
use rsiot_modbus_client::cmp_modbus_client::{self, *};

#[derive(Clone, Debug, Deserialize, PartialEq, Serialize)]
pub enum Messages {
    ValueWrite(f64),
    ValueRead(f64),
}

impl IMessage for Messages {
    fn into_eav(self) -> Vec<rsiot_messages_core::eav::EavModel> {
        vec![]
    }
}

#[main]
async fn main() {
    // логгирование
    fmt().init();

    // Конфигурация modbus клиента
    let modbus_client_config = Config::<Messages>::Tcp(TcpClientConfig {
        host: IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)),
        port: 5020,
        unit_id: 1,
        input_config: vec![InputConfig {
            fn_input: |msg| match msg {
                Messages::ValueWrite(val) => Some(Request::WriteSingleRegister(0, *val as u16)),
                Messages::ValueRead(_) => None,
            },
            fn_on_success: |_data| vec![],
            fn_on_failure: Vec::new,
        }],
        periodic_config: vec![PeriodicConfig {
            period: Duration::from_secs(2),
            request: Request::ReadHoldingRegisters(0, 1),
            fn_on_success: |data| {
                let mut msgs = vec![];
                if let Response::U16(data) = data {
                    msgs.push(Messages::ValueRead(data[0] as f64));
                }
                msgs
            },
            fn_on_failure: Vec::new,
        }],
    });

    let mut counter = 0.0;
    let mut chain = ComponentCollection::new(
        100,
        vec![
            // Периодическое генерирование сообщения для записи счетчика на сервер
            cmp_inject_periodic::new(cmp_inject_periodic::Config {
                period: Duration::from_secs(2),
                fn_periodic: move || {
                    let msg = Messages::ValueWrite(counter);
                    counter += 1.0;
                    vec![msg]
                },
            }),
            // Клиент modbus
            cmp_modbus_client::new(modbus_client_config),
            // Вывод сообщений в лог
            cmp_logger::new(cmp_logger::Config {
                level: Level::INFO,
                header: "".into(),
            }),
        ],
    );

    chain.spawn().await;
}

Modules

• cmp_modbus_client
  Обмен данными с устройством, поддерживающим Modbus TCP сервер.
• conversion
  Модуль для конвертации числовых данных в регистры и наоборот.

Structs

• ComponentCollection
  Объединение компонентов в одну цепочку

Traits

• IMessage
  Трейт, который необходимо реализовать на конкретном типе сообщения