日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

前言

套接字除了前文用于分析網絡地址等功能之外，還可以配置一個服務器，監(jiān)聽到來的消息。

比如你在網絡上跟網絡機器人聊天，你發(fā)送數(shù)據到機器人(服務器)，然后服務器反饋聊天數(shù)據信息給你。當然，機器人的回復還涉及機器學習，但簡單的消息反饋涉及的就是套接字的知識。

而且，如果你直接將服務器配置為連接到其他應用的客戶端，那么雙向通信也可以實現(xiàn)。(比如QQ聊天)

簡單的搭建服務器與客戶端

既然已經了解了套接字的應用。下面，我們來實現(xiàn)一個簡單的單向通信TCP/IP服務器與客戶端。

服務器

服務器的原理如下：

1.首先創(chuàng)建一個套接字，TCP是面向流的套接字。故需要使用SOCK_STREAM。

2.然后使用bind()函數(shù)將套接字與服務器地址關聯(lián)(因為我們只是在本地測試，直接將地址設置為127.0.0.1或者localhost，端口號為10000)，當然你身邊如果有2臺電腦設備，可以直接替換局域網的IP地址

3.調用listen()函數(shù)將套接字設置為服務器模式，然后無限循環(huán)等待，參數(shù)為最大排隊數(shù)

4.在循環(huán)中，調用accept()等待客戶端的消息連接(當然，這里可以設置最大連接數(shù)，超過直接拒絕連接)。如果有客戶端進行連接，那么accept()函數(shù)會返回一個打開的連接與客戶端地址

5.指明一個緩沖區(qū)，該緩沖區(qū)用來存放recv函數(shù)接收到的數(shù)據

6.通過sendall()進行回傳客戶端數(shù)據。

7.傳回數(shù)據后，與當前的客戶端通信就算完成了。需要使用close()進行清理

示例代碼如下：

 
 
 
 

  
  
  
  
import socket 
  
  
  
  
 
  
  
  
  
# 1.創(chuàng)建一個套接字， 
  
  
  
  
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
  
  
  
  
# 2.使用bind()函數(shù)將套接字與服務器地址關聯(lián) 
  
  
  
  
sock.bind(('localhost', 10000)) 
  
  
  
  
# 3.調用listen()函數(shù)將套接字設置為服務器模式 
  
  
  
  
sock.listen(1) 
  
  
  
  
 
  
  
  
  
while True: 
  
  
  
  
    # 4.調用accept()等待客戶端的消息連接 
  
  
  
  
    # 如果有客戶端進行連接，那么accept()函數(shù)會返回一個打開的連接與客戶端地址 
  
  
  
  
    connection, client_address = sock.accept() 
  
  
  
  
    print("連接客戶端地址：", client_address) 
  
  
  
  
    try: 
  
  
  
  
        # 5.指明一個緩沖區(qū)，該緩沖區(qū)用來存放recv函數(shù)接收到的數(shù)據 
  
  
  
  
        data = connection.recv(1024) 
  
  
  
  
        print(data) 
  
  
  
  
        if data: 
  
  
  
  
            # 6.通過sendall()進行回傳客戶端數(shù)據。 
  
  
  
  
            connection.sendall("已接受到數(shù)據".encode()) 
  
  
  
  
        else: 
  
  
  
  
            print("客戶端沒有發(fā)送數(shù)據，不需要傳送數(shù)據") 
  
  
  
  
    finally: 
  
  
  
  
        #7.需要使用close()進行清理 
  
  
  
  
        connection.close() 
 
 
 
 

 客戶端

實現(xiàn)客戶端相對來說比服務器要簡單的多，因為其不需要監(jiān)聽，只需要連接發(fā)送數(shù)據即可?？蛻舳藢崿F(xiàn)主要分為：

1.創(chuàng)建一個套接字

2.使用connect()函數(shù)連接到服務器

3.通過sendall()向服務器發(fā)送數(shù)據

4.通過recv()接受服務器傳遞回的數(shù)據

5.交互完成之后，使用close()清理

示例如下：

 
 
 
 

  
  
  
  
import socket 
  
  
  
  
 
  
  
  
  
# 1.創(chuàng)建一個套接字， 
  
  
  
  
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
  
  
  
  
# 2.使用bind()函數(shù)將套接字與服務器地址關聯(lián) 
  
  
  
  
sock.connect(('localhost', 10000)) 
  
  
  
  
 
  
  
  
  
try: 
  
  
  
  
    msg = b"Are you there?" 
  
  
  
  
    # 3.通過sendall()向服務器發(fā)送數(shù)據 
  
  
  
  
    sock.sendall(msg) 
  
  
  
  
    # 4.通過recv()接受服務器傳遞回的數(shù)據 
  
  
  
  
    data = sock.recv(1024) 
  
  
  
  
    print(data.decode()) 
  
  
  
  
finally: 
  
  
  
  
    # 5.交互完成之后，使用close()清理 
  
  
  
  
    sock.close() 
 
 
 
 

 運行之后，服務器與客戶端交互效果如下：

create_connection(更簡易的客戶端)

連接服務器除了使用connect()函數(shù)之外，其實還有另一個函數(shù)create_connection()來連接服務器，它可以省略幾個步驟。示例如下：

 
 
 
 

  
  
  
  
import socket 
  
  
  
  
 
  
  
  
  
# 獲取匹配開頭字符串的所有屬性值 
  
  
  
  
def getConstants(prefix): 
  
  
  
  
    return { 
  
  
  
  
        getattr(socket, n): n 
  
  
  
  
        for n in dir(socket) 
  
  
  
  
        if n.startswith(prefix) 
  
  
  
  
    } 
  
  
  
  
 
  
  
  
  
ipproto_str = getConstants("IPPROTO_") 
  
  
  
  
family_str = getConstants("AF_") 
  
  
  
  
type_str = getConstants("SOCK_") 
  
  
  
  
 
  
  
  
  
sock = socket.create_connection(('127.0.0.1', 10000)) 
  
  
  
  
print(ipproto_str[sock.proto]) 
  
  
  
  
print(family_str[sock.family]) 
  
  
  
  
print(type_str[sock.type]) 
  
  
  
  
 
  
  
  
  
try: 
  
  
  
  
    msg = b"Are you there?" 
  
  
  
  
    sock.sendall(msg) 
  
  
  
  
    data = sock.recv(1024) 
  
  
  
  
    print(data.decode()) 
  
  
  
  
finally: 
  
  
  
  
    sock.close() 
 
 
 
 

 運行之后，效果如下：

create_connection()函數(shù)的原理是使用getaddrinfo()函數(shù)查找候選連接的參數(shù)，并返回一個打開的socket。getaddrinfo()函數(shù)的講解在上一篇socket庫。

本文名稱：socket庫：Python實現(xiàn)TCP/IP客戶和服務器通信
轉載源于：http://www.5511xx.com/article/dhisssg.html