updated udp and zhiwu.

Author: junhuanchen

12.network/udp_client.py

@@ -0,0 +1,47 @@
+import wifi
+wifi.try_connect()
+
+from XAsyncSockets import XAsyncSocketsPool, XAsyncUDPDatagram
+from   _thread  import start_new_thread
+
+class NetServer:
+    Pool = None
+
+    def __init__(self, Server = ('0.0.0.0', 32)):
+        if NetServer.Pool is None:
+            NetServer.Pool = XAsyncSocketsPool()
+            start_new_thread(NetServer.run_forever, ())
+
+        self.UDPDatagram = XAsyncUDPDatagram.Create(NetServer.Pool, Server, 256)
+        self.UDPDatagram.OnDataRecv = NetServer._onUDPDatagramDataRecv
+        self.UDPDatagram.OnFailsToSend = NetServer._onUDPDatagramFailsToSend
+        print("LocalAddr : %s:%s" % self.UDPDatagram.LocalAddr)
+
+    def exit(self):
+        self.UDPDatagram.Close()
+
+    def unit_test(self):
+        import time
+        Remote = ('10.10.10.237', 9954)
+        data = bytearray(u"1231")
+        while True:
+            self.UDPDatagram.AsyncSendDatagram(datagram=data, remoteAddr=Remote)
+            print(data)
+            time.sleep(2)
+
+    def run_forever():
+        try:
+            NetServer.Pool.AsyncWaitEvents()
+        finally:
+            NetServer.Pool.StopWaitEvents()
+
+    def _onUDPDatagramDataRecv(xAsyncUDPDatagram, remoteAddr, datagram):
+        print('On UDP Datagram Data Recv (%s:%s) :' % remoteAddr, bytes(datagram), xAsyncUDPDatagram)
+
+    def _onUDPDatagramFailsToSend(xAsyncUDPDatagram, datagram, remoteAddr):
+        print('On UDP Datagram Fails To Send', bytes(datagram), remoteAddr, xAsyncUDPDatagram)
+
+if __name__ == '__main__':
+    client = NetServer()
+    client.unit_test()
+    client.exit()

12.network/zhiwu.py

@@ -58,13 +58,13 @@ def parse(self, pack):
         res = self.core(pack)
         if (pack[0] == TYPE_COLLECT):
             # return [TYPE_COLLECT, res[1:ord(res[0]) + 1], res[ord(res[0]) + 2:]]
-            src = 1+ord(res[0])
+            src = 1+res[0]
             dt = 1 + src
-            return [TYPE_COLLECT, res[1:src], res[dt:dt+ord(res[src])]]
+            return [TYPE_COLLECT, res[1:src], res[dt:dt+res[src]]]
         elif (pack[0] == TYPE_COMMAND):
-            result = [TYPE_COMMAND, res[1:ord(res[0]) + 1]]
+            result = [TYPE_COMMAND, res[1:res[0] + 1]]
             # print(result)
-            if (result[1] == 'TimeSysn'):
+            if (result[1] == b'TimeSysn'):
                 # print(decode_parse(self.de))
                 set_time(decode_parse(self.de)[0])
             return result
@@ -83,10 +83,14 @@ def parse(self, pack):
     print(B)
 
     Pack = A.command()
+    Data = B.parse(bytearray(Pack))
     print(B.parse(bytearray(Pack)))
     print(A)
     print(B)
 
+    print(Data[1].decode('iso-8859-1'))
+    print(Data[1].split(b' '))
+
     Pack = A.command('TimeSysn')
     print(B.parse(bytearray(Pack)))
     print(A)