Das deutsche Python-Forum

Code: Alles auswählen

import socketserver

class MyTCPHandler(socketserver.BaseRequestHandler):
     
    def handle(self):
        # self.request is the TCP socket connected to the client
        self.data = self.request.recv(1024).strip()
        print("{}:{} wrote:".format(self.client_address[0],self.client_address[1]))
        print(self.data)
        # just send back the same data, but upper-cased
        #self.request.sendall(self.data.upper())
        
        msg = self.data
        print(msg)
        
        if msg[2] == 0x07:
            print("<- U (STARTDT act)")
            data = bytearray(msg)
            data[2] = 0x0B
            self.request.sendall(data)
            print("-> U (STARTDT con)")
        elif msg[2] == 0x43:                              
            print("<- U (TESTFR act)")
            data = bytearray(msg)
            data[2] = 0x83
            self.request.sendall(data)
            print("-> U (TESTFR con)")
        else:
            print("NIL: {}".fomat(msg))


HOST, PORT = "localhost", 2404

    # Create the server, binding to localhost on port 9999
with socketserver.TCPServer((HOST, PORT), MyTCPHandler) as server:
        # Activate the server; this will keep running until you
        # interrupt the program with Ctrl-C
        server.serve_forever()

Code: Alles auswählen

127.0.0.1:52036 wrote:
b'h\x04\x07\x00\x00\x00'
b'h\x04\x07\x00\x00\x00'
2022-01-25 21:47:13,855 - INFO - <- U (STARTDT act)
2022-01-25 21:47:13,856 - INFO - -> U (STARTDT con)
127.0.0.1:52037 wrote:
b'h\x04\x07\x00\x00\x00'
b'h\x04\x07\x00\x00\x00'
2022-01-25 21:47:18,861 - INFO - <- U (STARTDT act)
2022-01-25 21:47:18,863 - INFO - -> U (STARTDT con)
127.0.0.1:52038 wrote:
b'h\x04\x07\x00\x00\x00'
b'h\x04\x07\x00\x00\x00'
2022-01-25 21:47:23,869 - INFO - <- U (STARTDT act)
2022-01-25 21:47:23,870 - INFO - -> U (STARTDT con)
127.0.0.1:52039 wrote:
b'h\x04\x07\x00\x00\x00'
b'h\x04\x07\x00\x00\x00'
2022-01-25 21:47:28,873 - INFO - <- U (STARTDT act)
2022-01-25 21:47:28,873 - INFO - -> U (STARTDT con)
127.0.0.1:52042 wrote:
b'h\x04\x07\x00\x00\x00'
b'h\x04\x07\x00\x00\x00'
2022-01-25 21:47:33,876 - INFO - <- U (STARTDT act)
2022-01-25 21:47:33,876 - INFO - -> U (STARTDT con)
127.0.0.1:52043 wrote:
b'h\x04\x07\x00\x00\x00'
b'h\x04\x07\x00\x00\x00'
2022-01-25 21:47:38,881 - INFO - <- U (STARTDT act)
2022-01-25 21:47:38,882 - INFO - -> U (STARTDT con)
127.0.0.1:52044 wrote:
b'h\x04\x07\x00\x00\x00'
b'h\x04\x07\x00\x00\x00'
2022-01-25 21:47:43,888 - INFO - <- U (STARTDT act)
2022-01-25 21:47:43,889 - INFO - -> U (STARTDT con)
127.0.0.1:52046 wrote:
b'h\x04\x07\x00\x00\x00'
b'h\x04\x07\x00\x00\x00'

Code: Alles auswählen

        self.data = self.request.recv(1024).strip()

Code: Alles auswählen

import socketserver

class MyTCPHandler(socketserver.BaseRequestHandler):
    """
    The request handler class for our server.

    It is instantiated once per connection to the server, and must
    override the handle() method to implement communication to the
    client.
    """

    def handle(self):
        # self.request is the TCP socket connected to the client
        self.data = self.request.recv(1024).strip()
        print("{} wrote:".format(self.client_address[0]))
        print(self.data)
        # just send back the same data, but upper-cased
        self.request.sendall(self.data.upper())

if __name__ == "__main__":
    HOST, PORT = "localhost", 9999

    # Create the server, binding to localhost on port 9999
    with socketserver.TCPServer((HOST, PORT), MyTCPHandler) as server:
        # Activate the server; this will keep running until you
        # interrupt the program with Ctrl-C
        server.serve_forever()
        

Code: Alles auswählen

pip3 install pynng     
Collecting pynng
  Downloading pynng-0.7.1.tar.gz (3.8 MB)
     |████████████████████████████████| 3.8 MB 3.3 MB/s
  Preparing metadata (setup.py) ... done
Requirement already satisfied: cffi in c:\users\pfanne\appdata\local\programs\python\python310\lib\site-packages (from pynng) (1.15.0)
Requirement already satisfied: sniffio in c:\users\pfanne\appdata\local\programs\python\python310\lib\site-packages (from pynng) (1.2.0)
Requirement already satisfied: pycparser in c:\users\pfanne\appdata\local\programs\python\python310\lib\site-packages (from cffi->pynng) (2.21)
Building wheels for collected packages: pynng
  Building wheel for pynng (setup.py) ... error
  ERROR: Command errored out with exit status 1:
   command: 'C:\Users\Pfanne\AppData\Local\Programs\Python\Python310\python.exe' -u -c 'import io, os, sys, setuptools, tokenize; sys.argv[0] = '"'"'C:\\Users\\Pfanne\\AppData\\Local\\Temp\\pip-install-93bk9dgg\\pynng_fecaf0105997410991c5738fb969c8c7\\setup.py'"'"'; __file__='"'"'C:\\Users\\Pfanne\\AppData\\Local\\Temp\\pip-install-93bk9dgg\\pynng_fecaf0105997410991c5738fb969c8c7\\setup.py'"'"';f = getattr(tokenize, '"'"'open'"'"', open)(__file__) if os.path.exists(__file__) else io.StringIO('"'"'from setuptools import setup; setup()'"'"');code = f.read().replace('"'"'\r\n'"'"', '"'"'\n'"'"');f.close();exec(compile(code, __file__, '"'"'exec'"'"'))' bdist_wheel -d 'C:\Users\Pfanne\AppData\Local\Temp\pip-wheel-tt5nwwdc'
       cwd: C:\Users\Pfanne\AppData\Local\Temp\pip-install-93bk9dgg\pynng_fecaf0105997410991c5738fb969c8c7\
  Complete output (5 lines):
  running bdist_wheel
  running build
  running build_py
  error: [WinError 2] Das System kann die angegebene Datei nicht finden
  building mbedtls with: ['cmake', '-DCMAKE_POSITION_INDEPENDENT_CODE:BOOL=true', '-A', 'x64', '-DENABLE_PROGRAMS=OFF', '-DCMAKE_BUILD_TYPE=Release', '-DCMAKE_INSTALL_PREFIX=../prefix', '..']
  ----------------------------------------
  ERROR: Failed building wheel for pynng
  Running setup.py clean for pynng
Failed to build pynng
Installing collected packages: pynng
    Running setup.py install for pynng ... error
    ERROR: Command errored out with exit status 1:
     command: 'C:\Users\Pfanne\AppData\Local\Programs\Python\Python310\python.exe' -u -c 'import io, os, sys, setuptools, tokenize; sys.argv[0] = '"'"'C:\\Users\\Pfanne\\AppData\\Local\\Temp\\pip-install-93bk9dgg\\pynng_fecaf0105997410991c5738fb969c8c7\\setup.py'"'"'; __file__='"'"'C:\\Users\\Pfanne\\AppData\\Local\\Temp\\pip-install-93bk9dgg\\pynng_fecaf0105997410991c5738fb969c8c7\\setup.py'"'"';f = getattr(tokenize, '"'"'open'"'"', open)(__file__) if os.path.exists(__file__) else io.StringIO('"'"'from setuptools import setup; setup()'"'"');code = f.read().replace('"'"'\r\n'"'"', '"'"'\n'"'"');f.close();exec(compile(code, __file__, '"'"'exec'"'"'))' install --record 'C:\Users\Pfanne\AppData\Local\Temp\pip-record-2d9h1i0l\install-record.txt' --single-version-externally-managed --compile --install-headers 'C:\Users\Pfanne\AppData\Local\Programs\Python\Python310\Include\pynng'
         cwd: C:\Users\Pfanne\AppData\Local\Temp\pip-install-93bk9dgg\pynng_fecaf0105997410991c5738fb969c8c7\
    Complete output (4 lines):
    running install
    running build
    running build_py
    error: [WinError 183] Eine Datei kann nicht erstellt werden, wenn sie bereits vorhanden ist: 'mbedtls/build'
    ----------------------------------------
ERROR: Command errored out with exit status 1: 'C:\Users\Pfanne\AppData\Local\Programs\Python\Python310\python.exe' -u -c 'import io, os, sys, setuptools, tokenize; sys.argv[0] = '"'"'C:\\Users\\Pfanne\\AppData\\Local\\Temp\\pip-install-93bk9dgg\\pynng_fecaf0105997410991c5738fb969c8c7\\setup.py'"'"'; __file__='"'"'C:\\Users\\Pfanne\\AppData\\Local\\Temp\\pip-install-93bk9dgg\\pynng_fecaf0105997410991c5738fb969c8c7\\setup.py'"'"';f = getattr(tokenize, '"'"'open'"'"', open)(__file__) if os.path.exists(__file__) else io.StringIO('"'"'from setuptools import setup; setup()'"'"');code = f.read().replace('"'"'\r\n'"'"', '"'"'\n'"'"');f.close();exec(compile(code, __file__, '"'"'exec'"'"'))' install --record 'C:\Users\Pfanne\AppData\Local\Temp\pip-record-2d9h1i0l\install-record.txt' --single-version-externally-managed --compile --install-headers 'C:\Users\Pfanne\AppData\Local\Programs\Python\Python310\Include\pynng' Check the logs for full command output.

Code: Alles auswählen

class MyTCPHandler(socketserver.BaseRequestHandler):
    def handle(self):
        with self.request.makefile('rwb') as file:
            msg = file.read(length_of_packet)
            print("{}:{} wrote:".format(self.client_address[0],self.client_address[1]))
            print(msg)
            
            if msg[2] == 0x07:
                print("<- U (STARTDT act)")
                data = bytearray(msg)
                data[2] = 0x0B
                file.write(data)
                print("-> U (STARTDT con)")
            elif msg[2] == 0x43:
                print("<- U (TESTFR act)")
                data = bytearray(msg)
                data[2] = 0x83
                file.write(data)
                print("-> U (TESTFR con)")
            else:
                print("NIL: {}".fomat(msg))

Code: Alles auswählen

PS H:\Pfanne-NET\HomeControl\Code\Python\104-CMC-Mapper> pip show pynng
Name: pynng
Version: 0.7.1
Summary: Networking made simply using nng
Home-page: https://github.com/codypiersall/pynng
Author: Cody Piersall
Author-email: cody.piersall@gmail.com
License: MIT
Location: c:\users\pfanne\appdata\local\programs\python\python39\lib\site-packages
Requires: cffi, sniffio
Required-by

Code: Alles auswählen

"""
Request/Reply is used for synchronous communications where each question is responded with a single answer,
for example remote procedure calls (RPCs).
Like Pipeline, it also can perform load-balancing.
This is the only reliable messaging pattern in the suite, as it automatically will retry if a request is not matched with a response.

"""
#import datetime
import pynng
import curio


#print(pynng.version)
#print(curio.__version__)

DATE = "DATE"

address = "ipc:///tmp/reqrep.ipc"


async def node0(sock):
    async def response_eternally():
        while True:
            msg = await sock.arecv_msg()
            content = msg.bytes.decode()
            if DATE == content:
                print("NODE0: RECEIVED DATE REQUEST")
                date = str(datetime.datetime.now())
                await sock.asend(date.encode())

    sock.listen(address)
    return await curio.spawn(response_eternally)


async def node1():
    with pynng.Req0() as sock:
        sock.dial(address)
        print(f"NODE1: SENDING DATE REQUEST")
        await sock.asend(DATE.encode())
        msg = await sock.arecv_msg()
        print(f"NODE1: RECEIVED DATE {msg.bytes.decode()}")


async def main():
    with pynng.Rep0() as rep:
        n0 = await node0(rep)
        await curio.sleep(1)
        await node1()

        await n0.cancel()


if __name__ == "__main__":
    try:
        curio.run(main)
    except KeyboardInterrupt:
        # that's the way the program *should* end
        pass

Code: Alles auswählen

msg = file.read(2)
assert msg[0] == 0x68
msg += file.read(msg[1])

Code: Alles auswählen

[Conversation completeness: Complete, WITH_DATA (63)]

Code: Alles auswählen

[Conversation completeness: Incomplete, DATA (15)]

Code: Alles auswählen

---
<module 'pynng' from 'h:\\Pfanne-NET\\HomeControl\\Code\\Python\\104-CMC-Mapper\\CMC-104_Mapper\\pynng.py'>
---
---
<module 'pynng' from 'h:\\Pfanne-NET\\HomeControl\\Code\\Python\\104-CMC-Mapper\\CMC-104_Mapper\\pynng.py'>
---