파이썬 thread 소켓 프로그래밍

이전 블로그는 한번에 하나의 메세지만 전달이 가능했다.

이번에는 thread를 이용해 지속적인 연결로 메세지를 전달한다.

[server]

import socket

from _thread import *

#thread를 생성하는 threaded함수 구현

def threaded(client_socket,addr):

print('Connected by :',addr[0],':',addr[1]) #addr[0]은 ip,addr[1]은 port

while True:

try:

data = client_socket.recv(1024) #client가 보낸 메세지를 받아 data에 저장

if not data:

print('Disconnected by '+addr[0],':',addr[1])

break

#받은 데이터 출력

print('Received from '+addr[0],':',addr[1],data.decode())

#client에 받은 데이터 재전송

client_socket.send(data)

#conncetcionError의 서브클래스로, 연결 시도가 상대방에 의해 중단될 때 발생.

#내장예외에 대한 설명 : https://python.flowdas.com/library/exceptions.html

except ConnectionResetError as e:

print('Disconnected by '+addr[0],':',addr[1])

break

#client와 연결 끊음

client_socket.close()

HOST='127.0.0.1'

PORT = 9999

#socket생성 후 listen상태 만들기

server_socket = socket.socket(socket.AF_INET,socket.SOCK_STREAM)

server_socket.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)

server_socket.bind((HOST,PORT))

server_socket.listen()

print('server start')

while True:

print('wait')

client_socket,addr = server_socket.accept()

start_new_thread(threaded(client_socket,addr))

server_socket.close()

[client]

import socket

HOST='127.0.0.1'

PORT=9999

#socket 생성

client_socket = socket.socket(socket.AF_INET,socket.SOCK_STREAM)

client_socket.connect((HOST,PORT))

while True:

message = input('Enter Message: ')

if message == 'quit':

break

#메세지 전송

client_socket.send(message.encode())

#서버로 부터 메세지 받기

data= client_socket.recv(1024)

print('received from the server:',repr(data.decode()))

client_socket.close()

[실행]

먼저 서버 쪽을 실행한다.

서버는 9999포트를 listening상태로 대기한다.

client 쪽을 실행시켜 메세지를 보내면

서버 쪽에서 받은 메세지를 출력하고 받은 메세지를 client쪽으로 전달한다.

client는 메세지를 계속해서 보낼 수 있다.