1.tcp基本语法

# ### TCP协议 客户端
import socket
# 1.创建一个socket对象
sk = socket.socket()

# 2.与服务端建立连接
sk.connect( ("127.0.0.1" , 9000) )

# 3.收发数据的逻辑
"""发送的数据类型是二进制字节流"""
"""b开头的字符串是二进制字节流格式,要求字符类型必须是ascii编码"""
sk.send("今天我们学习网络编程".encode()) 

# 接受数据
res = sk.recv(1024)
print(res.decode())
# 4.关闭连接
sk.close()

 

# ### socket 服务端
"""
一发一收是一对,不匹配会导致数据异常
send 发送 recv 接受
"""
import socket

# 1.创建一个socket对象
sk = socket.socket()

# 一个端口绑定多个程序(仅在测试时使用)
sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)

# 2.在网络中注册该主机(绑定对应的ip和端口号)
""" 默认本地ip : 127.0.0.1  => localhost """
sk.bind(  ("127.0.0.1" , 9000) )
# 3.开启监听
sk.listen()

# 4.三次握手
conn,addr = sk.accept()

# 5.收发数据的逻辑

# 接受数据
"""一次最多接受1024个字节"""
res = conn.recv(1024)
print(res)
print(res.decode())

# 发送数据
conn.send("好好学习,天天向上".encode())

# 6.四次挥手
conn.close()

# 7.退还端口
sk.close()

2.tcp循环发消息

# ### 客户端
import socket

# (1) 创建socket对象
sk = socket.socket()
# (2) 连接服务端
sk.connect( ("127.0.0.1" , 9001) )
# (3) 收发数据的逻辑

while True:
    # 发送数据
    strvar = input("[客户端]请输入您要发送的数据>>>")
    sk.send(strvar.encode())
    
    # 接受数据
    res = sk.recv(1024)
    if res == b"q":
        break
    print(res.decode())
# (4) 关闭连接
sk.close()

 

# ### 服务端
import socket

# (1) 创建socket对象
sk = socket.socket()

# 一个端口绑定多个程序(仅在测试时使用)
sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)

# (2) 在网络中注册该主机(绑定ip和端口号)
sk.bind(  ("127.0.0.1" , 9001)  )
# (3) 监听端口
sk.listen()
# (4) 三次握手
# conn,addr = sk.accept()
# (5) 收发数据的逻辑

"""
print(conn)
print(addr)
<socket.socket fd=4, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=0, laddr=('127.0.0.1', 9000), raddr=('127.0.0.1', 50176)>
('127.0.0.1', 50176)
"""

while True:
    conn,addr = sk.accept()
    while True:
        # 接受数据
        res = conn.recv(1024)
        print(res.decode())
        
        # 发送数据
        strvar = input("[服务端]请输入您要发送的数据>>>")
        conn.send(strvar.encode())
        
        # 退出
        if strvar == "q":
            break

    # (6) 四次挥手
    conn.close()
    
# (7) 退还端口
sk.close() 

3.udp基本语法

# ### UDP协议 客户端
import socket 

# 1.创建udp对象
sk = socket.socket(type=socket.SOCK_DGRAM)

# 2.收发数据的逻辑
# 发送数据
msg = "你喜欢我么~"
# sendto(  二进制字节流 , ip端口号  )
sk.sendto(   msg.encode() ,  ("127.0.0.1",9000) )

# 接受数据
msg , addr = sk.recvfrom(1024)
print(msg.decode())
print(addr)

# 3.关闭连接
sk.close()
 

# ### UDP协议 服务端
import socket 

# 1.创建udp对象
sk = socket.socket(type=socket.SOCK_DGRAM)

# 2.在网络中注册该主机(绑定ip和端口号)
sk.bind( ("127.0.0.1",9000) )

# 3.收发数据的逻辑
"""udp协议下,默认第一次只能接收数据(没有三次握手,不清楚对方的ip和端口号)"""
# 接受数据
msg , addr  = sk.recvfrom(1024)
print(msg.decode())
print(addr)

# 发送数据
sk.sendto( "我喜欢你个锤子".encode()  , addr )

# 4.关闭连接
sk.close()

4.udp循环发消息

# ### udp 客户端
import socket

sk = socket.socket(type=socket.SOCK_DGRAM)

while True:
    # 发送数据
    strvar = input("[客户端]请输入您要发送的内容>>>")
    sk.sendto( strvar.encode() , ("127.0.0.1",9000) )
    
    # 接受数据
    msg , addr = sk.recvfrom(1024)
    print(msg.decode())
    
sk.close()

 

# ### udp 服务端
import socket 

sk = socket.socket(type=socket.SOCK_DGRAM)
sk.bind( ("127.0.0.1",9000) )

while True:
    # 接受数据
    msg , addr = sk.recvfrom(1024)
    print(msg.decode())
    print(addr)
    
    # 发送数据
    strvar = input("[服务端]请输入您要发送的内容>>>")
    sk.sendto( strvar.encode() ,  addr)
sk.close()

5.黏包

# ### 客户端
import socket
import time 

sk = socket.socket()
sk.connect( ("127.0.0.1",9001)  )

time.sleep(2)
# 收发数据的逻辑
res1 = sk.recv(1024)
print(res1.decode() , "<==1===>")
res2 = sk.recv(1024)
print(res2.decode() , "<==2===>")

sk.close()

# ### 服务端
import socket
import time
"""
黏包现象:
    (1)发送端,数据小,时间间隔短,造成黏包
    (2)接收端,没有及时接受数据,可能把多次发送的数据当成一条截取.
"""

sk = socket.socket()
sk.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
sk.bind( ("127.0.0.1",9001) )
sk.listen()
conn,addr = sk.accept()

# 收发数据的逻辑
conn.send("world,".encode())
time.sleep(1)
conn.send("hello".encode())

conn.close()
sk.close()