Python MJPEG Server

Я пытаюсь выполнить обработку зрения на Raspberry Pi и отслеживать эффекты на графическом интерфейсе. Использование cv2.imshow действительно снижает частоту кадров, поэтому вместо этого я пытаюсь передать операции на локальный сервер MPEG, а затем отслеживать их из chrome на другом рабочем столе. Вот код, который я разработал:

from http.server import BaseHTTPRequestHandler, HTTPServer
from socketserver import ThreadingMixIn
from threading import Thread
import imutils
import sys

class CamHandler(BaseHTTPRequestHandler):
    def do_GET(self):
        print(self.path)
        if self.path.endswith('/stream.mjpg'):
            self.send_response(20)
            self.send_header('Content-type', 'multipart/x-mixed-replace; boundary=--jpgboundary')
            self.end_headers()
            while True:
                try:

                    if(frame != None):
                        pass
                    r, buf = cv2.imencode(".jpg", frame)
                    self.wfile.write("--jpgboundary\r\n".encode())
                    self.end_headers()
                    self.wfile.write(bytearray(buf))
                except KeyboardInterrupt:
                    break
            return

        if self.path.endswith('.html') or self.path == "/":
            self.send_response(200)
            self.send_header('Content-type', 'text/html')
            self.end_headers()
            self.wfile.write('<html><head></head><body>')
            self.wfile.write('<img src="http://localhost:9090/stream.mjpg" height="240px" width="320px"/>')
            self.wfile.write('</body></html>')
            return

class ThreadedHTTPServer(ThreadingMixIn, HTTPServer):
    """Handle requests in a separate thread."""


class WebcamVideoStream:
    def __init__(self, src=0):
        # initialize the video camera stream and read the first frame
        # from the stream
        self.stream = cv2.VideoCapture(src)
        # self.stream.set(3, 1920)
        # self.stream.set(4, 1080)
        # self.stream.set(15,-100)
        (self.grabbed, self.frame) = self.stream.read()

        # initialize the variable used to indicate if the thread should
        # be stopped
        self.stopped = False

    def start(self):
        # start the thread to read frames from the video stream
        Thread(target=self.update, args=()).start()
        return self

    def update(self):
        # keep looping infinitely until the thread is stopped
        while True:
            # if the thread indicator variable is set, stop the thread
            if self.stopped:
                self.stream.release()
                return

            # otherwise, read the next frame from the stream
            (self.grabbed, self.frame) = self.stream.read()

    def read(self):
        # return the frame most recently read
        return self.frame

    def stop(self):
        # indicate that the thread should be stopped
        self.stopped = True


def realmain():
    global frame

    ip = 'localhost'

    try:
        cap = WebcamVideoStream().start()
        server = ThreadedHTTPServer((ip, 9090), CamHandler)
        print("starting server")
        target = Thread(target=server.serve_forever,args=())

        i = 0
        while True:

            img = cap.read()
            img1 = imutils.resize(img, width=600)
            img2 = cv2.GaussianBlur(img1, (5, 5), 0)
            #frame = cv2.cvtColor(img2, cv2.COLOR_BGR2HSV)

            frame = cv2.Canny(img, 35, 125)
            if(i == 0):
                target.start()
            i +=1

    except KeyboardInterrupt:
        sys.exit()

if __name__ == '__main__':
    realmain()

Прямо сейчас я могу запустить сервер со своего рабочего стола и просматривать MPEG в порядке с chrome на своем рабочем столе, но я не могу запустить сервер с моего raspberry pi и получить к нему доступ, введя этот URL: http:// "RASPBERRY PI IP":9090/stream.mjpg, на моем рабочем столе. Когда я делаю это, Chrome просто говорит, что веб-страница недоступна. Даже при запуске сервера на PI я не могу просмотреть URL-адрес в браузере Epiphany, он просто загружает изображение. Интересно, есть ли у кого-нибудь ответ на эту проблему?

Кроме того, есть ли более быстрый способ распаковать и повторно сжать JPG перед отправкой его на сервер?

1 ответ

Вы привязываете сервер к localhost:

ip = 'localhost'

try:
    cap = WebcamVideoStream().start()
    server = ThreadedHTTPServer((ip, 9090), CamHandler)

Попробуйте изменить 'localhost' в '0.0.0.0', Это свяжет сервер со всеми сетевыми интерфейсами.

Другие вопросы по тегам