網絡編程: 基於TCP協議的socket, 實現一對一, 一對多通信

TCP協議  面向連接 可靠的 面向字節流形式的

 

tcp是基於鏈接的，必須先啟動服務端，然后再啟動客戶端去鏈接服務端

 

TCP協議編碼流程:

服務器端:             　　   客戶端

實例化對象               　  實例化對象

綁定IP地址和端口號         

監聽

接收客戶端的連接           連接服務器

收發                      　　 收發

關閉                   　　    關閉

 

 

 

問題：有的同學在重啟服務端時可能會遇到

解決方法： 

#加入一條socket配置，重用ip和端口
import socket
from socket import SOL_SOCKET,SO_REUSEADDR
sk = socket.socket()
sk.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) #就是它，在bind前加
sk.bind(('127.0.0.1',8898))  #把地址綁定到套接字
sk.listen()          #監聽鏈接
conn,addr = sk.accept() #接受客戶端鏈接
ret = conn.recv(1024)   #接收客戶端信息
print(ret)              #打印客戶端信息
conn.send(b'hi')        #向客戶端發送信息
conn.close()       #關閉客戶端套接字
sk.close()        #關閉服務器套接字(可選)

 

 

tcp三次握手: 一定是client先發起請求

             a 客戶端發起請求連接服務器

             b 服務器返回:接收到請求,並要求連接客戶端

             c 客戶端回復:可以連接

四次揮手:  誰先發起斷開連接的請求都可以

             a 客戶端發起斷開連接的請求:

                  意思是: 我想和你斷開連接,我沒有數據要繼續發送了,但是如果你有數據需要發送,我可以繼續接收

             b  服務器回復 : 我接收到你的請求了

             c  服務器發送 : 我已經准備好斷開連接了

             d  客戶端回復 : 收到你的信息,斷開連接

 

 

 tcp實現的一個聊天室, 可以實現一對多,但是必須斷掉別人的連接, 然后才能和下一個人聊,本質還是一對一

只是創建一個死循環,讓服務器一直處於待機狀態  

while 1:
    conn,addr = sk.accept()

 

import socket


sk = socket.socket()
sk.bind(('127.0.0.1',8888))
sk.listen()

while 1:

    conn,addr = sk.accept()

    msg_r = conn.recv(1024)
    if msg_r.decode('utf-8') != 'q':
        print(msg_r.decode('utf-8'))

    else:
        break

    msg_s = input('>>>')
    if msg_s != 'q':
        conn.send(msg_s.encode('utf-8'))
    else:
        conn.send(msg_s.encode('utf-8'))
        break

import socket

name = input('請輸入你的名字:\n')

sk = socket.socket()
sk.connect(('127.0.0.1', 8888))


while 1:

    msg_s = input('>>>')
    if msg_s != 'q':
        sk.send((name + msg_s).encode('utf-8'))
    else:
        sk.send(msg_s.encode('utf-8'))
        break

    msg_r = sk.recv(1024)
    if msg_r != 'q':
        print(msg_r.decode('utf-8'))
    else:
        break

sk.close()

import socket

name = input('請輸入你的名字:\n')

sk = socket.socket()
sk.connect(('127.0.0.1', 8888))

while 1:

    msg_s = input('>>>')
    if msg_s != 'q':
        sk.send((name + msg_s).encode('utf-8'))
    else:
        sk.send(msg_s.encode('utf-8'))
        break

    msg_r = sk.recv(1024)
    if msg_r != 'q':
        print(msg_r.decode('utf-8'))
    else:
        break

sk.close()