Программа для связи между Raspberry Pi

import pyaudio, socket
 
port = 5000
chunk = 256
FORMAT = pyaudio.paInt16
CHANNELS = 1
RATE = 44100
 
p = pyaudio.PyAudio()
stream = p.open(format = FORMAT, channels = CHANNELS, rate = RATE, input = True, output = True, frames_per_buffer = chunk)
 
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # create the socket
server_socket.bind(('', port)) # listen on port 5000
server_socket.listen(5) # queue max 5 connections
client_socket, address = server_socket.accept()
 
print "Your IP address is: ", socket.gethostbyname(socket.gethostname())
print "Server Waiting for client on port ", port
 
while True:
 
    # test string
    #data = bytearray('DEADBEEF'.decode('hex'))
    #client_socket.sendall(data)
   
   try:
      client_socket.sendall(stream.read(chunk))
   except IOError,e:
      if e[1] == pyaudio.paInputOverflowed:
         print e
         x = '\x00'*16*256*2 #value*format*chunk*nb_channels
 
stream.stop_stream()
stream.close()
server_socket.close()
client_socket.close()
p.terminate()

import pyaudio, socket
 
port = 5000
ip = "192.168.1.77"
 
chunk = 512
FORMAT = pyaudio.paInt16
CHANNELS = 1
RATE = 44100
 
p = pyaudio.PyAudio().get_def
stream = p.open(format = FORMAT, channels = CHANNELS, rate = RATE, input = True,output = True, frames_per_buffer = chunk)
 
#Create a socket connection for connecting to the server:
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect((ip, port))
 
while True:
 
   #Recieve data from the server:
   data = client_socket.recv(1024)
   stream.write(data,chunk)
   #print data
   
   
socket.close()

import socket, select
 
 
class ChatServer:
    def __init__(self):
 
        self.CONNECTION_LIST = []
        self.chat_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.chat_server_socket.bind(("192.168.1.77", 5000))
        self.chat_server_socket.listen(5)
 
        self.CONNECTION_LIST.append(self.chat_server_socket)
 
        print "Server Started!"
 
    def broadcast(self, sock, data):
        for current_socket in self.CONNECTION_LIST:
            if current_socket != self.chat_server_socket and current_socket != sock:
                try:
                    current_socket.send(data)
                except:
                    pass
 
    def run(self):
        while True:
            rlist, wlist, xlist = select.select(self.CONNECTION_LIST, [], [])
 
            for current_socket in rlist:
                if current_socket is self.chat_server_socket:
                    (new_socket, address) = self.chat_server_socket.accept()
                    self.CONNECTION_LIST.append(new_socket)
                    print "%s connected to the server" % str(address)
                else:
                    try:
                        data = current_socket.recv(1024)
                        self.broadcast(current_socket, data)
                    except socket.error:
                        print "%s left the server" % str(address)
                        current_socket.close()
                        self.CONNECTION_LIST.remove(current_socket)
 
 
if __name__ == "__main__":
    ChatServer().run()

import socket
import pyaudio
import wave
import thread
 
# record
CHUNK = 1024 # 512
FORMAT = pyaudio.paInt16
CHANNELS = 1
RATE = 20000
 
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(("192.168.1.77", 5000))
 
p = pyaudio.PyAudio()
 
receive_stream = p.open(format=FORMAT, channels=CHANNELS, rate=RATE, output=True, frames_per_buffer=CHUNK)
send_stream = p.open(format=FORMAT, channels=CHANNELS, rate=RATE, input=True, frames_per_buffer=CHUNK)
 
print("Voice chat running")
 
def receive_data():
    while True:
        try:
            data = s.recv(1024)
            receive_stream.write(data)
        except:
            pass
 
 
def send_data():
    while True:
        try:
            data = send_stream.read(CHUNK)
            s.sendall(data)
        except:
            pass
 
thread.start_new_thread(receive_data, ())
thread.start_new_thread(send_data, ())
 
while True:
    pass