update

http_server.py

+from flask import Flask,request
+from time import sleep
+import uuid
+
+app = Flask(__name__)
+@app.route('/',methods = ['POST'])
+# ‘/’ URL is bound with hello_world() function.
+def hello_world():
+    sleep(10)
+    content = request.get_json()
+    print(content)
+    # content = json.loads(content)
+    num1=content["num1"]
+    num2=content["num2"]
+    res=num1+num2
+    print(uuid.uuid4())
+    return {
+        "res": res
+    }
+ 
+# main driver function
+if __name__ == '__main__':
+    app.run(debug=True,host='192.168.88.128',port=8080)
\ No newline at end of file

opcua_client.py

+from opcua import Client
+
+url = "opc.tcp://kali:53530/OPCUA/SimulationServer"
+
+client=Client(url)
+client.connect()
+print("client connected")
+while True:
+    counter=client.get_node("ns=3;i=1001")
+    count=counter.get_value()
+    print(count)
\ No newline at end of file

tcp_client.py

+import socket
+def client_program(op1):
+    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    sock.connect(("192.168.88.128", 53530))
+    print(op1)
+    sock.send(op1)
+    response = b""
+    while True:
+        chunk = sock.recv(4096)
+        if len(chunk) == 0:     # No more data received, quitting
+            break
+        response = response + chunk;
+    return response
+
+
+if __name__ == '__main__':
+    client_program()
\ No newline at end of file

tcp_server.py

+import socket
+import udp_client
+from time import sleep
+
+def server_program():
+    SERVER_HOST = '192.168.88.132'
+    SERVER_PORT = 53530
+    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    server_socket.bind((SERVER_HOST, SERVER_PORT))
+    server_socket.listen(100)
+    print('Listening on port %s ...' % SERVER_PORT)
+
+    while True:
+        # Wait for client connections
+        client_connection, client_address = server_socket.accept()
+        request = client_connection.recv(1024)
+        rec_data=udp_client.udp_client_program(request)
+        print(rec_data)
+        client_connection.sendall(rec_data)
+        client_connection.close()
+    server_socket.close()
+
+
+if __name__ == '__main__':
+    server_program()
\ No newline at end of file

udp_client.py

+import socket
+bufferSize          = 1024
+
+def udp_client_program(data):
+    msgFromClient       = data
+    bytesToSend         = msgFromClient
+    print(bytesToSend)
+    serverAddressPort   = ("127.0.0.1", 20001)
+    # Create a UDP socket at client side
+    UDPClientSocket = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)
+    # Send to server using created UDP socket
+    UDPClientSocket.sendto(bytesToSend, serverAddressPort)
+    msgFromServer = UDPClientSocket.recvfrom(bufferSize)
+    msg = msgFromServer[0]
+    return(msg)
\ No newline at end of file

udp_server.py

+import socket
+import tcp_client
+
+localIP     = "127.0.0.1"
+localPort   = 20001
+bufferSize  = 1024
+
+
+# Create a datagram socket
+UDPServerSocket = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)
+
+# Bind to address and ip
+UDPServerSocket.bind((localIP, localPort))
+print("UDP server up and listening")
+
+# Listen for incoming datagrams
+
+while(True):
+    bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
+    message = bytesAddressPair[0]
+    address = bytesAddressPair[1]
+    clientMsg = message
+    clientIP  = "Client IP Address:{}".format(address)
+    msgFromServer       = tcp_client.client_program(clientMsg)
+    bytesToSend         = msgFromServer
+    # Sending a reply to client
+    UDPServerSocket.sendto(bytesToSend, address)
\ No newline at end of file