python TCP socket套接字编程以及注意事项

TCPServer.py

#coding:utf-8

import socket
#s 等待链接
#c 实时通讯
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#socket.AF_INET代表ipv4，socket.SOCK_STREAM代表tcp套接字
s.bind(('',23333))
#绑定ip端口  如果为空，那就是所有网络号都可以
s.listen(5)
#最大同时5个人链接


print('[+]服务端开启')

while True:
    try:
        c,c_addr = s.accept()
        #这里只能接受一个人链接，如果要链接多个客户端，需要开启多线程
        #先接受客户端的连接
        #阻塞形式
        #client 通讯操作的套接字
        #c_addr 是客户端的地址

        print('有人来链接了:',c_addr)
        while True:
            data = c.recv(1024).decode('utf-8')
            #客户端断开链接 会发送一个空字符串，长度为0
            #data存储的是最大1024字节的数据 
            #要decode解码，以utf8的形式
            if not data:
                #判断接受到的数据，是不是为空，如果为空的话 就表示客户端已经断开链接
                # print(type(data))
                # print('----------')
                # print(len(data))
                # print('----------')
                print('[+] 这个人走了')
                break
                #跳出循环，断开链接
            print('这个人说',data)
            msg = input('>>>')
            #回复客户端
            if msg == 'quit':
                #如果 msg为 quit  就与客户端主动断开链接
                print('[+]  与这个人主动断开链接.....')
                break
            c.send(msg.encode('utf-8'))
            #发送的时候加码，以uff8的形式
        c.close()
        #断开与客户端的连接
    except KeyboardInterrupt:
        #ctrl+c终止程序 防止卡主
        print('检测到异常 即将推出')
        break

print('[+]  服务器关闭')
s.close()

TCPclient.py

#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()

#注意事项：

• 网络中传输数据的格式是二进制，所以传输的数据都要编码和解码，默认是UTF-8
• 代码中发送和接受的数据最大为1024字节，如果大于这个数据，数据会留在缓冲区，等待下一次发送，如果要一次性发送，需要用到循环语句
• 客户端和服务器如果断开连接的话，会发送一个空字符串，长度为0，然后对方用一个判断语句来判断是否断开链接
• 发送的数据不能为空，假如直接按回车的话 会发送空，是不行的，程序会卡住，input对于用户输入的换行是不会读入的，因为我们都知道input是以换行作为输入结束的标志的。
  • 对于空消息：tcp是基于数据流的，于是收发的消息不能为空，这就需要在客户端和服务端都添加空消息的处理机制，防止程序卡住，
  • 
  • QQ也是这样的，不能发送为空的内容

TCP套接字模型

• 服务器套接字创建模型：

  • s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)

  • s.bind( ('', 8000) )：绑定该套接字有效地址和端口

    • 参数是一个元组

  • s.listen(5) 开启服务器

  • c,c_addr = s.accept() 阻塞等待客户端连接

    • c：客户端来访套接字来与客户端进行交流

    • c_addr：客户来访地址，(ip,port)

  • while：具体和这个客户端进行沟通

    • c.send(msg)

      • 发送数据

      • msg == byte

    • data = c.recv(1024)： -> bytes

      • 接收数据

      • 接收到的也是个二进制

    • 取决于客户端发来的数据如果为空，那么就可以关闭与他的连接了。

  • c.close()

    • 关闭套接字 释放资源

  • s.close()

• ---

• • 客户端套接字模型：

    • c = socket.socket(socket.AF_INET,socket.SOCK_STREAM)

    • c.connect( (ip,port) )

      • 47.104.224.67

      • 8000

    • c.recv() 接收

    • c.send() 发送

    • c.close()

      • 关闭套接字 断开连接 释放资源

• 单进程模型下，我们写的代码，同一时间只能处理一个用户的来访信息

  • TCP是要构成连接的