Copyright © Dipl.-Ing. Johannes Hofer 2022
Die KI-SPS
Die Möglichkeit einer Programmierung für eine SPS, um diese am Geschehen der künstlichen Intelligenz zu beteiligen
Das Listing zum Pi:
# socket test for raspi
import socket
import threading
import sys
import time
HOST_CLIENT = "192.168.8.106"
PORT_RCV = 3000 # port used by receive
PORT_SEND = 2000 # port used by send
FORMAT = 'utf-8'
# client to receive and send
def RCV_SEND():
try:
_rcv = None
_send = None
# socket receive messages
_rcv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
_rcv.settimeout(30)
_rcv.connect((HOST_CLIENT, PORT_RCV))
print("Socket RCV is connected")
# socket send answer
_send = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
_send.settimeout(30)
_send.connect((HOST_CLIENT, PORT_SEND))
print("Socket SEND is connected")
connected = True
while connected:
data = _rcv.recv(1024).decode(FORMAT)
l = len(data)
s = str(l)
print(f"Len: " + s)
# parseData
print(f"Message [RCV]: {data}")
# return from parseData
s = "[{" + "SD:Raspi RCV -> ok" + "}]"
_send.send(s.encode(FORMAT))
print("[SEND]: " + s)
except:
print("Exception in RCV_SEND ",sys.exc_info()[0])
if(_rcv != None):
_rcv.close()
if(_send != None):
_send.close()
print("Close sockets")
return;
# main
def main():
while(True):
thread_RCV_SEND = threading.Thread(target = RCV_SEND)
thread_RCV_SEND.start()
print("Start RCV and SEND Thread")
while(thread_RCV_SEND.is_alive()):
...
print("Inteface network is disconnect ... wait")
time.sleep(2)
print("try again")
main()
print("Program out")
