在Python中使用pygame通过套接字进行流媒体传输

1 投票
2 回答
1394 浏览
提问于 2025-04-18 01:46

我正在用Python编写一个网络摄像头的脚本,使用的是pygame模块。问题是我的摄像头会打开,但连接会掉线,并且提示“套接字已经在使用中”。服务器的代码是

import socket

import pygame

import sys


port=5014


#create pygame screen

screen = pygame.display.set_mode((800,600),0)


while True:

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

s.bind(("",port)) # server is available on the whole network by setting host to ""

s.listen(1)

connection, addr = s.accept()

received = []


# loop .recv, it returns empty string when done, then transmitted data is completely received

while True:

    recvd_data = connection.recv(1440021)

    if not recvd_data:

        break

    else:

        received.append(recvd_data)



dataset = ''.join(received)

image = pygame.image.fromstring(dataset,(800,600),"RGB") # convert received image from string

#image = pygame.transform.scale(image,(800,600)) # scale image to 800*600

screen.blit(image,(0,0)) # "show image" on the screen

pygame.display.update()


# check for quit events

for event in pygame.event.get():

    if event.type == pygame.QUIT:

        pygame.quit()

        sys.exit()

客户端的代码是

    import socket

    import pygame

    import pygame.camera

    import sys

    import time



   host = "localhost"

   port = 5014



   pygame.init()

   pygame.camera.init()


    cam_list = pygame.camera.list_cameras() # list available cameras

    webcam = pygame.camera.Camera(cam_list[0],(800,600)) # use first camera in list and set resolution

    webcam.start() # start camera


    while True:

    image = webcam.get_image() # capture image

    data = pygame.image.tostring(image,"RGB") # convert captured image to string, use RGB color scheme

    #print sys.getsizeof(data) # in case somebody wants to know the size of the captured   image


    # prepare for connection to server

    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # TCP is used

    s.connect((host, port))

    s.sendall(data)

    s.close()

    time.sleep(0.1)

我在服务器上遇到的错误是

Traceback (most recent call last):
  File "/root/Desktop/s.py", line 20, in <module>
    s.bind(("",port)) # server is available on the whole network by setting host to ""
  File "/usr/lib/python2.7/socket.py", line 224, in meth
    return getattr(self._sock,name)(*args)
socket.error: [Errno 98] Address already in us

我在客户端遇到的错误是

Traceback (most recent call last):
  File "/root/Desktop/c.py", line 45, in <module>
    s.connect((host, port))
  File "/usr/lib/python2.7/socket.py", line 224, in meth
    return getattr(self._sock,name)(*args)
socket.error: [Errno 111] Connection refused

对了,我已经更改过端口号了,有人知道问题出在哪里吗?

2 个回答

1

问题在于你在第一个无限循环里调用了 s.bind()。第一次调用的时候是可以的,但之后这个地址已经被占用了,所以就不能再绑定了。

s.bind() 和 socket.socket 这些操作不应该放在循环里,它们只需要执行一次。之后可以用无限循环来接受连接。

1

在服务器端,你只需要创建一次套接字(socket),这一步要放在循环外面。然后在循环里面,你可以接受多个连接。

s=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind(("",port)) # server is available on the whole network by setting host to ""
s.listen(1)

while True:
    connection, addr = s.accept()
    received = []
    ...

撰写回答