python进程将赢得杀人方法的停止

Question

因此，我正在尝试拥有一个自制的LED控制器（Raspberry Pi）。

控制器应该能够播放我自己预先定义的不同场景。 现在解决主要问题...

控制器以TCP服务器运行，并通过TCP消息改变他的场景。 我编码了很多场景，这些场景需要在循环时无休止地运行。 因此，如果新的TCP消息到达，我决定使用多处理能够杀死运行的“场景过程”。

因此，我的两个脚本的尴尬结果是，如果我在Windows上运行了服务器脚本，它的工作原理非常有效，但是如果IM更改以在Raspberry Pi上运行服务器脚本，则运行过程并不会像应有的那样被杀死。

因此，当我的服务器测试脚本时，我使用了以下内容：

import multiprocessing
import time

from time import sleep

try: 
    from analyse import *
    from handler import *
    from history import writeState
    from led import *
except: pass 

import socket


from subprocess import check_output #um die IP-Adresse unter Raspian auszulesen 
from platform import system


class SYSINFO():
    os=system() #Fragt das System nach dem laufenden OS-Typ ab

    if os=="Linux":
        IP_ADDRESS=check_output(["hostname",'-I']).decode().split(" ")[0]
    elif os=="Windows" or os=="Darwin":
        IP_ADDRESS=  socket.gethostbyname(socket.gethostname())#"192.168.168.97"


class MyProcess(multiprocessing.Process):

    def __init__(self, ):
        multiprocessing.Process.__init__(self)
        self.exit = multiprocessing.Event()

    def run(self):
        while not self.exit.is_set():
            print(round(time.perf_counter()), self.pid)
            time.sleep(1)
        print("You exited!")

    def shutdown(self):
        print("Shutdown initiated")
        self.exit.set()

class TCPController(multiprocessing.Process): 
    def __init__(self, ):
        multiprocessing.Process.__init__(self)
        self.exit = multiprocessing.Event()

    def run(self): 
        counter=0
        
    
    def shutdown(self):
        print("Shutdown initiated")
        self.exit.set()

if __name__ == "__main__":
    
    HOST = SYSINFO.IP_ADDRESS  # Standard loopback interface address (localhost
    PORT = 6060  # Port to listen on (non-privileged ports are > 1023)
    
    while True:

        with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
            s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
            s.bind((HOST, PORT))
            print(f"server listens under  {HOST!r} ,  {PORT!r} now")

            s.listen()
        
            while True: 
                try:
                    conn, addr = s.accept()
                    print("waiting for connection")
                    with conn: 
                        print(f"Connected by {addr}")
                        data = conn.recv(1024).decode()
                        print(data)
                        if data=="on": 
                            process = MyProcess()
                            process.daemon=True
                            process.start()
                            time.sleep(3)
                        elif data=="off": 
                            #process.shutdown()
                            process.kill()
                            time.sleep(3)
                            print("Child process state: %d" % process.is_alive())
                except: pass
                sleep(.5)

我的客户端测试周期脚本看起来像是

# echo-client.py

import socket

from time import sleep

class heimkinoSteuereinheit: 
        
    HOST = "192.168.168.97" #"192.168.168.97"  # The server's hostname or IP address
    PORT = 6060  # The port used by the server


def cinemaclient(msg):

    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        s.connect((heimkinoSteuereinheit.HOST, heimkinoSteuereinheit.PORT))
        s.sendall(msg.encode())
        data = s.recv(1024).decode()
       
    print(f"Received {data!r}")
    return data

while True: 
  sleep(1)
  cinemaclient("on")
  sleep(5)
  cinemaclient("off")

希望你们能提供帮助。

感谢您的帮助， 卢卡

Answer 1

可变过程仅在

if data=="on"

的变量过程的同时

if data=="off

您使用尚未定义 定义。那是故意完成的吗？

此外，您的代码是什么意思是不起作用的。你有任何错误吗？