【问题标题】:Python TCP Server Stops Responding After A WhilePython TCP 服务器在一段时间后停止响应
【发布时间】:2016-06-07 01:52:55
【问题描述】:

所以我在我的 RPI 上编写了这个 python 代码来创建一个与我的快思聪控制处理器对话的数字海报。由于某种原因,我的代码在一段时间后停止响应。我不知道为什么。 我不知道我的 Pi 是否会睡觉,但如果有人能指出我的代码中可能导致这种情况的任何内容,请告诉我。

编辑:我自己想出来的。非常感谢所有评论的人。

每次我通过循环时,我都在创建一个新的 FBI 进程,我最终用尽了 Pi 的所有 RAM,直到它停止,因为它没有任何剩余。我现在在加载修复该问题的图像后终止 FBI 进程。感谢大家的帮助。

我的功能和设置资料:

import socket
import os
import thread
import sys
import urllib
from time import ctime
from PIL import Image
import time
import random
import logging

frameBufferCommand = "sudo fbi -a -T 1 -d /dev/fb0 -noverbose "
moviePosterLocation = "/home/pi/movieposters/"
openBlackImage = "/home/pi/movieposters/special/black.jpg"
killFrameBuffer = "sudo killall fbi"
turnOffScreen = "sudo /opt/vc/bin/tvservice -o"
turnOnScreen = "sudo /opt/vc/bin/tvservice -p"

def splitString(input): 
    stringList = input.split("/x00/") 
    return stringList

def displayRandomPoster():
    displayingPoster = False
    fileCount = next(os.walk(moviePosterLocation))[2] #get the number of available posters
    print('Current # Of Posters in Directory: ' + str(len(fileCount)))

    attemptNumber = 0

    while not displayingPoster:
        posterToDisplay = random.randint(0, len(fileCount))
        print('Trying To Display A Random Poster')
        attemptNumber += 1

        try:
            image = Image.open(moviePosterLocation + fileCount[posterToDisplay]) #open the current image
            width, height = image.size
        except IndexError as msg:
            print("encountered an IndexError while opening an image")
            width = 0
            height = 0      
        except IOError as msg:
            print(msg)
        try:
            conn.send(msg)
        except socket.error as msg:
            print("Socket Error")


    if width > height:
        if attemptNumber > 5:
            print("Too Many Attempts, Stopping")
            break
        else:
            print("We Think This Isnt A Poster, Trying Again")               
            continue    
    else:
        try:
            conn.send("  Displaying Poster: " + str(fileCount[posterToDisplay]))
        except socket.error as msg:
            print msg                
        os.system(frameBufferCommand + moviePosterLocation + fileCount[posterToDisplay])
        displayingPoster = True
        return

正在监听的线程和主循环:

#-- CLIENT THREAD --

def client(conn):
    try:
        conn.send("Connected With Raspberry Pi")
        os.system(frameBufferCommand + openBlackImage)
    except socket.Error as msg:
        print(msg)

print(str(bindSuccess))

while 1:    
    dataReceived = conn.recv(1024)
    reply = "OK.. "
    conn.send(reply + dataReceived)
    dataList = splitString(dataReceived)
    print(dataList)
    if dataList[6] == "": 
        print("dataList[6] is empty, displaying a random poster")
        displayRandomPoster()
    else: 
        try:    
            moviePosterURL = dataList[6]            
            splitPosterURL = moviePosterURL.split("%")            
            moviePosterFilename = splitPosterURL[7]                
            urllib.urlretrieve(moviePosterURL, moviePosterLocation + moviePosterFilename)                
            conn.send("XBMC Movie Poster Downloading")
            conn.send("Movie Poster saved as: " + moviePosterLocation + moviePosterFilename)
            print("Movie Poster saved as: " + moviePosterLocation + moviePosterFilename)                            
        except socket.error:
            print("Encountered Socket Error While Downloading Poster - Line 80")            
        try:
            os.system(frameBufferCommand + moviePosterLocation + moviePosterFilename)
            print('Opening Downloaded Poster')
        except OSError as msg:
            print(str(msg[0]) + str(msg[1]))
    if not dataReceived:
        break
    time.sleep(1)


#-- MAIN FUNCTION --

host = ''
communicationPort = 5005

bindSuccess = False

crestronSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

print("Socket Created Successfully")

try:
    crestronSocket.bind((host, communicationPort))
    bindSuccess = True
except socket.Error as msg: 
    bindSuccess = False
    print("Socket Bind Error" + msg)
    sys.exit()

crestronSocket.listen(1)
print("Crestron Socket Listening")

while bindSuccess == True:
    #wait to accept a connection - blocking call
    conn, addr = crestronSocket.accept()
    print('Connected with Client: ' + addr[0] + ':' + str(addr[1]))      
    thread.start_new_thread(client , (conn,))
crestronSocket.close()

【问题讨论】:

  • 代码太多了。尝试将其修剪为MVCE
  • @LexScarisbrick 你的意思是为了调试目的吗?
  • 请阅读我其他评论中的链接。要点是人们必须筛选的代码越多,您得到答案的可能性就越小。
  • “代码停止响应” - 您的意思是您的服务器不接受新连接,还是现有连接停止工作?在 ConnectionThread 函数中,您应该在它退出并关闭连接的地方放置一些打印语句,也许您的代码正在那里?否则,是的,代码太多了,任何人都无法轻松地深入了解。也太特定于应用程序 - 如果有人可以自己运行它,那么检查你的代码是最容易的,所以把自己放在一个潜在的回答者的位置,一个没有你可用的图像/位的人。
  • @barny 现有连接停止响应。但是我想我可能已经想通了。我只是在看电视时运行脚本,我想我可能已经发现了问题。在 displayRandomPoster() 函数中,我遇到了 IOError,因为它试图打开一个没有正确保存的文件。我认为这就是问题所在。但我不确定。

标签: python raspberry-pi tcpsocket


【解决方案1】:

每次我通过循环时,我都会创建一个新的 FBI 进程,我最终用尽了 Pi 的所有 RAM,直到它停止,因为它没有任何剩余。我现在在加载修复该问题的图像后终止 FBI 进程。感谢大家的帮助。

我还想出了一些其他的东西,让它运行得更好/更无缝。

【讨论】:

    猜你喜欢
    • 2015-05-01
    • 1970-01-01
    • 1970-01-01
    • 2018-05-24
    • 1970-01-01
    • 1970-01-01
    • 2019-10-20
    • 2011-09-15
    • 1970-01-01
    相关资源
    最近更新 更多