Kategori : Network
Python TCP Client-Server
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