🐍 Python * socket 연결 + 문자열 전송

 

SERVER

1. 먼저 통신할 소켓의 구조를 생성합니다.

 class SocketInfo() :
    HOST='' 
    #HOST에 아무것도 지정하지 않으면 가능한 모든 인터페이스를 의미한다.
    
    PORT=1024
    #두 디바이스가 만날 지점을 정해준다고 생각하면 편할 것 같다.
    #포트번호는 아무거나 해도 상관없으나 이미 정해져 있는 포트번호는 사용하면 안된다.
    # HTTP, FTP 등의 지정 포트번호 사용 불가
    
    BUFSIZE=1024
    #소켓이 한번에 받아올 수 있는 용량이라고 생각하면 되겠다.
    #최대 1024 byte까지만 전달 받겠다.

    ADDR=(HOST, PORT)
    #후에 server에서 bind 함수를 사용할 때 bind 함수의 인자 값이 ( IP, PORT ) 이기 때문에
    #그냥 하나로 합쳐준 것이다.

파일로 따로 분리하지 않으시고 한 파일에 같이 넣으셔도 됩니다.

저는 따로 놔두는게 보기 편해서 분리했어요.

2. Server의 소켓을 생성합니다.

# -*- coding:utf-8 -*-
#한글을 사용할 경우 에러가 날 수 있음으로 인코딩을 시켜주는 명령이다.
#한글주석을 다는데도 없으면 에러가 난다.


from socket import *
#소켓을 사용하기 위하여 소켓 모듈을 import한다.
from data_file import *
#소켓의 구조정보를 담아놓은 파일을 import한다.

ssock=socket(AF_INET, SOCK_STREAM)
ssock.bind(SocketInfo.ADDR)
ssock.listen(5)
#서버 소켓이 클라이언트의 접속을 기다린다. (listen socket 상태)
csock=None

while True :
    if csock is None :
    #연결된 client 소켓이 없으면 실행한다.
        print "waiting for connection..."
        csock, addr_info = ssock.accept()
        #client에서 연결을 시도하면 ssock.accpet() 실행 후 반환 되는 값을 각각 csock, addr_info에 저장한다.
        print "got connection from", addr_info

    else:
    #연결된 client 소켓이 있으면 실행한다.
        print "waiting for response..."
        commend=csock.recv(SocketInfo.BUFSIZE)
        #client에서 응답을 돌려주면 BUFSIZE만큼 받아드려 commend에 저장한다.
        print "accept >> "+commend

        if commend=="hi" :
            csock.send("Hello")

        elif commend=="exit" :
            csock.send("bye")
            csock.close()
            #연결되어 있는 client csock을 닫는다. ( server와 client의 연결이 끊어진다. )
            print "close csock"

        else:
            csock.send("bye")
            csock.close()
            #연결되어 있는 client csock을 닫는다. ( server와 client의 연결이 끊어진다. )
            print "close csock"

 

 

 

CLIENT

Client 소켓을 생성합니다.

 # -*- coding:utf-8 -*-

from socket import  *
from sys import exit
#프로그램을 종료하는 exit()함수의 사용을 위해 sys 모듈의 exit를 import한다.
from data_file import SocketInfo
#소켓의 구조정보를 담아놓은 파일을 import한다.

class SocketInfo(SocketInfo) :
    HOST='127.0.0.1'

csock=socket(AF_INET, SOCK_STREAM)
#IPv4, TCP 구조를 가진 소켓을 생성한다.
csock.connect(SocketInfo.ADDR)
#ADDR에 해당하는 IP와 PORT를 가진 소켓에 연결을 시도한다. ( server와 client가 연결되었다. )

while True:
    try:
    #예외처리, 에러가 나지 않을 경우 실행한다.
        commend=raw_input(" >> ")
        #commend 변수에 문자열을 입력받아 저장한다.
        csock.send(commend)
        #csock을 이용하여 commend문자열을 전송한다.
        print "waiting for response..."
        commend=csock.recv(SocketInfo.BUFSIZE)
        #commend에 csock을 이용하여 server로 돌려받은 응답을 BUFSIZE 만큼 받아서 저장한다.
        print commend

    except Exception as e :
    #예외처리, 에러가 날 경우 실행한다.
        print "%s:%s" %(e, SocketInfo.ADDR)
        csock.close()
        #연결되어 있는 client csock을 닫는다. ( server와 client의 연결이 끊어진다. )
        exit()
        #프로세스를 종료한다.

    print "connect is success"

 

 

 

Let's Do it

Server와 Client를 실행하고, Client에 hi를 입력해봅니다.