upload

src/kr/co/swh/lecture/network/chat/client/chatclient.py

@@ -0,0 +1,24 @@
+import socket
+import threading
+
+def worker(conn):
+    while True:
+        data = conn.recv(1024)
+        print("chat message " + data.decode())
+    conn.close()
+    
+def run():
+  with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
+    s.connect(('127.0.0.1', 4000))
+    print("클라이언트 소켓정보 : ", s)
+    th = threading.Thread(target=worker, name="[스레드 이름 {}]".format(s), args=(s,))
+    th.start()  # 생성한 스레드를 시작한다
+            
+    while True:
+        line = input()
+        s.send(line.encode())    # 서버가 빈 데이터를 받고 연결을 종료할 수 있도록
+        if not line: break         # 빈 데이터를 먼저 보낸 후 루프를 탈출
+        
+
+if __name__ == '__main__':
+  run()

src/kr/co/swh/lecture/network/chat/server/chatserver.py

@@ -0,0 +1,35 @@
+import socket
+import threading
+import time
+
+connList=[]
+
+def worker(conn):
+    while True:
+        data = conn.recv(1024)  # 변수 msg 은 바이트형이며, 클라이언트로 부터 받은 메세지가 저장된다. recv함수의 매개변수는 바이트 크기
+        if not data: break
+        print(data.decode())
+        
+        for b in connList:
+            b.send(data)      # 메세지를 연결된 클라이언트에게 전달
+    conn.close()
+    
+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(conn), args=(conn,))
+            th.start()  # 생성한 스레드를 시작한다
+
+if __name__ == '__main__':
+  run_server()

src/kr/co/swh/lecture/network/echo/echoclient.py

@@ -6,7 +6,7 @@ def run():
     print("클라이언트 소켓정보 : ", s)
     while True:
         line = input(':')
-        s.sendall(line.encode())    # 서버가 빈 데이터를 받고 연결을 종료할 수 있도록
+        s.send(line.encode())    # 서버가 빈 데이터를 받고 연결을 종료할 수 있도록
         if not line: break         # 빈 데이터를 먼저 보낸 후 루프를 탈출
         data = s.recv(1024)
         print("서버로 부터 전달받은 문자열 : ", data.decode())

src/kr/co/swh/lecture/network/echo/echoserver.py

@@ -15,7 +15,7 @@ def run_server(port=4000):
             if not data: break
             print(type(data))
             print("클라이언트로부터 전송받은 문자열 : ", data.decode())
-            conn.sendall(data)      # 메세지를 연결된 클라이언트에게 전달
+            conn.send(data)      # 메세지를 연결된 클라이언트에게 전달
         conn.close()
 
 if __name__ == '__main__':

src/kr/co/swh/lecture/network/multithread/multithread_client.py

@@ -0,0 +1,15 @@
+import socket
+
+def run():
+  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.sendall(line.encode())    # 서버가 빈 데이터를 받고 연결을 종료할 수 있도록
+        if not line: break         # 빈 데이터를 먼저 보낸 후 루프를 탈출
+        data = s.recv(1024)
+        print("서버로 부터 전달받은 문자열 : ", data.decode())
+
+if __name__ == '__main__':
+  run()

src/kr/co/swh/lecture/network/multithread/multithread_server.py

@@ -0,0 +1,34 @@
+import socket
+import threading
+import time
+
+def worker(conn, addr):
+    print("{} 실행 중 ".format(threading.currentThread().getName()))
+    
+    while True:
+        data = conn.recv(1024)  # 변수 msg 은 바이트형이며, 클라이언트로 부터 받은 메세지가 저장된다. recv함수의 매개변수는 바이트 크기
+        if not data: break
+        print(type(data))
+        print("클라이언트로부터 전송받은 문자열 : ", data.decode())
+        conn.sendall(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)
+            
+            th = threading.Thread(target=worker, name="[스레드 이름 {}]".format(addr), args=(conn, addr))
+            th.start()  # 생성한 스레드를 시작한다
+
+if __name__ == '__main__':
+  run_server()