Python：在等待服务器套接字连接时运行循环

Question

我有一个液晶显示器，我用它来显示我正在我的XBMC上看的电影的时间码，我想显示当前的日期和小时时，什么都不播放。托管LCD的机器正在运行pythonTCPSocketServer服务器，接收要从XBMC安装中显示的文本。问题是我必须保持一个活跃的网络连接，这样XBMC就可以通过插座发送小时和日期，并且液晶显示器可以显示它。 在我看来，最好的做法是显示托管LCD的机器的日期，然后在插座处于活动状态时切换到“时间码视图”。在

是否有任何“pythonic”方法来设置TCPSocketServer，该服务器在等待连接时计算一个显示日期的循环，然后更改其行为以计算通过套接字接收的数据？在

非常感谢

Answer 1

这里有一些代码可以满足您的需要。它启动一个TCP服务器，监听发送到端口9876的文本。当它得到一些文本时，它将它发送到显示对象。代码还设置了一个计时器，它每秒运行一次，向显示对象发送“空闲文本”（即：当前时间戳）。在

显示从服务器获取正常更新文本，从第二个线程获取“空闲文本”。对象知道有多长时间没有收到真实文本，并显示其中一条或其他消息。在

如果显示对象连接到硬件，它可以使用multiprocessing.RLock或其他机制来保护自己。在

玩得开心！在

在lcdcontrol.py来源

import signal, SocketServer, threading, time

class Display(object):
    IDLE_TIME = 5               # seconds

    def __init__(self):
        self.updated = None
        self.write('Hello')

    def _write(self, arg):
        print 'DISPLAY:', arg

    def write(self, arg):
        """
        update display and 'last updated' timestamp
        """
        self._write(arg)
        self.updated = time.time()

    def idle(self, arg):
        """
        update display only if it's been a few seconds
        """
        if time.time() - self.updated >= self.IDLE_TIME:
            self._write(arg)

class DisplayHandler(SocketServer.BaseRequestHandler):

    DisplayObj = None          # class var

    def handle(self):
        text = self.request.recv(1024).strip()
        print "{} wrote: {}".format(
            self.client_address[0], text,
            )
        # send text to LCD immediately
        self.DisplayObj.write(text)


def check_idle(display_obj):
    """
    update display with current time if it's idle
    """
    while True:
        display_obj.idle(
            time.strftime('time: %H:%M:%S'),
        )
        time.sleep(1)


def start_server(host, port):
    """
    start (single threaded) server
    """
    SocketServer.TCPServer(
        (host, port), 
        DisplayHandler,
    ).serve_forever()


def main(host, port):
    display = Display()

    # store global display obj so Handler can get to it
    DisplayHandler.DisplayObj = display

    print 'serving on {}:{}'.format(host, port)
    print 'Example: echo beer | nc localhost {}'.format(port)
    print

    server_t = threading.Thread(
        target=start_server, args=(host, port)
    )
    server_t.daemon = True
    server_t.start()

    idle_t = threading.Thread(
        target=check_idle, args=[display],
        )
    idle_t.daemon = True
    idle_t.start()

    # wait for control-C to interrupt
    try:
        signal.pause()
    except KeyboardInterrupt:
        pass

if __name__ == "__main__":
    main("localhost", 9876)

样品运行

在这里，我启动了服务器，等待了几秒钟，然后输入fortune -s | nc localhost 9876 向我的液晶服务器发送一个简短的幸运饼。在

注意“空闲计时器”在:07停止，输出幸运cookie，等待5秒钟，然后继续执行:13，:14。在切换回空闲时间戳之前，消息显示五秒钟。在

^{pr2}$