Python设置Socket代理及实现远程摄像头控制的例子

import socksimport socketsocks.setdefaultproxy(socks.PROXY_TYPE_SOCKS5,"127.0.0.1",8088)socket.socket =socks.socksocketimport urllib2urllib2.urlopen('http://www.baidu.com').read()

from VideoCapture import Deviceimport ImageDraw, sys, pygame, timefrom pygame.locals import *import socketimport timefrom PIL import ImageEnhancefrom threading import Threadimport tracebackimport threading  # 全局变量is_sending = Falsecli_address = ('', 0)# 主机地址和端口host = 'localhost'port = 10218# 初始化UDP socketser_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)ser_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)ser_socket.bind((host, port))# 接收线程类，用于接收客户端发送的消息class UdpReceiver(threading.Thread):  def __init__(self):    threading.Thread.__init__(self)    self.thread_stop = False          def run(self):    while not self.thread_stop:      # 声明全局变量，接收消息后更改      global cli_address        global is_sending      try:        message, address = ser_socket.recvfrom(2048)      except:        traceback.print_exc()        continue      print message,cli_address      cli_address = address      if message == 'startCam':        print 'start camera',        is_sending = True        ser_socket.sendto('startRcv', cli_address)              if message == 'quitCam':        is_sending = False        print 'quit camera',  def stop(self):    self.thread_stop = Trueif __name__=='__main__':  res = (640,480)    cam = Device()  cam.setResolution(res[0],res[1])     brightness = 1.0  contrast = 1.0  shots = 0    receiveThread = UdpReceiver()  receiveThread.setDaemon(True)      # 该选项设置后使得主线程退出后子线程同时退出  receiveThread.start()    while 1:    if is_sending:       camshot = ImageEnhance.Brightness(cam.getImage()).enhance(brightness)      camshot = ImageEnhance.Contrast(camshot).enhance(contrast)      clock = pygame.time.Clock()      img = cam.getImage().resize((160,120))      data = img.tostring()      ser_socket.sendto(data, cli_address)       time.sleep(0.05)     else:      time.sleep(1)  receiveThread.stop()  ser_socket.close()    

# -*- coding: UTF-8 -*-import socket, timeimport pygamefrom pygame.locals import *from sys import exit# 服务器地址，初始化socketser_address = ('localhost', 10218)cli_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)# 设置超时cli_socket.settimeout(5)# 向服务器发送消息，并判断接收时是否超时，若超时则重发while 1:  cli_socket.sendto('startCam', ser_address)  try:    message, address = cli_socket.recvfrom(2048)    if message == 'startRcv':      print message      break  except socket.timeout:    continuecli_socket.recvfrom(65536)# 初始化视频窗口pygame.init()screen = pygame.display.set_mode((640,480))pygame.display.set_caption('Web Camera')pygame.display.flip()# 设置时间，可以用来控制帧率clock = pygame.time.Clock()# 主循环，显示视频信息while 1:  try:    data, address = cli_socket.recvfrom(65536)  except socket.timeout:    continue  camshot = pygame.image.frombuffer(data, (160,120), 'RGB')  camshot = pygame.transform.scale(camshot, (640, 480))  for event in pygame.event.get():    if event.type == pygame.QUIT:      cli_socket.sendto('quitCam', ser_address)      cli_socket.close()      pygame.quit()      exit()  screen.blit(camshot, (0,0))  pygame.display.update()   clock.tick(20)