python socket 套接字編程 單進程服務器 實現多客戶端訪問

服務器：

import socket
#單進程服務器 實現多客戶端訪問 IO復用
#吧所有的客戶端套接字 放在一個列表里面，一次又一次的便利過濾
#這就是apache： select模型 6 server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) #設置端口復用
#AF_INET: IPV4
#AF_INET6: IPV6
#SOCK_STREAM: TCP
#SOCK_DGRAM: UDP
Host = ''
port = 23333
server.bind((Host,port))
#服務器綁定端口 8080
server.listen(5)
#服務器同時監聽5個 最大鏈接數 5

print('[+]  server open')

c_server = {}
#定義一個全局字典
server.setblocking(0)
#設置服務器recv接受信息和send發送信息為非阻塞狀態（默認為阻塞狀態）
#是否阻塞（默認True），如果設置False，那么accept和recv時一旦無數據，則報錯。
while True:
    try:
        try:

            client,c_addr = server.accept()

        except BlockingIOError:
            #無法立即完成一個非阻止性套接字操作。
            if not c_server:
                #如果字典為空
                continue
                #重新接收套接字
            pass
        else:
            client.setblocking(0)#設置套接字屬性為非阻塞
            #是否阻塞（默認True），如果設置False，那么accept和recv時一旦無數據，則報錯。
            #[WinError 10035] 無法立即完成一個非阻止性套接字操作。
            c_server[client] = c_addr#以字典形式存儲新鏈接的套接字
            print('[+] from',c_addr)
        for a in list(c_server.keys()):
            #這里將字典的keys取出來 在列表化,在沒有信息的時候刪除套接字了
            try:
                msg = a.recv(1024).decode('utf-8')
                #非阻塞接受消息，但是如果客戶端不馬上發送，就會報錯，所以設置一個延遲接收
            except BlockingIOError as e:
                continue

            if not msg:
                print('[%s] closed'%(c_server[a][0]))
                a.close()
                del c_server[a]
                continue
            print("來自%s的消息： %s"%(c_server[a][0],msg))
            a.send(msg.encode('utf-8'))
            #發送重復的消息
    except KeyboardInterrupt:
        break


server.close()

 

 

客戶端：

 

 

#coding:utf-8

import socket
client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#創建一個客戶端鏈接,socket.AF_INET代表ipv4，socket.SOCK_STREAM代表tcp套接字
client.connect(('127.0.0.1',23333))
#客戶端鏈接
print('[+]  鏈接成功')
#鏈接成功顯示
while True:
    msg = input('>>>')
    if msg == 'quit':
        #如果輸入的信息是quit  就退出鏈接
        break
    if len(msg) == 0:#如果直接輸入的一個回車的話
    #就重新輸入,因為不能發送空 ，發送空的花  客戶端會卡住
        continue
    client.send(msg.encode('utf-8'))
    #客戶端發送信息msg  以utf8格式發送數據
    data = client.recv(1024).decode('utf-8')
    if not data:
        #如果數據為空/0  
        #服務器主動斷開s
        break
        print('[+]  服務器主動斷開了鏈接......')

    print('服務器發來：',data)


print('[+]  鏈接關閉...')

client.close()

 

服務器就是apache： select模型