python实现ModBusTCP协议的server

python实现ModBusTCP协议的server是一件简单的事情,只要通过pymodbus、pyModbusTCP等模块都可以实现,本文采用pymodbus。

相关文章见:

python实现ModBusTCP协议的client-CSDN博客

一、了解pymodbus的Server

1、pymodbus.server的模块

pymodbus.server中的模块,能够用于用于实现 Modbus 协议的服务器端。以下是每个模块的功能介绍:

(1)ModbusSerialServer: 这个模块提供了一个基于串口的 Modbus 服务器。它允许通过串口与 Modbus 客户端通信。

(2)ModbusTcpServer: 这个模块提供了一个基于 TCP/IP 的 Modbus 服务器。它通过 TCP/IP 网络接口与 Modbus 客户端通信。

(3)ModbusTlsServer: 这个模块提供了一个基于 TLS 加密的 Modbus 服务器。它通过安全的 TLS 连接与 Modbus 客户端通信,确保通信的安全性。

(4)ModbusUdpServer: 这个模块提供了一个基于 UDP 的 Modbus 服务器。与 TCP 不同,UDP 是一种面向无连接的协议,适用于某些特定的网络环境。

(5)ServerAsyncStop: 这个类用于异步服务器的停止信号。通过发送这个信号,可以优雅地停止异步服务器的运行。

(6)ServerStop: 这个类用于同步服务器的停止信号。与 ServerAsyncStop 类似,但用于同步服务器。

(7)StartAsyncSerialServer: 这个函数用于启动一个异步的基于串口的 Modbus 服务器。

(8)StartAsyncTcpServer: 这个函数用于启动一个异步的基于 TCP/IP 的 Modbus 服务器。

(9)StartAsyncTlsServer: 这个函数用于启动一个异步的基于 TLS 加密的 Modbus 服务器。

(10)StartAsyncUdpServer: 这个函数用于启动一个异步的基于 UDP 的 Modbus 服务器。

(11)StartSerialServer: 这个函数用于启动一个同步的基于串口的 Modbus 服务器。

(12)StartTcpServer: 这个函数期望用于启动一个同步的基于 TCP/IP 的 Modbus 服务器。(备注:源码其实是异步的)

(13)StartTlsServer: 这个函数期望用于启动一个同步的基于 TLS 加密的 Modbus 服务器。(备注:源码其实是异步的)

(14)StartUdpServer: 这个函数期望用于启动一个同步的基于 UDP 的 Modbus 服务器。(备注:源码其实是异步的)

这些模块和函数提供了多种不同类型的 Modbus 服务器的实现方式,可以根据具体的需求选择合适的模块和函数来创建和启动 Modbus 服务器。

2、模块的选用

StartAsyncTcpServerStartTcpServerpymodbus 库中用于启动 Modbus TCP 服务器的两种不同的方法,其主要区别在于同步(Synchronous)和异步(Asynchronous)执行方式。

(1)StartAsyncTcpServer(异步方式):

StartAsyncTcpServer 是一个异步函数,它使用 Python 的 asyncio 模块来实现异步的 Modbus TCP 服务器。在异步编程中,事件循环(event loop)可以处理多个任务,使得程序在等待某些耗时操作(比如 I/O 操作)时不会被阻塞。这意味着它可以同时处理多个客户端连接,提高了服务器的并发性能。

该函数的调用方式是异步的,需要在异步上下文(比如异步函数内部或者异步脚本中)使用。

(2)StartTcpServer(同步方式):

StartTcpServer 是一个同步函数,它使用 Python 的标准同步执行方式,会阻塞当前线程。在同步模式下,每次只能处理一个客户端连接。这意味着服务器只能顺序处理客户端请求,一个接一个地处理。

该函数的调用方式是同步的,可以在任何地方调用。

总之,选择哪种方式取决于你的应用场景。如果需要处理大量并发连接并提高性能,可以选择异步方式;如果简单的同步处理能够满足需求,可以选择同步方式。

本文采用StartAsyncTcpServer,所以他涉及到的模块是StartTcpServer,源码如下:

def StartTcpServer(**kwargs):  # pylint: disable=invalid-name"""Start and run a serial modbus server."""return asyncio.run(StartAsyncTcpServer(**kwargs))

如果要停止异步,需要调用ServerAsyncStop模块。

二、一个Demo

1、服务端读写自身的保持寄存器的示例

import asyncio
import threading
import time
import json
from pymodbus.server import StartTcpServer, ServerAsyncStop
from pymodbus.datastore import ModbusSequentialDataBlock, ModbusSlaveContext, ModbusServerContextif __name__ == "__main__":# Modbus TCP服务器的IP地址和端口号server_ip = "192.168.1.188"port = 502station = 1# 创建一个数据存储区,用于存储从客户端读取的数据store = ModbusSlaveContext(hr=ModbusSequentialDataBlock(0, [0] * 100))# 创建一个服务器上下文,用于处理客户端的请求context = ModbusServerContext(slaves=store, single=True)# 启动ModBusTCP服务器# 创建并启动线程(启动异步服务器)# StartTcpServer(context=context, address=(server_ip, port))modbus_server_thread = threading.Thread(target=StartTcpServer, kwargs=({"context":context, "address":(server_ip, port)}))modbus_server_thread.start()# 设置保持寄存器的0地址的值为s# 定义函数参数fc_as_hex = 0x03  # 功能码,例如读保持寄存器是"0x03"write_address = 0  # 起始地址read_address = 10read_count = 1values = [115]  # 触发指令s 要设置的多个值列表,如[10, 20, 30]# 调用函数,设置0地址为触发指令sstore.setValues(fc_as_hex, write_address, values)# 获取保持寄存器的值并打印hr_values = store.getValues(3, read_address, count=read_count)print("Hold Register Values:", hr_values)assert hr_values == [0], print("测试失败!")time.sleep(10)try:print("停止服务器")asyncio.run(ServerAsyncStop())  # 停止服务器except:pass

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/121619.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【JAVA学习笔记】48 - 八大常用Wrapper类(包装类)

一、包装类 1.针对八种基本定义相应的引用类型一包装类 2.有了类的特点,就可以调用类中的方法。 黄色背景的表示父类是Number 二、包装类和基本数据的转换 演示包装类和基本数据类型的相互转换,这里以int和Integer演示。 1.jdk5前的手动装箱和拆箱方…

逆向第一课---安装ADB工具,并使用夜神模拟器连接

1、安装ADB 如果安装了Android SDK可以直接去android_sdk/platform-tools/目录下使用ADB命令。 如果没有安装Android SDK,需要先通过下面的地址下载ADB https://adbdownload.com/ 根据自己的系统点击下载,我这里使用Windows系统,所以下载Wi…

国产CAN总线收发芯片DP1042 兼容替换TJA1042

说明 1 简述 DP1042是一款应用于 CAN 协议控制器和物理总线之间的接口芯片,可应用于卡车、公交、小汽车、工业控制等领域,支持 5Mbps CAN FD 灵活数据速率,具有在总线与 CAN 协议控制器之间进行差分信号传输的能力,完全兼容“ISO…

安装clang

安装clang: scanscan-virtual-machine:~$ clang -v Ubuntu clang version 14.0.0-1ubuntu1.1 Target: x86_64-pc-linux-gnu Thread model: posix InstalledDir: /usr/bin Found candidate GCC installation: /usr/bin/../lib/gcc/x86_64-linux-gnu/11 Selected GCC installatio…

【pytorch】torch.gather()函数

dim0时 index[ [x1,x2,x2],[y1,y2,y2],[z1,z2,z3] ]如果dim0 填入方式为: index[ [(x1,0),(x2,1),(x3,2)][(y1,0),(y2,1),(y3,2)][(z1,0),(z2,1),(z3,2)] ]input [[1, 2, 3, 4],[5, 6, 7, 8],[9, 10, 11, 12] ] # shape(3,4) input torch.…

Spring Security —漏洞防护—跨站请求伪造(CSRF)

在终端用户可以 登录 的应用程序中,必须考虑如何防止 跨站请求伪造(CSRF)。 Spring Security 默认为 不安全的HTTP方法(如POST请求)提供CSRF攻击防护,因此无需额外代码。你可以使用下面的方法明确指定默认…

【Html】交通灯问题

效果 实现方式 计时器:setTimeout或setInterval来计时。setInterval和 setTimeout 在某些情况下可能会出现计时不准确的情况。这通常是由于JavaScript的事件循环机制和其他代码执行所需的时间造成的。 问询:通过getCurrentLight将每个状态的持续时间设置…

【纯离线】Ubuntu离线安装ntp时间同步服务

Ubuntu离线安装ntp服务 准备阶段:下载安装包 apt-get download ntp apt-get download ntpdate 一、服务端( 192.166.6.xx) 1、环境准备 先判断是否已安装 systemd-timesyncd systemctl is-active systemd-timesyncd 如果返回结果是 active,则表示…

ES 8 新特性

1. async 和 await async 和 await 两种语法结合可以让异步代码像同步代码一样。(即:看起来是同步的,实质上是异步的。) 先从字面意思理解,async 意为异步,可以用于声明一个函数前,该函数是异步的。await 意为等待,即等待一个异步方法完成。 1.1 async async 声明(…

spring boot利用redis作为缓存

一、缓存介绍 在 Spring Boot 中,可以使用 Spring Cache abstraction 来实现缓存功能。Spring Cache abstraction 是 Spring 框架提供的一个抽象层,它对底层缓存实现(如 Redis、Ehcache、Caffeine 等)进行了封装,使得在…

如何在VScode中让printf输出中文

如何在VScode中让printf输出中文? 1、在“Visual Studio Code”图标上右击,弹出对话框。见下图: 2、点击“以管理员身份运行”,得到下图: 3、点击“UTF-8”按钮,得到下图: 4、点击“通过编码重…

Docker创建mysql容器

1.递归创建目录,若上级目录不存在,会按目录层级自动创建目录 mkdir -p创建宿主机挂载文件夹 mkdir -p /data/docker/mysql/{conf,data,logs}/ 2.拉取mysql镜像 docker pull mysql:8.0 3.创建容器 docker run -itd --restartalways --name mysql8.…

电脑提示找不到msvcp140.dll无法继续执行代码的4种解决办法

今天我想和大家分享的是关于找不到msvcp140.dll无法继续执行代码的4种解决办法。在我们日常的教学和工作中,有时候会遇到这样的问题,让我们感到困惑和无奈。那么,msvcp140.dll究竟是什么?为什么会丢失呢?接下来&#x…

[hive] 窗口函数 ROW_NUMBER()

文章目录 ROW_NUMBER() 示例窗口函数 ROW_NUMBER() 在 Hive SQL 中,ROW_NUMBER()是一个用于生成行号的窗口函数。 它可以为查询结果集中的每一行分配一个唯一的行号。 以下是 ROW_NUMBER() 函数的基本语法: ROW_NUMBER() OVER (PARTITION BY column…

matlab simulink PMSM永磁电机DTC控制

1、内容简介 略 10-可以交流、咨询、答疑 2、内容说明 PMSM永磁电机DTC控制 PMSM、永磁电机、DTC控制 传 是 ,它的工作原理是:首先设定好运行期望值和滞环的容差值,然后把电机 到的差值 号输出,可以 示需要减小 大输出…

MySQL数据库备份实战

一、为什么进行数据库备份? 保证业务连续性:数据库中存储着企业的核心业务数据,如果数据丢失或损坏,将会对企业的业务运营产生重大影响。通过定期备份数据库,可以在系统故障或数据丢失时快速恢复数据,保证业务的连续性。 保护数据资产:数据库中存储着企业的重要数据资产…

【Linux】虚拟机安装Linux、客户端工具及Linux常用命令(详细教程)

目录 一、导言 1、引言 2、使用场景 二、Linux安装 1、安装 2、网络配置 2.1、查看网络配置 2.2、更改网络配置 三、安装客户端工具 1、介绍 2、安装MobaXterm 3、换源 4、拍照功能 四、常用命令 一、导言 1、引言 Linux是一个开源的操作系统内核,它最…

基于Pytorch的驾驶员分心行为实时检测

本文使用深度学习和Pytorch(PyTorch 2.0.1\Torchvision 0.15.2)实时检测驾驶员的分心行为,并附录完整代码。 检测分心驾驶是现代汽车中最重要的功能之一。无论是自动驾驶汽车还是其它高端汽车,都配备了驾驶员监控系统,以持续跟踪驾驶员的行为。这对确保驾驶员保持目光在道路…

数据分享 I 地级市人口和土地使用面积基本情况

数据地址: 地级市人口和土地使用面积基本情况https://www.xcitybox.com/datamarketview/#/Productpage?id394 基本信息. 数据名称: 地级市人口和土地使用面积基本情况 数据格式: ShpExcel 数据时间: 2021年 数据几何类型: 面 数据坐标系: WGS84坐标系 数据…

【Maven教程】(九):使用 Maven 进行测试 ~

目录 1️⃣ account-captcha 1.1 account-captcha 1.2 account-captcha 的主代码 1.3 account-captcha的测试代码 2️⃣ maven-surefire-plugin 简介 3️⃣ 跳过测试 4️⃣ 动态指定要运行的测试用例 5️⃣ 包含与排除测试用例 6️⃣ 测试报告 6.1基本的测试报告 6.…