从摄像头获取图像，然后通过mjpeg stream方式显示。

# -*- coding: utf-8 -*-

#MJPEG Server for the webcam

import string,cgi,time

from os import curdir, sep

from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer

from SocketServer import ThreadingMixIn

import cv2.cv as cv

import re

import sys

import imutils

import socket

capture = cv.CaptureFromCAM(0)

img1 = cv.QueryFrame(capture)

if img1 == None :

print "No WebCam Found!"

sys.exit()

if len(sys.argv) < 2 :

print "Usage : webcamserver "

cameraQuality = 100

port = 8080

else:

cameraQuality = sys.argv[1]

port = int(sys.argv[2])

class MyHandler(BaseHTTPRequestHandler):

def do_GET(self):

global cameraQuality

try:

self.path=re.sub('[^.a-zA-Z0-9]', "",str(self.path))

if self.path=="" or self.path==None or self.path[:1]==".":

return

if self.path.endswith(".html"):

f = open(curdir + sep + self.path)

self.send_response(200)

self.send_header('Content-type', 'text/html')

self.end_headers()

self.wfile.write(f.read())

f.close()

return

if self.path.endswith(".mjpeg"):

self.send_response(200)

self.wfile.write("Content-Type: multipart/x-mixed-replace; boundary=--aaboundary")

self.wfile.write("\r\n\r\n")

while 1:

img1 = cv.QueryFrame(capture)

cv2mat1 = cv.EncodeImage(".jpeg", img1, (cv.CV_IMWRITE_JPEG_QUALITY, cameraQuality))

JpegData1 = cv2mat1.tostring()

self.wfile.write("--aaboundary\r\n")

self.wfile.write("Content-Type: image/jpeg\r\n")

self.wfile.write("Content-length: "+str(len(JpegData1))+"\r\n\r\n" )

self.wfile.write(JpegData1)

self.wfile.write("\r\n\r\n\r\n")

time.sleep(0.02)

return

if self.path.endswith(".jpeg"):

f = open(curdir + sep + self.path)

self.send_response(200)

self.send_header('Content-type','image/jpeg')

self.end_headers()

self.wfile.write(f.read())

f.close()

return

return

except IOError:

self.send_error(404,'File Not Found: %s' % self.path)

def do_POST(self):

global rootnode, cameraQuality

try:

ctype, pdict = cgi.parse_header(self.headers.getheader('content-type'))

if ctype == 'multipart/form-data':

query=cgi.parse_multipart(self.rfile, pdict)

self.send_response(301)

self.end_headers()

upfilecontent = query.get('upfile')

print "filecontent", upfilecontent[0]

value=int(upfilecontent[0])

cameraQuality=max(2, min(99, value))

self.wfile.write("POST OK. Camera Set to
");

self.wfile.write(str(cameraQuality));

except :

pass

class ThreadedHTTPServer(ThreadingMixIn, HTTPServer):

#class ThreadedHTTPServer(HTTPServer):

"""Handle requests in a separate thread."""

myname = socket.getfqdn(socket.gethostname())

myaddr = socket.gethostbyname(myname)

def main():

while 1:

try:

server = ThreadedHTTPServer(('0.0.0.0', port), MyHandler)

print 'Starting httpServer...'

print 'See :'+ str(port) + '/1.mjpeg'

server.serve_forever()

except KeyboardInterrupt:

print '^C received, shutting down server'

server.socket.close()

if __name__ == '__main__':

main()

在浏览器中输入127.0.0.1:8080/1.mjpeg 访问

或用VLC播放器，输入http://:8080/1.mjpeg访问

说明：1.mjpeg可以换成任意字符.mjpeg，如aaa.mjpeg，都可以访问