sock.py 542 B

1234567891011121314151617
  1. import socket
  2. import threading
  3. import json
  4. class Sock(threading.Thread):
  5. def __init__(self):
  6. super(Sock, self).__init__()
  7. self.running = False
  8. def run(self):
  9. self.INFOBEAMER_ADDR = ('127.0.0.1', 4444)
  10. self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
  11. self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
  12. self.running = True
  13. def send(self,obj):
  14. data = str.encode("eba/data:%s\n" % json.dumps(obj))
  15. self.sock.sendto(data, self.INFOBEAMER_ADDR)