import socket

import random
import socket
#1.創(chuàng)建服務(wù)器對(duì)象
server=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
# 參數(shù)1:socket.AF_INET, 表示 ipv4地址
# 參數(shù)2：socket.SOCK_STREAM表示 tcp協(xié)議封裝好的參數(shù)
#2.獲取當(dāng)前計(jì)算機(jī)地址的代碼
p=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
p.connect(('8.8.8.8',80))
nowip=p.getsockname()[0]
p.close()
port=8888
print('當(dāng)前的ip地址：',nowip)
print('當(dāng)前端口號(hào)：',port)
#3.把服務(wù)器綁定到本計(jì)算機(jī)上
server.bind((nowip,port))
#4.設(shè)置監(jiān)聽模式，設(shè)置最大的監(jiān)聽數(shù)
server.listen(128) #設(shè)置最大的連接數(shù)128
print('服務(wù)端已啟動(dòng)，等待連接……')
#5.等待客戶的連接
conn, addr = server.accept()
# conn 是連接客戶端的套接字對(duì)象
# addr 是表示客戶端的連接地址
while 1:
    try:
        #6.接受客戶端的數(shù)據(jù)
        #網(wǎng)絡(luò)數(shù)據(jù)都是以字節(jié)流的形式去發(fā)送的
        data=conn.recv(1024).decode('utf8') #參數(shù)1024表示每次接受最大的字節(jié)數(shù),decode進(jìn)行解碼，由字節(jié)流編碼轉(zhuǎn)換為字符
        if not data:#當(dāng)接受到空數(shù)據(jù)的時(shí)候就說明客戶端斷開了連接
            print(f'{addr}斷開了連接')
            break
        print(f'----{addr}發(fā)送了----',data)
        #7.返回一個(gè)0~100的隨機(jī)數(shù)數(shù)據(jù)給客戶端
        conn.send(str(random.randint(0,100)).encode('utf8'))#進(jìn)行字節(jié)流編碼發(fā)送
    except ConnectionResetError:
        print('error')
        break
#7.關(guān)閉套接字對(duì)象
conn.close()
#8.關(guān)閉服務(wù)器
server.close()

#客戶端
import socket
#1.創(chuàng)建客戶端對(duì)象
client=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#2.連接服務(wù)器地址和端口
client.connect(('10.33.110.204',8888))
count=1 #計(jì)數(shù)
while 1:
    a=input(r'輸入你要發(fā)送的內(nèi)容(\q退出):').strip()
    if a==r'\q':
        break
    if not a: #當(dāng)發(fā)送的數(shù)據(jù)為空時(shí)就重新輸入
        print('發(fā)送的數(shù)據(jù)不能為空')
        continue
    #3.把數(shù)據(jù)發(fā)送給服務(wù)器    
    client.send(a.encode('utf8'))
    #4.獲取到服務(wù)器發(fā)送的數(shù)據(jù)
    data = client.recv(1024)  # receive
    if not data:
        break
    print(f'對(duì)方發(fā)送的消息--{count}--:',data.decode("utf8"))
    count+=1
#5.關(guān)閉客戶端
client.close()