Das deutsche Python-Forum

Code: Alles auswählen

import socket
import threading
import queue

# read actual configaration of device
# HOST = '192.168.2.100'
HOST = '127.0.0.1'
PORT = 23
TRX_VALUE_FILENAME = "_trx_value"

def client_read_thread(client_socket, queue):
    while True:
        queue.put(client_socket.recv(4096))

def client_write_thread(client_socket, queue):
    while True:
        client_socket.sendall(queue.get())

def start_ethernet_client(host, port):
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    client_socket.connect((host, port))
    read_queue = queue.Queue()
    write_queue = queue.Queue()
    threading.Thread(target=client_read_thread, args=(client_socket, read_queue), daemon=True).start()
    threading.Thread(target=client_write_thread, args=(client_socket, write_queue), daemon=True).start()
    return read_queue, write_queue

def main():
    read_queue, write_queue = start_ethernet_client(HOST, PORT)
    with open("_ask_tokens") as file:
        ask_tokens = list(file)
    with open(TRX_VALUE_FILENAME, "w") as output:
        for token in ask_tokens:
            lines = token.split()
            text = f"{int(lines[0]):04x}"
            if len(lines) > 1:
                text += lines[1]
            write_queue.put(text.encode())
            try:
                data = queue.get(timeout=5)
            except queue.Empty:
                print("timeout")
            else:
                out = "".join(f"{char:02x}" for char in data)
                print("client recceived ", out)
                output.write(out + "\n")

if __name__ == "__main__":
    main()

Code: Alles auswählen

import socket

# read actual configaration of device
# HOST = '192.168.2.100'
HOST = '127.0.0.1'
PORT = 23
TRX_VALUE_FILENAME = "_trx_value"

def main():
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    client_socket.connect((host, port))
    client_socket.set_timeout(5)
    with open("_ask_tokens") as file:
        ask_tokens = list(file)
    with open(TRX_VALUE_FILENAME, "w") as output:
        for token in ask_tokens:
            lines = token.split()
            text = f"{int(lines[0]):04x}"
            if len(lines) > 1:
                text += lines[1]
            client_socket.sendall(text.encode())
            try:
                data = client_socket.recv(4096)
            except socket.timeout:
                print("timeout")
            else:
                out = "".join(f"{char:02x}" for char in data)
                print("client recceived ", out)
                output.write(out + "\n")

if __name__ == "__main__":
    main()

Code: Alles auswählen

import socket

# read actual configaration of device
# HOST = '192.168.2.100'
HOST = '127.0.0.1'
PORT = 23
TRX_VALUE_FILENAME = "_trx_value"

def main():
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    client_socket.connect((host, port))
    client_socket.set_timeout(5)
    socketfile = client_socket.makefile('rwb')
    with open("_ask_tokens") as file:
        ask_tokens = list(file)
    with open(TRX_VALUE_FILENAME, "w") as output:
        for token in ask_tokens:
            lines = token.split()
            text = f"{int(lines[0]):04x}"
            if len(lines) > 1:
                text += lines[1]
            socketfile.write(text.encode())
            try:
                data = socketfile.readline()
            except socket.timeout:
                print("timeout")
            else:
                out = "".join(f"{char:02x}" for char in data)
                print("client recceived ", out)
                output.write(out + "\n")

if __name__ == "__main__":
    main()