update

asyncua_server.py

@@ -5,7 +5,7 @@ import socket
 import threading
 from time import sleep
 
-localIP = "2.2.2.7"
+localIP = "2.2.2.5"
 localPort = 20002
 bufferSize = 1024
 UDPServerSocket = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)
@@ -63,7 +63,7 @@ asr = asyncua_server()
 
 def hash_receive():
     prev_hash = 0
-    sleep(5)
+    sleep(1)
     while (True):
         bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
         message = bytesAddressPair[0]
@@ -79,4 +79,4 @@ def hash_receive():
 def st():
     t1=threading.Thread(target=hash_receive)
     t1.start()
-    asyncio.run(asr.start_server("opc.tcp://2.2.2.7:53531/myopc/free","http://klopc.com"))
+    asyncio.run(asr.start_server("opc.tcp://2.2.2.5:53531/myopc/free","http://klopc.com"))

opcua_receiver.py

@@ -5,7 +5,7 @@ from asyncua_server import st
 import asyncio
 import threading
 
-localIP = "2.2.2.7"
+localIP = "2.2.2.5"
 
 localPort = 20001
 
@@ -26,13 +26,13 @@ UDPServerSocket.bind((localIP, localPort))
 print("UDP server up and listening")
 t1=threading.Thread(target=st,args=())
 t1.start()
-sleep(1)
+sleep(30)
 print("here")
 opua=opcua_pack()
-sock = opua.connect("opc.tcp://2.2.2.7:53531/myopc/free")
+sock = opua.connect("opc.tcp://2.2.2.5:53531/myopc/free")
 
-while (True):
-    bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
-    message = bytesAddressPair[0]
-    datatype,value,ns,nodeid = message.decode().split("&")
-    opua.write_opcua_value(sock,ns,nodeid, value,datatype)
+# while (True):
+#     bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
+#     message = bytesAddressPair[0]
+#     datatype,value,ns,nodeid = message.decode().split("&")
+#     opua.write_opcua_value(sock,ns,nodeid, value,datatype)

opcua_subscriber/opcua_subscribe.py

@@ -141,7 +141,7 @@ class opcua_pack():
         DiscoveryProfileUri = binascii.unhexlify("ffffffff")
         ArraySize = 0
         ServerUri= binascii.unhexlify("ffffffff")
-        EndpointUrl= "opc.tcp://2.2.2.7:53531/myopc/free"
+        EndpointUrl= "opc.tcp://2.2.2.5:53531/myopc/free"
         EndpointUrllen= len(EndpointUrl.encode()).to_bytes(4,byteorder="little")
         SessionName= "Pure Python Client Session1"
         SessionNamelen=len(SessionName.encode()).to_bytes(4,byteorder="little")
@@ -426,7 +426,7 @@ class opcua_pack():
         return session
 
     def connect(self,address):
-        server_address = ('2.2.2.7', 53531)
+        server_address = ('2.2.2.5', 53531)
         sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
         sock.connect(server_address)
         message = self.helf(address)