使用libmodbus库开发modbusTcp从站(支持多个主站连接)

2023-10-06 12:56
文章标签 使用 连接 开发 支持 多个 modbustcp libmodbus

本文主要是介绍使用libmodbus库开发modbusTcp从站(支持多个主站连接)，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

使用libmodbus库开发modbusTcp从站（支持多个主站连接）

  • Chapter1 使用libmodbus库开发modbusTcp从站(支持多个主站连接)
    • rdsmodbusslave.h
    • rdsmodbusslave.cpp
    • main.cpp

Chapter1 使用libmodbus库开发modbusTcp从站(支持多个主站连接)

参考链接：https://blog.csdn.net/v6543210/article/details/127426450

https://blog.csdn.net/qq_38158479/article/details/120928043

当我们需要自己搞一个C/C++版的 modbus Server时，总想像C#里面借助个好用的库来实现，但是libmodbus这个库封装的并不好用，从官方的源码中连个example都没有，能参考的也就tests目录下有几个可以借鉴。

但是仔细看了一下，random-test-server.c 还是会阻塞的，单线程。与拿来即用的标准相差甚远。

如果需要实现对多个客户端提供服务，需要参考 bandwidth-server-many-up.c

本文借鉴这篇文章，进行了一点优化，实现了可以为多个客户端提供服务的modbus tcp Server，可以拿来即用。

使用libmodbus库开发modbusTcp从站(支持多个主站连接)_酸菜。的博客-CSDN博客_libmodbus tcp

如果需要自己实现逻辑可以直接在另一个线程函数中对modbus的变量进行修改。

rdsmodbusslave.h

#ifndef RDSMODBUSSLAVE_H
#define RDSMODBUSSLAVE_H#include <iostream>
#include <thread>
#include <stdlib.h>
#include <iostream>
#include <mutex>
#include <string>
using namespace std;
/*如果是windows平台则要加载相应的静态库和头文件*/
#ifdef _WIN32
#define _WINSOCK_DEPRECATED_NO_WARNINGS
#include <winsock2.h>
#include <windows.h>
//#include <modbus.h>
#pragma comment(lib, "Ws2_32.lib")
//#pragma comment(lib, "modbus.lib")
/*linux平台*/
#else
//#include <modbus/modbus.h>
#include <unistd.h>
#include <error.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <sys/select.h>
#endif//#define  MAX_POINT  50000
#include <QObject>
#include <QThread>
#include <stdio.h>
#include <libmodbus/config.h>
#include <libmodbus/modbus.h>
#include <libmodbus/modbus-rtu.h>
#include <QTimer>
#include <QDebug>
#include <QStringList>
#include <QSerialPortInfo>
#include <QSerialPort>class RDSModbusSlave : public QObject
{Q_OBJECT
public:explicit RDSModbusSlave(QObject *parent = nullptr);RDSModbusSlave(string host="0.0.0.0", uint16_t port=502);~RDSModbusSlave();public:void recieveMessages();bool modbus_set_slave_id(int id);bool initModbus(std::string Host_Ip, int port, bool debugging);uint8_t getTab_Input_Bits(int NumBit);bool setTab_Input_Bits(int NumBit, uint8_t Value);uint16_t getHoldingRegisterValue(int registerStartaddress);float getHoldingRegisterFloatValue(int registerStartaddress);bool setHoldingRegisterValue(int registerStartaddress, uint16_t Value);bool setHoldingRegisterValue(int registerStartaddress, float Value);bool setInputRegisterValue(int registerStartaddress, uint16_t Value);bool setInputRegisterValue(int registerStartaddress, float Value);private:std::mutex slavemutex;int m_errCount{ 0 };int m_modbusSocket{ -1 };bool m_initialized{ false };modbus_t* ctx{ nullptr };modbus_mapping_t* mapping{ nullptr };/*Mapping*/int m_numBits{ 60000 };int m_numInputBits{ 60000 };int m_numRegisters{ 60000 };int m_numInputRegisters{ 60000 };public:void loadFromConfigFile();void run();signals:};/*annotation:
(1)https://www.jianshu.com/p/0ed380fa39eb
(2)typedef struct _modbus_mapping_t
{int nb_bits;                //线圈int start_bits;int nb_input_bits;          //离散输入int start_input_bits;int nb_input_registers;     //输入寄存器int start_input_registers;int nb_registers;           //保持寄存器int start_registers;uint8_t *tab_bits;uint8_t *tab_input_bits;uint16_t *tab_input_registers;uint16_t *tab_registers;
}modbus_mapping_t;*/#endif // RDSMODBUSSLAVE_H

rdsmodbusslave.cpp

#include "rdsmodbusslave.h"#ifdef _WIN32
typedef int socklen_t;
#endifRDSModbusSlave::RDSModbusSlave(QObject *parent) : QObject(parent)
{}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      Constructor* @version    v1* @return     null* @date       2021/10/6**************************************************************/
RDSModbusSlave::RDSModbusSlave(string host, uint16_t port)
{initModbus(host, port, false);//TODO：this->setHoldingRegisterValue(0, (uint16_t)0x1122);this->setHoldingRegisterValue(3, (uint16_t)0x3022);this->setHoldingRegisterValue(6, (uint16_t)0x6022);
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      Destructor* @version    v1* @return     null* @date       2021/10/6**************************************************************/
RDSModbusSlave::~RDSModbusSlave()
{modbus_mapping_free(mapping);modbus_close(ctx);modbus_free(ctx);
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      支持多个master同时连接* @version    v1* @return     null* @date       2021/10/6**************************************************************/
void RDSModbusSlave::recieveMessages()
{uint8_t query[MODBUS_TCP_MAX_ADU_LENGTH];int master_socket;int rc;fd_set refset;fd_set rdset;/* Maximum file descriptor number */int fdmax;/* Clear the reference set of socket */FD_ZERO(&refset);/* Add the server socket */FD_SET(m_modbusSocket, &refset);/* Keep track of the max file descriptor */fdmax = m_modbusSocket;while( true ){rdset = refset;if (select(fdmax+1, &rdset, NULL, NULL, NULL) == -1){perror("Server select() failure.");break;}/* Run through the existing connections looking for data to be* read */for (master_socket = 0; master_socket <= fdmax; master_socket++){if (!FD_ISSET(master_socket, &rdset)){continue;}if (master_socket == m_modbusSocket){/* A client is asking a new connection */socklen_t addrlen;struct sockaddr_in clientaddr;int newfd;/* Handle new connections */addrlen = sizeof(clientaddr);memset(&clientaddr, 0, sizeof(clientaddr));newfd = accept(m_modbusSocket, (struct sockaddr *)&clientaddr, &addrlen);if (newfd == -1){perror("Server accept() error");} else{FD_SET(newfd, &refset);if (newfd > fdmax){/* Keep track of the maximum */fdmax = newfd;}printf("New connection from %s:%d on socket %d\n", inet_ntoa(clientaddr.sin_addr), clientaddr.sin_port, newfd);}} else{modbus_set_socket(ctx, master_socket);rc = modbus_receive(ctx, query);if (rc > 0){modbus_reply(ctx, query, rc, mapping);} else if (rc == -1){/* This example server in ended on connection closing or* any errors. */printf("Connection closed on socket %d\n", master_socket);#ifdef _WIN32closesocket(master_socket);#elseclose(master_socket);#endif/* Remove from reference set */FD_CLR(master_socket, &refset);if (master_socket == fdmax){fdmax--;}}}}}m_initialized = false;
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      modbus_set_slave_id* @param      id* @version    v1* @return     null* @date       2021/10/19**************************************************************/
bool RDSModbusSlave::modbus_set_slave_id(int id)
{int rc = modbus_set_slave(ctx, id);if (rc == -1){fprintf(stderr, "Invalid slave id\n");modbus_free(ctx);return false;}return true;
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      modbus initialization* @param      IP/PORT/debugflag* @version    v1* @return     null* @date       2021/10/6**************************************************************/
bool RDSModbusSlave::initModbus(std::string Host_Ip = "127.0.0.1", int port = 502, bool debugging = false)
{ctx = modbus_new_tcp(Host_Ip.c_str(), port);modbus_set_debug(ctx, debugging);if (ctx == NULL){fprintf(stderr, "There was an error allocating the modbus\n");throw - 1;}m_modbusSocket = modbus_tcp_listen(ctx, 1);/*设置线圈, 离散输入, 输入寄存器, 保持寄存器个数(数组元素个数))*/mapping = modbus_mapping_new(m_numBits, m_numInputBits, m_numInputRegisters, m_numRegisters);if (mapping == NULL){fprintf(stderr, "Unable to assign mapping：%s\n", modbus_strerror(errno));modbus_free(ctx);m_initialized = false;return false;}m_initialized = true;return true;
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      getTab_Input_Bits(获取输入寄存器某一位的值)* @param      NumBit(输入寄存器相应的bit位)* @version    v1* @return     null* @date       2021/10/8**************************************************************/
uint8_t RDSModbusSlave::getTab_Input_Bits(int NumBit)
{if (!m_initialized){return -1;}return mapping->tab_input_bits[NumBit];
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      setTab_Input_Bits(设置输入寄存器某一位的值)* @param      NumBit(输入寄存器的起始地址)* @param      Value(输入寄存器的值)* @version    v1* @return     null* @date       2021/10/8**************************************************************/
bool RDSModbusSlave::setTab_Input_Bits(int NumBit, uint8_t Value)
{if (NumBit > (m_numInputBits - 1)){return false;}slavemutex.lock();mapping->tab_input_bits[NumBit] = Value;slavemutex.unlock();return true;
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      getRegisterValue(获取保存寄存器的值)* @param      registerStartaddress(保存寄存器的起始地址)* @version    v1* @return     null* @date       2021/10/6**************************************************************/
uint16_t RDSModbusSlave::getHoldingRegisterValue(int registerStartaddress)
{if (!m_initialized){return -1;}return mapping->tab_registers[registerStartaddress];
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      获取寄存器里的浮点数* @param      registerStartaddress寄存器起始地址* @version    v1* @return     两个uint16_t拼接而成的浮点值* @date       2021/10/6**************************************************************/
float RDSModbusSlave::getHoldingRegisterFloatValue(int registerStartaddress)
{if (!m_initialized){return -1.0f;}return modbus_get_float_badc(&mapping->tab_registers[registerStartaddress]);
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      setRegisterValue(设置保存寄存器的值，类型为uint16_t)* @param      registerStartaddress(保存寄存器的起始地址)* @param      Value(写入到保存寄存器里的值)* @version    v1* @return     null* @date       2021/10/6**************************************************************/
bool RDSModbusSlave::setHoldingRegisterValue(int registerStartaddress, uint16_t Value)
{if (registerStartaddress > (m_numRegisters - 1)){return false;}slavemutex.lock();mapping->tab_registers[registerStartaddress] = Value;slavemutex.unlock();return true;
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      setRegisterFloatValue(设置浮点值)* @param      (Value：浮点值，registerStartaddress寄存器起始地址)* @version    v1* @return     null* @date       2021/10/8**************************************************************/
bool RDSModbusSlave::setHoldingRegisterValue(int registerStartaddress, float Value)
{if (registerStartaddress > (m_numRegisters - 2)){return false;}/*小端模式*/slavemutex.lock();modbus_set_float(Value, &mapping->tab_registers[registerStartaddress]);slavemutex.unlock();return true;
}bool RDSModbusSlave::setInputRegisterValue(int registerStartaddress, uint16_t Value)
{if (registerStartaddress > (m_numRegisters - 1)){return false;}slavemutex.lock();mapping->tab_input_registers[registerStartaddress] = Value;slavemutex.unlock();return true;
}bool RDSModbusSlave::setInputRegisterValue(int registerStartaddress, float Value)
{if (registerStartaddress > (m_numRegisters - 2)){return false;}/*小端模式*/slavemutex.lock();modbus_set_float(Value, &mapping->tab_input_registers[registerStartaddress]);slavemutex.unlock();return true;
}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      loadFromConfigFile* @version    v1* @return     null* @date       2021/10/18**************************************************************/
void RDSModbusSlave::loadFromConfigFile()
{}/**************************************************************** @file       RDSModbusSlave.cpp* @author     seer-txj* @brief      run* @version    v1* @return     null* @date       2021/10/18**************************************************************/
void RDSModbusSlave::run()
{std::thread loop([this](){while (true){if (m_initialized){recieveMessages();}else{m_initialized = true;}}});loop.detach();return;
}

main.cpp

#include "mainwindow.h"#include <QApplication>//#include "rdsmodbusslave.h"using namespace std;void modbusRunner(RDSModbusSlave* server)
{server->recieveMessages();
}RDSModbusSlave modServer("127.0.0.1", 502);int main(int argc, char *argv[])
{QApplication a(argc, argv);MainWindow w;w.show();std::thread modServerThread(modbusRunner, &modServer);modServerThread.join();return a.exec();
}

这篇关于使用libmodbus库开发modbusTcp从站(支持多个主站连接)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/153104。

相关文章

使用Python实现可恢复式多线程下载器

使用Python实现可恢复式多线程下载器

《使用Python实现可恢复式多线程下载器》在数字时代,大文件下载已成为日常操作,本文将手把手教你用Python打造专业级下载器,实现断点续传,多线程加速,速度限制等功能,感兴趣的小伙伴可以了解下... 目录一、智能续传：从崩溃边缘抢救进度二、多线程加速：榨干网络带宽三、速度控制：做网络的好邻居四、终端交互
阅读更多...
Python中注释使用方法举例详解

Python中注释使用方法举例详解

《Python中注释使用方法举例详解》在Python编程语言中注释是必不可少的一部分,它有助于提高代码的可读性和维护性,：本文主要介绍Python中注释使用方法的相关资料,需要的朋友可以参考下... 目录一、前言二、什么是注释？示例：三、单行注释语法：以 China编程# 开头，后面的内容为注释内容示例：示例：四
阅读更多...
Go语言数据库编程GORM 的基本使用详解

Go语言数据库编程GORM 的基本使用详解

《Go语言数据库编程GORM的基本使用详解》GORM是Go语言流行的ORM框架,封装database/sql,支持自动迁移、关联、事务等,提供CRUD、条件查询、钩子函数、日志等功能,简化数据库操作... 目录一、安装与初始化1. 安装 GORM 及数据库驱动2. 建立数据库连接二、定义模型结构体三、自动迁
阅读更多...
ModelMapper基本使用和常见场景示例详解

ModelMapper基本使用和常见场景示例详解

《ModelMapper基本使用和常见场景示例详解》ModelMapper是Java对象映射库,支持自动映射、自定义规则、集合转换及高级配置（如匹配策略、转换器）,可集成SpringBoot,减少样板... 目录1. 添加依赖2. 基本用法示例：简单对象映射3. 自定义映射规则4. 集合映射5. 高级配置匹
阅读更多...
MySQL中的表连接原理分析

MySQL中的表连接原理分析

《MySQL中的表连接原理分析》：本文主要介绍MySQL中的表连接原理分析,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1、背景2、环境3、表连接原理【1】驱动表和被驱动表【2】内连接【3】外连接【4编程】嵌套循环连接【5】join buffer4、总结1、背景
阅读更多...
Spring 框架之Springfox使用详解

Spring 框架之Springfox使用详解

《Spring框架之Springfox使用详解》Springfox是Spring框架的API文档工具,集成Swagger规范,自动生成文档并支持多语言/版本,模块化设计便于扩展,但存在版本兼容性、性... 目录核心功能工作原理模块化设计使用示例注意事项优缺点优点缺点总结适用场景建议总结Springfox 是
阅读更多...
嵌入式数据库SQLite 3配置使用讲解

嵌入式数据库SQLite 3配置使用讲解

《嵌入式数据库SQLite3配置使用讲解》本文强调嵌入式项目中SQLite3数据库的重要性,因其零配置、轻量级、跨平台及事务处理特性,可保障数据溯源与责任明确,详细讲解安装配置、基础语法及SQLit... 目录0、惨痛教训1、SQLite3环境配置（1）、下载安装SQLite库（2）、解压下载的文件（3）、
阅读更多...
使用Python绘制3D堆叠条形图全解析

使用Python绘制3D堆叠条形图全解析

《使用Python绘制3D堆叠条形图全解析》在数据可视化的工具箱里,3D图表总能带来眼前一亮的效果,本文就来和大家聊聊如何使用Python实现绘制3D堆叠条形图,感兴趣的小伙伴可以了解下... 目录为什么选择 3D 堆叠条形图代码实现：从数据到 3D 世界的搭建核心代码逐行解析细节优化应用场景：3D 堆叠图
阅读更多...
Springboot如何正确使用AOP问题

Springboot如何正确使用AOP问题

《Springboot如何正确使用AOP问题》：本文主要介绍Springboot如何正确使用AOP问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录​一、AOP概念二、切点表达式​execution表达式案例三、AOP通知四、springboot中使用AOP导出
阅读更多...
Navicat数据表的数据添加,删除及使用sql完成数据的添加过程

Navicat数据表的数据添加,删除及使用sql完成数据的添加过程

《Navicat数据表的数据添加,删除及使用sql完成数据的添加过程》：本文主要介绍Navicat数据表的数据添加,删除及使用sql完成数据的添加过程,具有很好的参考价值,希望对大家有所帮助,如有... 目录Navicat数据表数据添加,删除及使用sql完成数据添加选中操作的表则出现如下界面，查看左下角从左
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2