socket

# socket 是一套接口,封装了网络编程协议

socket是位于应用层与传输层之间的一个抽象层
专门把传输层以下的协议封装成接口提供给应用层使用
应用只需要调用socket的接口或者说按照socket的标准编写
程序，写出的程序自然是遵循tcp/ip协议

1, #===================================server.py

import socket



#作为服务器必须明确自己的IP和端口号,并且不应该改变
#参数1 指定socket类型  socket.AF_INET 表示网络类型
#参数2 指定的传输协议为 socket.SOCK_STREAM 表示为TCP协议  socket.SOCK_DGRAM协议表示UDP协议
# server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)     #1,买电话机

#默认是网络类型  TCP协议
server = socket.socket()

#127.0.0.1 这叫回送地址   表示当前电脑本身
# ip 一定是本机IP  本机可能会有多个IP(无线|有线)
#注意:需要参数就是一个元组,端口就是普通参数
server.bind(('127.0.0.1',8989))     #2,插入手机卡

#无论是服务器还是客户端 , 都是socket类型

#开始监听1688端口  盯着这个端口看以后没有数据过去
server.listen(4)                 #3,手机开始待机

#接受链接请求
#第一个表示客户端的socket        第二个客户端的地址信息
cilent,add = server.accept()    #4,接电话


#5,收发数据
data = cilent.recv(1024)
print(data.decode('utf-8'))

cilent.send('你好,我是服务端!'.encode('utf-8'))

server.close()



#=================================client.py

import socket

#买个电话
cilent = socket.socket()

# 作为客户端 ip 和端口可以变化,所有系统会自动分配随机端口给客户端
cilent.connect(('127.0.0.1',8989))

#开始通话
#发送数据,注意发送的内容只能是二进制  bytes
cilent.send('hello ,我是客户端'.encode('utf-8'))

#接收数据  单位为字节
data = cilent.recv(1024)
print(data.decode('utf-8'))

cilent.close()

2 ,#==========================client.py

import  socket

client = socket.socket()

#connect 本质实在进行三次握手,也是一个数据传输的过程,如果服务器没有立马响应,也会阻塞
client.connect(('127.0.0.1',8989))  #三次握手
print('握手成功! client')

#发送数据,本质是把数据交给操作系统来进行发送,一旦数据交给了操作系统,后续的发送
#应用程序就无法控制了,send一般不会卡,当然,如果数据很大就会阻塞
client.send('hello'.encode('utf-8'))
print('发送完成')

#是从操作系统缓存区读取数据,如果当前还没有任何数据,就会进入阻塞
#会一直等到有数据到来,在继续执行
try:
    data = client.recv(1024)
    print('接受完成')
    print(data)
except:
        print('服务器 强行下线了')

import time
time.sleep(4)
#客户端执行close是正常关闭链接,会给服务器送空字节,用于表示要断开链接
client.close()
print('客户端关机了')



#==========================server.py

import  socket

server = socket.socket()

server.bind(('127.0.0.1',8989))     #只有服务器需要绑定

server.listen(4)

#accept 是一个阻塞函数  会一直等到有客户端链接过来,在继续执行
cilent,addr = server.accept()   #完成了三次握手
print(cilent,addr)     #('127.0.0.1', 61638)

print('握手成功!')
#收发数据  注意都是用表示客户端的socket来收发数据
cilent.send('world'.encode('utf-8'))

import time
time.sleep(3)


try:
    data = cilent.recv(1024)
    print('客户端发来的数据',data)
    #发送数据时,对方可能也会异常下线,也会抛出异常
    #接受数据和发送数据都应该放到try
    cilent.send('test'.encode('utf-8'))
except:
        print('cilent 下线了')
        #断开链接
        cilent.close()  #完成四次挥手

server.close()
print("服务器关机!")

3 ,加上循环 #=========================client.py

import socket
client = socket.socket()

#指定服务器的端口和ip  客户端的端口系统会自动分配
client.connect(('127.0.0.1',8989))

#添加循环,用来重复接收数据
while True:
    #收发的顺序  必须和对面相反,否则会卡死
    msg = input('输入内容:')
    if not msg:continue
    #发送信息
    client.send(msg.encode('utf-8'))
    print('发送%s完成!'%msg)
    #接收信息
    data = client.recv(1024)
    print('接收到:%s'%data.decode('utf-8'))

client.close()


#=====================================server.py

import socket
server = socket.socket()
server.bind(('127.0.0.1',8989))
server.listen(5)

while True:
    client_socket,client_addr = server.accept()
    buffer_size = 1024  #缓冲区  就是一个临时的容器
    #缓冲区大小  不能随便写,太大会导致内存溢出 ,太小效率低下,在内存能够承受的情况下,可以打一些

    while True:
        try:
            #接收数据
            data =client_socket.recv(1024)
            #在linux中,对方如果强行下线了,服务器不会抛出异常,只会收到空消息
            #得加上以下判断,如果为空则意味着 对方下线了,应该关闭链接,跳出循环
            #windows上如果输入Q正常关闭,也会收到空消息不会抛异常会一直循环空,所有if必须要加
            if not data:
                client_socket.close()
                break

            print('接收到%s'%data.decode('utf-8')) #解码时必须保证双方统一编码方式

            #发送数据,转为大写在发回去
            client_socket.send(data.upper())

        except ConnectionResetError as e:
            print('%s %s'%(client_addr[0],client_addr[1]),e)
            #如果对方下线了,那服务器也应该关闭对应的客户端对象
            client_socket.close()
            break

#通常服务器不会关闭
# server.close()

4 ,加上异常 #==============================client.py

import  socket

client = socket.socket()

#connect 本质实在进行三次握手,也是一个数据传输的过程,如果服务器没有立马响应,也会阻塞
client.connect(('127.0.0.1',8989))  #三次握手
print('握手成功! client')

#发送数据,本质是把数据交给操作系统来进行发送,一旦数据交给了操作系统,后续的发送
#应用程序就无法控制了,send一般不会卡,当然,如果数据很大就会阻塞
client.send('hello'.encode('utf-8'))
print('发送完成')

#是从操作系统缓存区读取数据,如果当前还没有任何数据,就会进入阻塞
#会一直等到有数据到来,在继续执行
try:
    data = client.recv(1024)
    print('接受完成')
    print(data)
except:
        print('服务器 强行下线了')

import time
time.sleep(4)
#客户端执行close是正常关闭链接,会给服务器送空字节,用于表示要断开链接
client.close()
print('客户端关机了')



#==================================server.py

import  socket

server = socket.socket()

server.bind(('127.0.0.1',8989))     #只有服务器需要绑定

server.listen(4)

#accept 是一个阻塞函数  会一直等到有客户端链接过来,在继续执行
cilent,addr = server.accept()   #完成了三次握手
print(cilent,addr)     #('127.0.0.1', 61638)

print('握手成功!')
#收发数据  注意都是用表示客户端的socket来收发数据
cilent.send('world'.encode('utf-8'))

import time
time.sleep(3)


try:
    data = cilent.recv(1024)
    print('客户端发来的数据',data)
    #发送数据时,对方可能也会异常下线,也会抛出异常
    #接受数据和发送数据都应该放到try
    cilent.send('test'.encode('utf-8'))
except:
        print('cilent 下线了')
        #断开链接
        cilent.close()  #完成四次挥手

server.close()
print("服务器关机!")

5, 端口占用问题:=============================server.py

import socket
server = socket.socket()

server.bind(('127.0.0.1',9090))
server.listen()
server.accept()
server.close()

#如果已经开启了服务器,再次运行将会抛出端口占用异常,把之前开启的服务器关掉即可
'''
有些情况 明明关闭了进程,但是还是端口占用
可能是进程正在后台运行,可以通过端口查出进程,进行关闭

解决方式一 : 杀进程
windows下
netstat -ano| findstr 9090
tasklist | findstr 进程id 拿到进程名称
taskkill /f /t /im 进程名称

解决方式二:
    重启电脑

'''