| 1234567891011121314151617 |
- import socket
- import threading
- import json
- class Sock(threading.Thread):
- def __init__(self):
- super(Sock, self).__init__()
- self.running = False
- def run(self):
- self.INFOBEAMER_ADDR = ('127.0.0.1', 4444)
- self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
- self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
- self.running = True
- def send(self,obj):
- data = str.encode("eba/data:%s\n" % json.dumps(obj))
- self.sock.sendto(data, self.INFOBEAMER_ADDR)
|