Python의 소켓 모듈에 대한 자세한 설명
- 巴扎黑원래의
- 2017-08-21 14:53:173675검색
소켓(Socket)의 원래 의미는 영어로 "구멍" 또는 "소켓"입니다. BSD UNIX의 프로세스 통신 메커니즘으로 일반적으로 "소켓"이라고도 하며 IP 주소와 포트를 설명하는 데 사용됩니다. 통신 체인의 핸들이며 서로 다른 가상 머신 또는 서로 다른 컴퓨터 간의 통신을 구현하는 데 사용할 수 있습니다. .
네트워크의 두 프로그램은 양방향 통신 연결을 통해 데이터를 교환합니다. 이 연결의 한쪽 끝을 소켓이라고 합니다.
네트워크 통신 연결을 설정하려면 최소한 한 쌍의 포트 번호(소켓)가 필요합니다. 소켓은 본질적으로 TCP/IP를 캡슐화하는 프로그래밍 인터페이스(API)입니다. TCP/IP는 프로그래머가 네트워크 개발에 사용할 수 있는 인터페이스도 제공합니다. HTTP는 캡슐화하거나 표시하는 방법을 제공하는 자동차입니다. 데이터 특정 형식, 소켓은 네트워크 통신 기능을 제공하는 엔진입니다.
파이썬의 소켓에 대해 이야기해 봅시다.
1.socket 모듈
소켓을 생성하려면 소켓.socket() 함수를 사용하세요. 구문은 다음과 같습니다.
socket.socket(socket_family,socket_type,protocol=0)
socket_family는 다음 매개 변수일 수 있습니다.
socket.AF_INET IPv4(기본값)
socket.AF_INET6 IPv6
socket. AF_UNIX는 단일 Unix 시스템 프로세스 간 통신에만 사용됩니다.
socket_type은 다음 매개변수일 수 있습니다.
socket.SOCK_STREAM 스트리밍 소켓, TCP용(기본값)
socket.SOCK_DGRAM 데이터그램 소켓, UDP용
socket.SOCK_RAW 원시 소켓 , 일반 소켓은 ICMP 및 IGMP와 같은 네트워크 메시지를 처리할 수 없지만 SOCK_RAW는 처리할 수 있습니다. 둘째, SOCK_RAW는 또한 원시 소켓을 사용하여 IP_HDRINCL 소켓 옵션 IP 헤더를 통해 특수 IPv4 메시지도 처리할 수 있습니다.
socket.SOCK_RDM은 신뢰할 수 있는 UDP 형식으로, 데이터그램 전달은 보장하지만 순서는 보장하지 않습니다. SOCK_RAM은 원래 프로토콜에 대한 낮은 수준의 액세스를 제공하는 데 사용되며 ICMP 메시지 전송과 같은 특정 특수 작업을 수행해야 할 때 사용됩니다. SOCK_RAM은 일반적으로 고급 사용자나 관리자가 실행하는 프로그램으로 제한됩니다.
socket.SOCK_SEQPACKET 안정적인 연속 패킷 서비스
프로토콜 매개변수:
0 (기본값) 특정 주소 계열과 관련된 프로토콜이 0인 경우 시스템은 주소 형식 및 소켓 범주에 따라 자동으로 하나를 선택합니다. 프로토콜
2. 소켓 객체 내장 메소드
서버측 소켓 함수
s.bind() 주소(IP 주소, 포트)를 소켓에 바인딩하고 매개변수는 튜플 형식이어야 합니다. 예: s.bind (('127.0.0.1',8009))
s.listen(5) 듣기 시작, 5는 보류 중인 최대 연결 수
s.accept() 클라이언트 연결을 수동적으로 수락, 차단, 연결 대기 중
Client 소켓 함수
s.connect() 서버에 연결합니다. 매개변수는 튜플 형식이어야 합니다. 예: s.connect(('127,0.0.1',8009))
공용 소켓 함수
s .recv(1024) TCP 데이터 수신, 1024는 데이터 수신 1회 크기
s.send(bytes) TCP 데이터 전송, python3 전송 데이터 형식은 바이트 형식이어야 함
s.sendall( ) 데이터 전송 그리고 내부 루프는 send
s.close()를 호출하여 소켓
예제 1. 소켓 프로그램의 간단한 구현
서버 측
#!/usr/bin/env python
# _*_ coding:utf-8 _*_
import socket
import time
IP_PORT = ('127.0.0.1',8009)
BUF_SIZE = 1024
tcp_server = socket.socket()
tcp_server.bind(IP_PORT)
tcp_server.listen(5)
while True:
print("waiting for connection...")
conn,addr = tcp_server.accept()
print("...connected from:",addr)
while True:
data = tcp_server.recv(BUF_SIZE)
if not data:break
tcp_server.send('[%s] %s'%(time.ctime(),data))
tcp_server.close()위 코드 설명:
1~4줄
첫 번째 줄은 Unix의 시작 정보 줄이고, 그 다음에는 시간 모듈과 소켓 모듈을 가져옵니다.
5~10줄
IP_PORT는 전역 변수에 대한 IP 주소와 포트를 선언하여 바인딩() 함수가 있음을 나타냅니다. 이 주소와 버퍼의 크기는 1K로 설정되고, Listen() 함수는 동시에 들어올 수 있는 최대 연결 수를 나타냅니다. 후속 연결은 거부됩니다
11~ 마지막 줄
서버의 루프에 들어간 후 연결이 도착할 때까지 수동적으로 기다립니다. 연결이 되면 대화 루프에 들어가 클라이언트가 데이터를 보낼 때까지 기다립니다. 메시지가 비어 있으면 클라이언트가 종료되었음을 의미하며 루프에서 벗어나 다음 연결이 도착할 때까지 기다립니다. 클라이언트 메시지를 받은 후 메시지 앞에 타임스탬프를 추가하고 반환합니다. 루프가 종료되지 않아 서버가 close()를 실행하지 않으므로 마지막 줄은 실행되지 않습니다. close() 함수를 호출하는 것을 잊지 마세요.
클라이언트 측
#!/usr/bin/env python
# _*_ coding:utf-8 _*_
import socket
HOST = '127.0.0.1'
PORT = 8009
BUF_SIZE = 1024
ADDR = (HOST,PORT)
client = socket.socket()
client.connect(ADDR)
while True:
data = input(">>> ")
if not data:break
client.send(bytes(data,encoding='utf-8'))
recv_data = client.recv(BUF_SIZE)
if not recv_data:break
print(recv_data.decode())
client.close()5~11행
HOST 및 PORT 변수는 서버의 IP 주소와 포트 번호를 나타냅니다. 데모가 동일한 서버에서 실행되므로 IP 주소는 모두 127.0.0.1입니다. 다른 서버에서 실행하는 경우 해당 수정이 필요합니다. 포트 번호는 서버의 포트 번호와 정확히 동일해야 합니다. 그렇지 않으면 통신이 불가능합니다. 버퍼 크기는 여전히 1K입니다.
클라이언트 소켓은 10번째 줄에서 생성된 후 서버에 연결됩니다.
13~21번째 줄
클라이언트도 다음 두 가지 조건 중 하나가 발생하면 무한 루프를 반복합니다. 1. 사용자 입력이 비어 있습니다. 또는 서버 응답 메시지가 비어 있습니다. 그렇지 않으면 클라이언트는 처리를 위해 사용자가 입력한 문자열을 서버로 보낸 다음 디스플레이 서버에서 반환한 타임스탬프가 포함된 문자열을 받습니다.
클라이언트 프로그램과 서버 프로그램을 실행합니다
다음은 클라이언트의 입력과 출력입니다
[root@pythontab]# python client.py >>> hello python [Thu Sep 15 22:29:12 2016] b'hello python'
다음은 서버의 출력입니다
[root@pythontab]# python server.py waiting for connection... ...connected from: ('127.0.0.1', 55378)
3.socketserver 모듈
socketserver는 표준 라이브러리. 네트워크 클라이언트 및 서버를 구현하는 데 필요한 대량의 상용구 코드를 단순화하는 데 사용됩니다. 사용할 수 있는 일부 클래스가 모듈에 구현되었습니다.
예제 1: 위의 소켓() 예와 동일한 기능을 달성하려면 소켓서버를 사용하세요
服务端程序代码
#!/usr/bin/env python
# _*_ coding:utf-8 _*_
import socketserver
import time
HOST = '127.0.0.1'
PORT = 8009
ADDR = (HOST,PORT)
BUF_SIZE = 1024
class Myserver(socketserver.BaseRequestHandler):
def handle(self):
while True:
print("...connected from:",self.client_address)
data = self.request.recv(BUF_SIZE)
if not data:break
self.request.send(bytes("%s %s"%(time.ctime(),data)))
server = socketserver.ThreadingTCPServer(ADDR,Myserver)
print("waiting for connection...")
server.serve_forever()11~17行
主要的工作在这里。从socketserver的BaseRequestHandler类中派生出一个子类，并重写handle()函数。
在有客户端发进来的消息的时候，handle()函数就会被调用。
19~21行
代码的最后一部分用给定的IP地址和端口加上自定义处理请求的类(Myserver)。然后进入等待客户端请求与处理客户端请求的无限循环中。
客户端程序代码
import socket
HOST = '127.0.0.1'
PORT = 8009
ADDR = (HOST,PORT)
BUF_SIZE = 1024
client = socket.socket()
client.connect(ADDR)
while True:
data = input(">>> ")
if not data:continue
client.send(bytes(data,encoding='utf-8'))
recv_data = client.recv(BUF_SIZE)
if not recv_data:break
print(recv_data.decode())
client.close()执行服务端和客户端代码
下面是客户端输出
[root@pythontab]# python socketclient.py >>> hello python Thu Sep 15 23:53:31 2016 b'hello python' >>> hello pythontab Thu Sep 15 23:53:49 2016 b'hello pythontab'
下面是服务端输出
[root@pythontab]# python socketserver.py waiting for connection... ...connected from: ('127.0.0.1', 55385) ...connected from: ('127.0.0.1', 55385) ...connected from: ('127.0.0.1', 55385) ...connected from: ('127.0.0.1', 55385)
위 내용은 Python의 소켓 모듈에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!