sock.py 554 B

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