Client.py :

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
import socket
import struct
import ssl


class innerClassClient:

    def __init__(self):
        self.data=0

    xKoordinat = 0
    yKoordinat = 0

    islemDurumu = 0

    def testClient(self):
        host = '127.0.0.1'
        port = 8080
	
        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        s.connect((host, port))

        # context = ssl.create_default_context()
        # s = context.wrap_socket(socket.socket(socket.AF_INET),server_hostname=host)
        # s.connect((host,port))
        # s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
        # connect to server on local computer
        # s.connect((host,port))
        # s = ssl.wrap_socket(s, keyfile=None, certfile=None, server_side=False, cert_reqs=ssl.CERT_NONE, ssl_version=ssl.PROTOCOL_SSLv23)

        while True:

            data = s.recv(13)
            data = data[:13]
            showData = struct.unpack('<hh?ii', data)


            innerClassClient.islemDurumu=showData[2]
            innerClassClient.xKoordinat=showData[3]
            innerClassClient.yKoordinat=showData[4]
        # s.close()



Server.py:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
import socket
# import thread module
# from _thread import *
import threading

print_lock = threading.Lock()


class innerClassServer:
    def threaded(self,c):
        while True:
            data = b'\x00\xFF\x00\xFF\x00\x00\xE8\x1A\x03\x00\xE8\xFA\x03'
            # data=b'\x00\x01\x00\x02\x00\x00\x00\x03'
            # 0xFF0xFF0x00 0xE8 0x03 0xE8 0x03
            # 0xFF0xFF0x000xE80x030xE80x03
            c.send(data)
           
        c.close()

    def Main(self):
        host = ""
        innerClassintance=innerClassServer()
        port = 8080
        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        s.bind((host, port))
        print("socket binded to post", port)
        s.listen(5)
        print("socket is listening")

        while True:
            c, addr = s.accept()

            print_lock.acquire()
            print('Connected to :', addr[0], ':', addr[1])

            thr = threading.Thread(target=innerClassintance.threaded, args=(c,))
            thr.start()

        s.close()



Koordinat.py:

import multiprocessing
import sys
import teknoClient
import teknoServer
import threading
import testThread
from multiprocessing import Pool
import time


class innerKoordinatClass:
    durum=0
    xKoordinat=0
    yKoordinat=0

    def __init__(self):
        teknoClientinstance = teknoClient.innerClassClient()
        teknoServerinstance = teknoServer.innerClassServer()

        t1 = threading.Thread(target=teknoServerinstance.Main, args=())

        t1.start()

        t2 = threading.Thread(target=teknoClientinstance.testClient, args=())

    
        t2.start()

        time.sleep(1)
        print("Durum:")
        print(teknoClientinstance.islemDurumu)

        print("X Koordinat:")
        print(teknoClientinstance.xKoordinat)

        print("Y Koordinat:")
        print(teknoClientinstance.yKoordinat)

        innerKoordinatClass.durum = teknoClientinstance.islemDurumu

        innerKoordinatClass.xKoordinat = teknoClientinstance.xKoordinat

        innerKoordinatClass.yKoordinat = teknoClientinstance.yKoordinat

Yorumlar

  • YORUM YOK