...

src/kr/co/swh/lecture/python/pyqt5/drawing/lineDraw3.py

@@ -0,0 +1,68 @@
+from PyQt5.QtWidgets import QMainWindow, QApplication, QDesktopWidget
+from PyQt5.QtCore import Qt
+from PyQt5.QtWidgets import *
+from PyQt5.QtGui import QPainter, QBrush, QPen
+import sys
+import threading
+import time
+
+class Main(QMainWindow):
+    
+    def __init__(self):
+        super().__init__()
+
+        self.setMouseTracking(True)
+
+        self.setWindowTitle('mouse')
+        self.resize(900, 600)
+        self.xylist=[]
+        self.clicked = False
+        
+        msg = "함수형 스레드 {}".format(1)
+        th = threading.Thread(target=self.worker, name="[스레드 이름 {}]".format(1), args=(msg,))
+        th.start()  # 생성한 스레드를 시작한다
+        
+        self.show()
+
+    def mousePressEvent(self, e):  # e ; QMouseEvent
+        print('BUTTON Press')
+        if e.buttons() & Qt.LeftButton:
+            self.xylist.append(list())
+            self.clicked = True
+
+    def mouseReleaseEvent(self, e):  # e ; QMouseEvent
+        print('BUTTON RELEASE')
+        self.clicked = False
+#         self.mouseButtonKind(e.buttons())
+        
+    def mouseMoveEvent(self, e):  # e ; QMouseEvent
+        print('(%d %d)' % (e.x(), e.y()))
+        if self.clicked:
+            self.xylist[-1].append((e.x(), e.y()))
+            self.repaint()  # self.update()와 결과 동일
+
+    def paintEvent(self, event):
+#                 q.begin(self)
+        if len(self.xylist)> 0:
+            q = QPainter(self)
+            for b in self.xylist:
+                for c in range(len(b)-1):
+                    q.drawLine(b[c][0], b[c][1], b[c+1][0], b[c+1][1])
+                    
+    def worker(self, msg):
+        with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
+            s.connect(('127.0.0.1', 4000))
+            print("클라이언트 소켓정보 : ", s)
+            while True:
+                line = input(':')
+                s.send(line.encode())    # 서버가 빈 데이터를 받고 연결을 종료할 수 있도록
+                if not line: break         # 빈 데이터를 먼저 보낸 후 루프를 탈출
+                data = s.recv(1024)
+                print("서버로 부터 전달받은 문자열 : ", data.decode())
+                self.repaint()
+
+
+#                 q.end()
+App = QApplication(sys.argv)
+window = Main()
+sys.exit(App.exec())   

src/kr/co/swh/lecture/python/pyqt5/drawing/lineDraw4.py

@@ -0,0 +1,77 @@
+from PyQt5.QtWidgets import QMainWindow, QApplication, QDesktopWidget
+from PyQt5.QtCore import Qt
+from PyQt5.QtWidgets import *
+from PyQt5.QtGui import QPainter, QBrush, QPen
+import sys
+import threading
+import time
+import socket
+
+class Main(QMainWindow):
+    
+    def __init__(self):
+        super().__init__()
+
+        self.setMouseTracking(True)
+
+        self.setWindowTitle('mouse')
+        self.resize(900, 600)
+        self.xylist=[]
+        self.clicked = False
+        
+        self.client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+        self.client_socket.connect(('127.0.0.1', 4000))
+        
+        msg = "함수형 스레드 {}".format(1)
+        th = threading.Thread(target=self.worker, name="[스레드 이름 {}]".format(1), args=(msg,))
+        th.start()  # 생성한 스레드를 시작한다
+        
+        
+        self.show()
+
+    def mousePressEvent(self, e):  # e ; QMouseEvent
+        if e.buttons() & Qt.LeftButton:
+            xy = "%d_%d_%d" % (e.x(), e.y(), 0)
+            self.client_socket.send(xy.encode())
+
+    def mouseReleaseEvent(self, e):  # e ; QMouseEvent
+        xy = "%d_%d_%d" % (e.x(), e.y(), 1)
+        self.client_socket.send(xy.encode())
+        
+    def mouseMoveEvent(self, e):  # e ; QMouseEvent
+#         print('(%d %d)' % (e.x(), e.y()))
+        xy = "%d_%d_%d" % (e.x(), e.y(), 2)
+        self.client_socket.send(xy.encode())
+#         if self.clicked:
+#             self.xylist[-1].append((e.x(), e.y()))
+#             self.repaint()  # self.update()와 결과 동일
+
+    def paintEvent(self, event):
+#                 q.begin(self)
+        if len(self.xylist)> 0:
+            q = QPainter(self)
+            for b in self.xylist:
+                for c in range(len(b)-1):
+                    q.drawLine(b[c][0], b[c][1], b[c+1][0], b[c+1][1])
+                    
+    def worker(self, msg):
+        while True:
+            data = self.client_socket.recv(1024)
+#             print("서버로 부터 전달받은 문자열 : ", data.decode())
+            xy = data.decode().split("_")
+            div = int(xy[2])
+            if div is 0:
+                self.xylist.append(list())
+                self.clicked = True
+            elif div is 1:
+                self.clicked = False
+            else:
+                if self.clicked:
+                    self.xylist[-1].append((int(xy[0]), int(xy[1])))
+                    self.repaint()  # self.update()와 결과 동일
+
+
+#                 q.end()
+App = QApplication(sys.argv)
+window = Main()
+sys.exit(App.exec())   

src/kr/co/swh/lecture/python/pyqt5/drawing/multithread_server.py

@@ -0,0 +1,34 @@
+import socket
+import threading
+import time
+
+connList = []
+def worker(conn, addr):
+    print("{} 실행 중 ".format(threading.currentThread().getName()))
+    
+    while True:
+        data = conn.recv(1024)  # 변수 msg 은 바이트형이며, 클라이언트로 부터 받은 메세지가 저장된다. recv함수의 매개변수는 바이트 크기
+        if not data: break
+        for c in connList:
+            c.send(data)      # 메세지를 연결된 클라이언트에게 전달
+    conn.close()
+    print("{} 종료".format(threading.currentThread().getName()))
+    
+def run_server(port=4000):
+    host = ''
+    # socket.AF_INET 은 IP4v 주소체계(socket.AF_INET6 은 IP6v), socket.SOCK_STREAM은 소켓의 타입
+    # socket.AF_INET와 socket.SOCK_STREAM은 디폴트 값이므로 socket.socket() 로 코드를 작성해도 된다.
+    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
+        s.bind((host, port))
+        s.listen()
+        
+        while True: 
+            conn, addr = s.accept()     # accept함수의 결과는 튜플형이며, conn은 서버 소켓에 대한 정보, addr은 클라이언트의 정보
+            print("서버 소켓정보 : ", conn)
+            print("연결된 클라이언트 정보 : ", addr)
+            connList.append(conn)
+            th = threading.Thread(target=worker, name="[스레드 이름 {}]".format(addr), args=(conn, addr))
+            th.start()  # 생성한 스레드를 시작한다
+
+if __name__ == '__main__':
+  run_server()