• 1. socket()類

  # socket語(yǔ)法
  socket(socket_family, socket_type, protocol=0)
  # soket_family: AF_UNIT, AF_INET, AF_INET6...
  # socket_type: SOCK_STREAM(TCP), SOCK_DGRAM(UDP)
  # protocol默認(rèn)為0
  
  # 創(chuàng)建TCP/IPv4套接字
  tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  # 創(chuàng)建UDP/IPv6套接字
  tcpSock = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM)
  

• 2. 套接字對(duì)象（內(nèi)置）方法

• 3. 創(chuàng)建 TCP 服務(wù)器
     $ vim tsTserv.py

  1 #!/usr/bin/python3
  2 # coding=utf-8
  3 
  4 # 導(dǎo)入socket模塊抄沮，和時(shí)間模塊的ctime()方法，返回當(dāng)前時(shí)間戳
  5 import socket
  6 from time import ctime
  7 
  8 HOST = ''       # 空白地址除抛，表示任何可用的地址
  9 PORT = 6666     # 隨機(jī)端口
 10 BUFSIZ = 1024           # 緩沖區(qū)大小
 11 ADDR = (HOST, PORT)     # 地址
 12 
 13 # 創(chuàng)建一個(gè)tcp/ip套接字
 14 tcpSerSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 15 # 綁定的ip和端口并開啟監(jiān)聽
 16 tcpSerSock.bind(ADDR)
 17 # 傳入連接請(qǐng)求的最大數(shù)
 18 tcpSerSock.listen(5)
 19 
 20 # 等待用戶客戶端連接
 21 while True:
 22     # 輸出提示信息
 23     print('[*] waiting for connection...')
 24     # 被動(dòng)接受tcp連接，一直等待知道連接為止tcpCliSock為套接字母截，addr為元組（str, int）
 25     (tcpCliSock, addr) = tcpSerSock.accept()
 26     # 打印連接信息
 27     print('[+]...connected from: %s: %d' % (addr[0], addr[1]))
 28      
 29 
 30     # 接受用戶輸入并返回
 31     while True:
 32         # 接受BUFSIZ大小數(shù)據(jù)
 33         data = tcpCliSock.recv(BUFSIZ)
 34         # 當(dāng)數(shù)據(jù)為空到忽，則用戶關(guān)閉連接，退出
 35         if not data:
 36             break
 37         # 返回時(shí)間戳+數(shù)據(jù),python3使用byte
 38         tcpCliSock.send(b'[%s] %s' % (bytes(ctime(), 'utf-8'), data))
 39     # 關(guān)閉客戶端連接
 40     tcpCliSock.close()
 41 # 關(guān)閉服務(wù)器
 42 tcpSerSock.close()

• 4. 創(chuàng)建 TCP 客戶端
     $ vim tsTclnt.py

  1 #!/usr/bin/python3
  2 # coding=utf-8
  3 
  4 import socket
  5 
  6 HOST = '127.0.0.1'
  7 PORT = 6666
  8 BUFSIZ = 1024
  9 ADDR = (HOST, PORT)
 10 
 11 tcpClntSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 12 # 連接目標(biāo)主機(jī)
 13 tcpClntSock.connect(ADDR)
 14 
 15 while True:
 16     # 輸入發(fā)送的數(shù)據(jù)
 17     data = input(">>> ")
 18 
 19     # 判斷是否退出
 20     if data == 'exit':
 21         break
 22 
 23     # 發(fā)送信息清寇，byte
 24     tcpClntSock.send(bytes(data, 'utf-8'))
 25     # 接受返回的數(shù)據(jù)
 26     result = tcpClntSock.recv(BUFSIZ)
 27     if not result:
 28         break
 29     # 打印數(shù)據(jù)喘漏，解碼
 30     print(bytes.decode(result))
 31 # 關(guān)閉連接
 32 tcpClntSock.close()

• 5. 執(zhí)行 TCP 服務(wù)器和客戶端

# 終端1
$ ./tsTserv.py                          #先開啟服務(wù)端
[*] waiting for connection...           #等待用戶連接
[+]...connected from: 127.0.0.1: 36712  #有客戶端連接
[*] waiting for connection...           #連接斷開，等待新的連接
# 終端2
$ ./tsTclnt.py                          #開啟客戶端
>>> hello                               #發(fā)送
[Mon Nov 27 08:36:45 2017] hello        #回包
>>> good bey                            #發(fā)送
[Mon Nov 27 08:37:36 2017] good bey     #回包
>>> exit                                #退出關(guān)閉連接

• 6. 創(chuàng)建 UDP 服務(wù)器

  1 #!/usr/bin/python3
  2 # coding=utf-8
  3
  4 import socket
  5 from time import ctime
  6
  7 HOST = '127.0.0.1'
  8 PORT = 6666
  9 BUFSIZ = 1024
 10 ADDR = (HOST, PORT)
 11
 12 udpSerSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
 13 udpSerSock.bind(ADDR)
 14
 15 while True:
 16     print('[*] waiting for message...')
 17     # 接受數(shù)據(jù)
 18     (data, addr) = udpSerSock.recvfrom(BUFSIZ)
 19     # 返回?cái)?shù)據(jù)
 20     udpSerSock.sendto(b'[%s] %s' % (bytes(ctime(), 'utf-8'), data), addr)
 21     # 打印信息
 22     print('[+]...received from and returned to: %s: %d' % (addr[0], addr[1]))
 23 udpSerSock.close()

• 7. 創(chuàng)建 UDP 客戶端

  1 #!/usr/bin/python3
  2 # coding=utf-8
  3
  4 import socket
  5
  6 HOST = '127.0.0.1'
  7 PORT = 6666
  8 BUFSIZ = 1024
  9 ADDR = (HOST, PORT)
 10
 11 udpClntSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
 12
 13 while True:
 14     data = input(">>> ")
 15
 16     if data == 'exit':
 17         break
 18
 19     # 發(fā)送信息华烟，byte
 20     udpClntSock.sendto(bytes(data, 'utf-8'), ADDR)
 21     # 接受返回的數(shù)據(jù)
 22     (result, ADDR) = udpClntSock.recvfrom(BUFSIZ)
 23     if not result:
 24         break
 25     print(bytes.decode(result))
 26 udpClntSock.close()

• 8. 執(zhí)行 UDP 服務(wù)器和客戶端

# 終端1
$ ./tsUserv.py                                         #開啟udp服務(wù)器
[*] waiting for message...
[+]...received from and returned to: 127.0.0.1: 39160      #接受并返回
[*] waiting for message...
[+]...received from and returned to: 127.0.0.1: 39160
[*] waiting for message...

# 終端2
$ ./tsUclnt.py
>>> hello
[Mon Nov 27 10:25:27 2017] hello
>>> good bey!
[Mon Nov 27 10:25:34 2017] good bey!
>>> exit

• 9. socket 模塊屬性