运行使用 twind 守护进程的基于非 Twisted 的 Python 脚本

Question

我正在编写一个由服务器（使用 Twisted）和客户端（不使用 Twisted）组成的 Python 程序

服务器部分是使用 Twisted 和 Twisted 的 应用程序框架 并通过 Twistd 启动以进行守护进程。

在不同服务器上运行的客户端是一个简单的 Python 脚本，没有任何 Twisted 的东西（也没有应用程序框架特定的东西）。它也应该作为守护进程运行。仅供参考，这是来源：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import socket
import sys
import time
import syslog

SERVER_IP = '127.0.0.1' 
SERVER_PORT = 43278 
BEAT_PERIOD = 1

class HeartbeatClient:
    '''
    A Client sending heartbeats to a monitoring server.
    '''
    def __init__(self, server_ip, port, beat_period):
        syslog.syslog( ('Sending heartbeat to IP %s , port %d' +
                        '\n press Ctrl-C to stop\n') 
                        % (SERVER_IP, SERVER_PORT))

    def run(self):
        while True:
            hbSocket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
            hbSocket.sendto('PyHB', (SERVER_IP, SERVER_PORT))
            if __debug__: 
                print 'Time: %s' % time.ctime()
            time.sleep(BEAT_PERIOD)

if __name__ == '__main__':
    hbc = HeartbeatClient() 
    hbc.run()

现在我想知道是否也可以使用 Twistd 对客户端进行守护进程？因此，我会从客户端创建一个 Twisted-Application。但我看到的所有关于 Twisted 应用程序的示例都实现了一些 Twisted 互联网服务器内容（例如我的例子中的 internet.UDPServer...），但我的客户端不使用这些内容。

那么是否可以使用 Twistd 将我的客户端作为守护进程启动，我需要进行哪些更改？我应该重写客户端以充分利用 Twisted 吗？如果是，是否有类似的示例如何编写基于 Twisted 的网络客户端？

或者我是否必须为客户端使用不同的守护进程库？有一个很好的库，但我试图保持一致并使用客户端和服务器具有相同的守护进程机制。

Answer 1

使用 Twisted，作为 tac 文件，您的 HeartbeatClient 将如下所示：

from twisted.application.service import Application, Service
from twisted.internet import reactor
from twisted.internet.task import LoopingCall
from twisted.internet.protocol import DatagramProtocol

class HeartbeatClient(Service):
    def startService(self):
        self._call = LoopingCall(self._heartbeat)
        self._call.start(BEAT_PERIOD)

    def stopService(self):
        self._call.stop()

    def _heartbeat(self):
        port = reactor.listenUDP(0, DatagramProtocol())
        port.write('PyHB', (SERVER_IP, SERVER_PORT))
        port.stopListening()

application = Application("PyHB")
HeartbeatClient().setServiceParent(application)

请注意 reactor.listenUDP 的使用，即使您只发送 UDP 数据报，而不是接收任何。 UDP实际上没有客户端和服务器的概念，它只有开放的端口。所有UDP端口都可以发送和接收数据报。这就是为什么只有 reactor.listenUDP，而不是 reactor.connectUDP。

除此之外，LoopingCall 为您提供所需的循环，并将代码放入自定义 Service 子类中，让您可以在适当的时间启动和停止循环。