Вещание данных в сеть (сервер) - что читать?

import socket
 
UDP_IP = "127.0.0.1" #Объявляю IP-адрес, на который буду слать данные
UDP_PORT = 5005 #Объявляю порт, на который буду слать данные
MESSAGE = "Hello, World!" #Объявляю строку, которая будет передана
 
print "UDP target IP:", UDP_IP
print "UDP target port:", UDP_PORT
print "message:", MESSAGE
 
sock = socket.socket(socket.AF_INET, # Internet
                     socket.SOCK_DGRAM) # UDP
sock.sendto(MESSAGE, (UDP_IP, UDP_PORT))

import socket
 
UDP_IP = "192.168.1.128" 
UDP_PORT = 5005 
 
sock = socket.socket(socket.AF_INET,
                     socket.SOCK_DGRAM)
 
#Здесь - мой зацикленный код чтения данных и запись в переменную dataMatrix
 
MESSAGE = dataMatrix
 
sock.sendto(MESSAGE, (UDP_IP, UDP_PORT))

from threading import Thread
from rex.qt.QtCore import QObject, pyqtSignal
import socket
# noinspection PyUnresolvedReferences
 
PORT = 11412
 
 
class SignalSender(QObject):
    """ Simple class for sending signals.
    """
    # finished = pyqtSignal()  # список компонентов в виде чисел
    gid_request = pyqtSignal(unicode)
 
    def __init__(self):
        super(SignalSender, self).__init__()
 
 
class ServerThread(Thread):
    sig = SignalSender()
 
    def __init__(self):
        # self.q = Queue()
        self.host = ''
        self.backlog = 1  # 5
        self.msg_size = 1024
        self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        super(ServerThread, self).__init__(target=self.target_func, args=())
        # self._stop = Event()
        self.daemon = True  # thread dies with the program
        # self.start()
 
    def start_srv(self):
        try:
            self.socket.bind((self.host, PORT))
            self.socket.listen(self.backlog)
            self.start()
            return 1
        except socket.error as e:
            if e[0] == 10048:
                # log.dbg("Port is bisy")
                return 0
            else:
                raise e
 
    def target_func(self):
        while True:
            client, address = self.socket.accept()
            data = client.recv(self.msg_size)
            cmd, arg = data.split('=')
            if cmd == 'gid_path':
                client.send('1 ok, accepted gid path ' + arg)
                self.sig.gid_request.emit(arg.decode('cp1251'))
            # if data:
            #    client.send(data)
            client.close()
 
    def stop(self):
        pass

    import server
    srv = server.ServerThread()
    if srv.start_srv():
        log.dbg("Server started, port " + str(server.PORT))
 
        def on_gid_request(path):
            log.dbg('Accepted path: ' + path)
            main_w.project._prj_model.import_from_gid(path)
        srv.sig.gid_request.connect(on_gid_request)
    else:
        log.dbg("Port {0} is bisy".format(server.PORT))

def try_to_send(gid_data):
    try:
        host = 'localhost'
        size = 1024
        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        s.connect((host, PORT))
        s.send('gid_path=' + gid_data)
        data = s.recv(size)
        print(data)
        s.close()
        return data[0] == '1'
    except socket.error as e:
        if e[0] == 10061:
            return False
        else:
            raise e

import socket
import random
 
IPAD_TO_LISTEN_ON = '192.168.16.160'
PORT_TO_LISTEN_ON = 27948
 
def read_sensors():
    """generates random 10bit binary number between (0 and 1023)"""
    # этот генератор чисел имитирует считывание данных с сенсоров
    # на выходе - строка из 10 бит: '1001010001'
    return '{:010b}'.format(random.randint(0, 1023))
 
s = socket.socket()
 
s.bind((IPAD_TO_LISTEN_ON, PORT_TO_LISTEN_ON))
s.listen(5)
 
while True:
    # ждем соединения, возвращаем данные с "сенсоров" и закрываем соединение
    c, addr = s.accept()
    print 'Got connection from', addr, '. Sending data.'
    c.send(read_sensors())
    c.close()

import socket
 
s = socket.socket()
host = socket.getfqdn()
port = 27948
 
s.connect((host, port))
print(list(map(int, s.recv(1024))))
s.close()