def run(self): while True: try: self.sock.connect(self.ADDR) break except: time.sleep(3) continue print('音频客户端已经连接...') self.stream = self.p.open(format = FORMAT, channels=CHANNELS, rate=RATE, input=True, frames_per_buffer=CHUNK) while self.stream.is_active(): frames = [] for i in range(0, int(RATE / CHUNK * RECORED_SECONDS)): data = self.stream.read(CHUNK) frames.append(data) # 对语音进行变声 sound = AudioSegment.from_wav(b''.join(frames)) if self.stream.rate > 200: sound = sound.low_pass_filter(500) # 将音调调低一些 elif self.stream.rate < 200: sound = sound.high_pass_filter(500) # 将音调调高一些 data = sound.export(format='wav') senddata = pickle.dumps(frames) try: self.sock.sendall(struct.pack("L", len(senddata)) + senddata) except: break 无法打开视频，在此基础上针对此问题进行修改

这段代码是音频客户端代码，如果您想打开视频，则需要使用视频客户端代码。以下是视频客户端代码，您可以根据您的需求进行修改和优化。

import cv2
import numpy as np
import socket
import struct
import pickle
import time

class VideoClient:
    def __init__(self, host, port):
        self.host = host
        self.port = port
        self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.p = None

    def run(self):
        while True:
            try:
                self.sock.connect((self.host, self.port))
                break
            except:
                time.sleep(3)
                continue
        print('视频客户端已经连接...')

        # 打开摄像头
        cap = cv2.VideoCapture(0)
        while True:
            ret, frame = cap.read()

            # 对视频进行处理
            # ...

            # 将视频帧发送到服务器
            data = pickle.dumps(frame)
            try:
                self.sock.sendall(struct.pack("L", len(data)) + data)
            except:
                break

        # 释放资源
        cap.release()
        self.sock.close()

在这个版本的代码中，我们使用 OpenCV 库打开摄像头，并且使用`cv2.VideoCapture(0)`指定摄像头的设备号。在每个循环中，我们使用`cap.read()`读取摄像头的一帧视频，并且可以对视频进行处理，例如裁剪、缩放、调整亮度等等。最后，我们将处理后的视频发送到服务器中。

如果您需要对视频进行处理，可以在注释的部分添加处理代码。另外，您也可以根据您的需求进行优化和修改。