Python Twisted 从 TCP 接收命令写入串行设备返回响应

2022-01-18 00:00:00 python twisted serial-port

问题描述

我已经成功连接到 USB 调制解调器，客户端可以通过 tcp 连接到我的 reactor.listenTCP，从调制解调器接收到的数据将被发送回客户端.我想从客户端接收数据并将其发送到调制解调器.我正在努力让它工作.任何帮助将不胜感激！代码:

I've managed to connect to usb modem and a client can connect via tcp to my reactor.listenTCP,the data received from modem will be send back to client. I'm want to take dataReceived from client and send this to modem..I'm struggling to get this to work.Any help will be highly appreciated! the code:

from twisted.internet import win32eventreactor
win32eventreactor.install()
from twisted.internet import reactor
from twisted.internet.serialport import SerialPort
from twisted.internet.protocol import Protocol, Factory
from twisted.python import log
import sys

log.startLogging(sys.stdout)
client_list = []#TCP clients connecting to me

class USBClient(Protocol):

    def connectionFailed(self):
        print "Connection Failed:", self
        reactor.stop()

    def connectionMade(self):
        print 'Connected to USB modem'
        USBClient.sendLine(self, 'AT
')

    def dataReceived(self, data):
        print "Data received", repr(data)
        print "Data received! with %d bytes!" % len(data)
        #check & perhaps modify response and return to client
        for cli in client_list:
            cli.notifyClient(data)
        pass

    def lineReceived(self, line):
        print "Line received", repr(line)

    def sendLine(self, cmd):
        print cmd
        self.transport.write(cmd + "
")

    def outReceived(self, data):
        print "outReceived! with %d bytes!" % len(data)
        self.data = self.data + data

class CommandRx(Protocol):

    def connectionMade(self):
        print 'Connection received from tcp..'
        client_list.append(self)

    def dataReceived(self, data):
        print 'Command receive', repr(data)
        #Build command, if ok, send to serial port
        #????
    def connectionLost(self, reason):
        print 'Connection lost', reason
        if self in client_list:
            print "Removing " + str(self)
            client_list.remove(self)

    def notifyClient(self, data):
        self.transport.write(data)

class CommandRxFactory(Factory):
    protocol = CommandRx
    def __init__(self):
        client_list = []

if __name__ == '__main__':
    reactor.listenTCP(8000, CommandRxFactory())
    SerialPort(USBClient(), 'COM8', reactor, baudrate='19200')
    reactor.run()

解决方案

你的问题不是twisted，而是python.阅读此常见问题解答条目:

Your problem is not about twisted, but about python. Read this FAQ entry:

如何在一个连接上进行输入导致另一个连接上的输出?

问题是，如果您想在串行连接协议中向 TCP 连接的客户端发送内容，只需向协议传递对工厂的引用，这样您就可以使用该引用来构建桥接.

Thing is, if you want to send stuff to a TCP-connected client in your serial-connected protocol, just pass to the protocol a reference to the factory, so you can use that reference to make the bridge.

以下是一些大致执行此操作的示例代码:

Here's some example code that roughly does this:

class USBClient(Protocol):
    def __init__(self, network):
        self.network = network
    def dataReceived(self, data):
        print "Data received", repr(data)
        #check & perhaps modify response and return to client
        self.network.notifyAll(data)
    #...    

class CommandRx(Protocol):
    def connectionMade(self):
        self.factory.client_list.append(self)
    def connectionLost(self, reason):
        if self in self.factory.client_list:
            self.factory.client_list.remove(self)

class CommandRxFactory(Factory):
    protocol = CommandRx
    def __init__(self):
        self.client_list = []

    def notifyAll(self, data):
        for cli in self.client_list:
            cli.transport.write(data)

初始化时，传递引用:

tcpfactory = CommandRxFactory()
reactor.listenTCP(8000, tcpfactory)
SerialPort(USBClient(tcpfactory), 'COM8', reactor, baudrate='19200')
reactor.run()

相关文章