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

本文介绍了Python Twisted 接收命令从 TCP 写入串行设备返回响应的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！

问题描述

我已成功连接到 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\r\n')

    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 + "\r\n")

    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()

这篇关于Python Twisted 接收命令从 TCP 写入串行设备返回响应的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！

Modem