Python实现Mosbus_Tcp协议通信

【实例简介】

配合Qt5以及相关工具，实现数据的读写功能，并包括中文注释。

【实例截图】

【核心代码】

import sys
import StartWindow
import SetWindow
import time
import logging
import modbus_tk
import modbus_tk.defines as cst
import modbus_tk.modbus_tcp as modbus_tpc
from PyQt5.QtWidgets import *
from PyQt5.QtGui import *
from PyQt5.QtCore import *
from ctypes import *
# 编辑一个函数，可以将16进制转化为浮点数
def convert(s):
    i = int(s, 16)                   # convert from hex to a Python int
    cp = pointer(c_int(i))           # make this into a c integer
    fp = cast(cp, POINTER(c_float))  # cast the int pointer to a float pointer
    return fp.contents.value         # dereference the pointer, get the float

# 确立一个用户账号，密码
passport = {'admin': 'admin'}
# 导入一个全局变量，这个变量将控制是否进行循环读取数据
get_datas_state = False
logger = modbus_tk.utils.create_logger("console")


# 创建一个新的线程，这个线程起始是一个Qt自带的线程，只不过我们将里面的run（）重写成我们需要的
class WorkThread(QThread):
    trigger = pyqtSignal()

    def __init__(self):
        super(WorkThread, self).__init__()

    def run(self):

        try:
            # 获取输入栏中的地址
            ip = window2.ipID.text()
            # 建立一个与从站的连接
            master = modbus_tpc.TcpMaster(host=ip)
            master.set_timeout(5.0)
            window2.contented.hide()
            # 循环进行数据的读取
            while get_datas_state:
                # 读取保持寄存器前4个字符
                data = master.execute(1, cst.READ_HOLDING_REGISTERS, 0, 4)
                fdata = []
                for i in range(0, 3, 2):
                    n1 = hex(data[i]).replace('0x', '')
                    n2 = hex(data[i 1]).replace('0x', '')
                    n = n1 n2
                    fdata.append(('%.2f' % convert(n)))

                # 将数据传入对应的控件中
                window2.wellPress.display(fdata[0])
                window2.press2.display(fdata[1])
                # 间隔一秒
                time.sleep(1)
        # 出现任何异常均显示无法连接
        except Exception as e:
            print('无法连接')

# 建立一个类，这个类继承了起始界面的设计
class StartWin(QMainWindow, StartWindow.Ui_StartWindow):
    def __init__(self):
        super().__init__()
        self.setupUi(self)
    # 添加了账户确认的函数
    def makesure_click(self):

        # 获取用户输入的账号、密码
        self.name = self.userName.text()
        self.code = self.passWord.text()
        # 账号密码确认
        if self.name and self.code:

            if self.name in passport.keys():
                if self.code == passport[self.name]:
                    self.hide()
                    window2.show()
                else:
                    QMessageBox.warning(self, '错误', '请重新输入密码')
            else:
                QMessageBox.warning(self, '错误', '没有该用户')
        else:
            QMessageBox.warning(self, '错误', '请输入正确的账号密码')

# 建立一个类，这个类继承了设置界面。
class SetWin(QMainWindow, SetWindow.Ui_SetWindow):

    def __init__(self):
        super().__init__()
        self.setupUi(self)
    # 添加连接函数
    def get_content(self):
        global get_datas_state
        get_datas_state = True

        get_datas()

# 必须把新的线程放在Qt线程外进行处理
def get_datas():
    workthread.start()

 app = QApplication(sys.argv)
# 建立窗口
window = StartWin()
window2 = SetWin()
# 显示窗口
window.show()
# 建立一个线程
workthread = WorkThread()

# 退出整个主循环即 退出程序
sys.exit(app.exec_())